Skip to content

Commit

Permalink
chore(deps) : Upgrade to kafka 7.5.3
Browse files Browse the repository at this point in the history
  • Loading branch information
rajadilipkolli committed Jan 6, 2024
1 parent 418c44f commit f6cf6f0
Show file tree
Hide file tree
Showing 10 changed files with 11 additions and 11 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -35,7 +35,7 @@ class SpringBootKafkaAvroConsumerApplicationTests {
@Autowired KafkaProducer kafkaProducer;

private static final Network KAFKA_NETWORK = Network.newNetwork();
private static final String CONFLUENT_PLATFORM_VERSION = "7.5.2";
private static final String CONFLUENT_PLATFORM_VERSION = "7.5.3";
private static final DockerImageName KAFKA_IMAGE =
DockerImageName.parse("confluentinc/cp-kafka").withTag(CONFLUENT_PLATFORM_VERSION);
private static final KafkaContainer KAFKA =
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -60,7 +60,7 @@ public Statement apply(Statement base, Description description) {
@Bean
@ServiceConnection
KafkaContainer kafkaContainer() {
return new KafkaRaftWithExtraListenersContainer("confluentinc/cp-kafka:7.5.2")
return new KafkaRaftWithExtraListenersContainer("confluentinc/cp-kafka:7.5.3")
.withAdditionalListener(() -> "kafka:19092")
.withKraft()
.withNetwork(network)
Expand All @@ -72,7 +72,7 @@ KafkaContainer kafkaContainer() {
@DependsOn("kafkaContainer")
GenericContainer<?> schemaregistry(DynamicPropertyRegistry dynamicPropertyRegistry) {
GenericContainer<?> schemaRegistry =
new GenericContainer<>("confluentinc/cp-schema-registry:7.5.2")
new GenericContainer<>("confluentinc/cp-schema-registry:7.5.3")
.withExposedPorts(8085)
.withNetworkAliases("schemaregistry")
.withNetwork(network)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -29,7 +29,7 @@ PostgreSQLContainer<?> postgresContainer() {
@ServiceConnection
KafkaContainer kafkaContainer(DynamicPropertyRegistry propertyRegistry) {
KafkaContainer kafkaContainer = new KafkaContainer(
DockerImageName.parse("confluentinc/cp-kafka").withTag("7.5.2"))
DockerImageName.parse("confluentinc/cp-kafka").withTag("7.5.3"))
.withKraft();
propertyRegistry.add("spring.kafka.bootstrapServers", kafkaContainer::getBootstrapServers);
return kafkaContainer;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -24,7 +24,7 @@ public class TestBootKafkaReactorProducerApplication {
@ServiceConnection
KafkaContainer kafkaContainer(DynamicPropertyRegistry propertyRegistry) {
KafkaContainer kafkaContainer = new KafkaContainer(
DockerImageName.parse("confluentinc/cp-kafka").withTag("7.5.2"))
DockerImageName.parse("confluentinc/cp-kafka").withTag("7.5.3"))
.withKraft();
propertyRegistry.add("spring.kafka.bootstrapServers", kafkaContainer::getBootstrapServers);
return kafkaContainer;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,7 @@ GenericContainer<?> zipkinContainer() {
@ServiceConnection
KafkaContainer kafkaContainer(DynamicPropertyRegistry dynamicPropertyRegistry) {
KafkaContainer kafkaContainer = new KafkaContainer(
DockerImageName.parse("confluentinc/cp-kafka").withTag("7.5.2"))
DockerImageName.parse("confluentinc/cp-kafka").withTag("7.5.3"))
.withKraft()
.withReuse(true);
// Connect our Spring application to our Testcontainers Kafka instance
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@ public class TestBootKafkaSampleApplication {
@Bean
@ServiceConnection
KafkaContainer kafkaContainer() {
return new KafkaContainer(DockerImageName.parse("confluentinc/cp-kafka").withTag("7.5.2")).withKraft();
return new KafkaContainer(DockerImageName.parse("confluentinc/cp-kafka").withTag("7.5.3")).withKraft();
}

public static void main(String[] args) {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,7 @@ class TestCloudKafkaSampleApplication {
@ServiceConnection
KafkaContainer kafkaContainer(DynamicPropertyRegistry dynamicPropertyRegistry) {
KafkaContainer kafkaContainer = new KafkaContainer(
DockerImageName.parse("confluentinc/cp-kafka").withTag("7.5.2"))
DockerImageName.parse("confluentinc/cp-kafka").withTag("7.5.3"))
.withKraft()
.withReuse(true);
dynamicPropertyRegistry.add("spring.cloud.stream.kafka.binder.brokers", kafkaContainer::getBootstrapServers);
Expand Down
2 changes: 1 addition & 1 deletion kafka-sample/spring-modulith-outbox-pattern/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -26,7 +26,7 @@

<project.testresult.directory>${project.build.directory}/test-results</project.testresult.directory>
<spotless.version>2.41.1</spotless.version>
<dependency-check-maven.version>9.0.7</dependency-check-maven.version>
<dependency-check-maven.version>9.0.8</dependency-check-maven.version>
<properties-maven-plugin.version>1.2.1</properties-maven-plugin.version>
<sonar-maven-plugin.version>3.10.0.2594</sonar-maven-plugin.version>
<jacoco-maven-plugin.version>0.8.11</jacoco-maven-plugin.version>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@
public class TestAnalyticsConsumerApplication {

private static final DockerImageName KAFKA_IMAGE_NAME =
DockerImageName.parse("confluentinc/cp-kafka").withTag("7.5.0");
DockerImageName.parse("confluentinc/cp-kafka").withTag("7.5.3");

@Bean
@ServiceConnection
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,7 @@ class TestAnalyticsProducerApplication {
@ServiceConnection
KafkaContainer kafkaContainer(DynamicPropertyRegistry propertyRegistry) {
KafkaContainer kafkaContainer =
new KafkaContainer(DockerImageName.parse("confluentinc/cp-kafka").withTag("7.5.0"))
new KafkaContainer(DockerImageName.parse("confluentinc/cp-kafka").withTag("7.5.3"))
.withKraft();
propertyRegistry.add("spring.kafka.bootstrapServers", kafkaContainer::getBootstrapServers);
return kafkaContainer;
Expand Down

0 comments on commit f6cf6f0

Please sign in to comment.