Feature Release - KafkaTestCluster

3.0.0 (5/29/2018)

• Added ability to start one or more Kafka brokers configured within a functional cluster. This allows you to now to test functionality that depends on more than one broker within your cluster, as well as scenarios around how your code handles broker availability.
• Expanded the methods available in the KafkaTestUtils class.

Breaking Changes

• Several accessors were removed from SharedKafkaTestResource and should now be accessed
  via the KafkaTestUtils class. In most cases simply changing from sharedKafkaTestResource.getKafkaServer().... to sharedKafkaTestResource.getKafkaTestUtils()... will be sufficient to migrate your code.

Feature Release

2.3.0 (5/17/2018)

• Issue-12 Added ability to pass broker properties to be used by test kafka service instance.

• Added helper method getAdminClient() on KafkaTestServer to get a configured AdminClient instance.

• Deprecated Kafka-JUnit5 @ExtendWith annotation implementations. This has been replaced in favor of @RegisterExtension annotation. Review README.md for more information on updated usage instructions.

• Deprecated KafkaTestServer constructor: public KafkaTestServer(final String localHostname)

  This constructor was replaced with the constructor KafkaTestServer(final Properties overrideBrokerProperties) where overrideBrokerProperties should contain the property host.name set to the hostname or IP address Kafka should use.

v2.2.0

2.2.0 (4/24/2018)

• Issue-5 Updated to support Kafka versions 1.0.x and 1.1.x. Thanks kasuri!
• Issue-4 Fix server configuration to allow for transactional producers & consumers.

Breaking Change

This library now requires you to provide which version of Kafka you want to use.

See below for an example...for more details refer to README.

<!-- Declare kafka-junit4 dependency -->
<dependency>
    <groupId>com.salesforce.kafka.test</groupId>
    <artifactId>kafka-junit4</artifactId>
    <version>2.2.0</version>
    <scope>test</scope>
</dependency>

<!-- Now required to include a kafka dependencies explicitly -->
<dependency>
    <groupId>org.apache.kafka</groupId>
    <artifactId>kafka_2.11</artifactId>
    <version>0.11.0.1</version>
    <scope>test</scope>
</dependency>
<dependency>
    <groupId>org.apache.kafka</groupId>
    <artifactId>kafka-clients</artifactId>
    <version>0.11.0.1</version>
    <scope>test</scope>
</dependency>

v2.1.0

2.1.0 (4/24/2018)

• Issue-5 Updated to support Kafka versions 1.0.x and 1.1.x. Thanks kasuri!

Breaking Change

This library now requires you to provide which version of Kafka you want to use.

See below for an example...for more details refer to README.

<!-- Declare kafka-junit4 dependency -->
<dependency>
    <groupId>com.salesforce.kafka.test</groupId>
    <artifactId>kafka-junit4</artifactId>
    <version>1.0.1</version>
    <scope>test</scope>
</dependency>

<!-- Now required to include a kafka dependencies explicitly -->
<dependency>
    <groupId>org.apache.kafka</groupId>
    <artifactId>kafka_2.11</artifactId>
    <version>0.11.0.1</version>
    <scope>test</scope>
</dependency>
<dependency>
    <groupId>org.apache.kafka</groupId>
    <artifactId>kafka-clients</artifactId>
    <version>0.11.0.1</version>
    <scope>test</scope>
</dependency>

v2.0.0

2.0.0 (4/10/2018)

• Created new modules supporting both JUnit4 and JUnit 5.

v1.0.0

• Initial release!
• Based off of Kafka Server and Kafka-Clients version 0.11.0.1