diff --git a/pom.xml b/pom.xml index 002ea294ef..a30c9ef69a 100644 --- a/pom.xml +++ b/pom.xml @@ -812,6 +812,7 @@ spring-kafka-2 spring-kafka-3 + spring-kafka-4 spring-kafka spring-katharsis spring-mobile @@ -1059,6 +1060,7 @@ spring-kafka-2 spring-kafka-3 + spring-kafka-4 spring-kafka spring-katharsis spring-mobile diff --git a/spring-kafka-4/README.md b/spring-kafka-4/README.md new file mode 100644 index 0000000000..83dd249e09 --- /dev/null +++ b/spring-kafka-4/README.md @@ -0,0 +1,11 @@ +## Spring Kafka + +This module contains articles about Spring with Kafka + +### Relevant articles + +- [Get the Number of Messages in an Apache Kafka Topic](https://www.baeldung.com/java-kafka-count-topic-messages) +- [Sending Data to a Specific Partition in Kafka](https://www.baeldung.com/kafka-send-data-partition) + +- More articles: [[<-- prev]](../spring-kafka-3) + diff --git a/spring-kafka-4/pom.xml b/spring-kafka-4/pom.xml new file mode 100644 index 0000000000..224203b5c2 --- /dev/null +++ b/spring-kafka-4/pom.xml @@ -0,0 +1,62 @@ + + + 4.0.0 + spring-kafka-4 + spring-kafka-4 + Intro to Kafka with Spring + + + com.baeldung + parent-boot-3 + 0.0.1-SNAPSHOT + ../parent-boot-3 + + + + + org.springframework.boot + spring-boot-starter + + + org.springframework.kafka + spring-kafka + ${spring-kafka.version} + + + org.springframework.kafka + spring-kafka-test + test + + + org.testcontainers + kafka + test + + + org.testcontainers + junit-jupiter + test + + + + + + + org.springframework.boot + spring-boot-maven-plugin + + com.baeldung.spring.kafka.KafkaApplication + + + + + + + 3.1.2 + 3.2.2 + 5.10.2 + + + \ No newline at end of file diff --git a/spring-kafka/src/main/java/com/baeldung/countingmessages/Application.java b/spring-kafka-4/src/main/java/com/baeldung/countingmessages/Application.java similarity index 100% rename from spring-kafka/src/main/java/com/baeldung/countingmessages/Application.java rename to spring-kafka-4/src/main/java/com/baeldung/countingmessages/Application.java diff --git a/spring-kafka/src/main/java/com/baeldung/countingmessages/KafkaCountingMessagesComponent.java b/spring-kafka-4/src/main/java/com/baeldung/countingmessages/KafkaCountingMessagesComponent.java similarity index 100% rename from spring-kafka/src/main/java/com/baeldung/countingmessages/KafkaCountingMessagesComponent.java rename to spring-kafka-4/src/main/java/com/baeldung/countingmessages/KafkaCountingMessagesComponent.java diff --git a/spring-kafka/src/main/java/com/baeldung/partitioningstrategy/CustomPartitioner.java b/spring-kafka-4/src/main/java/com/baeldung/partitioningstrategy/CustomPartitioner.java similarity index 100% rename from spring-kafka/src/main/java/com/baeldung/partitioningstrategy/CustomPartitioner.java rename to spring-kafka-4/src/main/java/com/baeldung/partitioningstrategy/CustomPartitioner.java diff --git a/spring-kafka/src/main/java/com/baeldung/partitioningstrategy/KafkaApplication.java b/spring-kafka-4/src/main/java/com/baeldung/partitioningstrategy/KafkaApplication.java similarity index 100% rename from spring-kafka/src/main/java/com/baeldung/partitioningstrategy/KafkaApplication.java rename to spring-kafka-4/src/main/java/com/baeldung/partitioningstrategy/KafkaApplication.java diff --git a/spring-kafka/src/main/java/com/baeldung/partitioningstrategy/KafkaMessageConsumer.java b/spring-kafka-4/src/main/java/com/baeldung/partitioningstrategy/KafkaMessageConsumer.java similarity index 100% rename from spring-kafka/src/main/java/com/baeldung/partitioningstrategy/KafkaMessageConsumer.java rename to spring-kafka-4/src/main/java/com/baeldung/partitioningstrategy/KafkaMessageConsumer.java diff --git a/spring-kafka/src/main/java/com/baeldung/partitioningstrategy/ReceivedMessage.java b/spring-kafka-4/src/main/java/com/baeldung/partitioningstrategy/ReceivedMessage.java similarity index 100% rename from spring-kafka/src/main/java/com/baeldung/partitioningstrategy/ReceivedMessage.java rename to spring-kafka-4/src/main/java/com/baeldung/partitioningstrategy/ReceivedMessage.java diff --git a/spring-kafka-4/src/main/resources/application.properties b/spring-kafka-4/src/main/resources/application.properties new file mode 100644 index 0000000000..23e281f4e2 --- /dev/null +++ b/spring-kafka-4/src/main/resources/application.properties @@ -0,0 +1,2 @@ +server.port=8081 +spring.kafka.bootstrap-servers=localhost:9092 diff --git a/spring-kafka-4/src/main/resources/logback.xml b/spring-kafka-4/src/main/resources/logback.xml new file mode 100644 index 0000000000..7d900d8ea8 --- /dev/null +++ b/spring-kafka-4/src/main/resources/logback.xml @@ -0,0 +1,13 @@ + + + + + %d{HH:mm:ss.SSS} [%thread] %-5level %logger{36} - %msg%n + + + + + + + + \ No newline at end of file diff --git a/spring-kafka/src/test/java/com/baeldung/partitioningstrategy/KafkaApplicationIntegrationTest.java b/spring-kafka-4/src/test/java/com/baeldung/partitioningstrategy/KafkaApplicationIntegrationTest.java similarity index 100% rename from spring-kafka/src/test/java/com/baeldung/partitioningstrategy/KafkaApplicationIntegrationTest.java rename to spring-kafka-4/src/test/java/com/baeldung/partitioningstrategy/KafkaApplicationIntegrationTest.java diff --git a/spring-kafka-4/src/test/resources/application.yml b/spring-kafka-4/src/test/resources/application.yml new file mode 100644 index 0000000000..e160e06f80 --- /dev/null +++ b/spring-kafka-4/src/test/resources/application.yml @@ -0,0 +1,7 @@ +spring: + kafka: + consumer: + auto-offset-reset: earliest + group-id: baeldung +test: + topic: embedded-test-topic diff --git a/spring-kafka-4/src/test/resources/logback-test.xml b/spring-kafka-4/src/test/resources/logback-test.xml new file mode 100644 index 0000000000..74f126ebc1 --- /dev/null +++ b/spring-kafka-4/src/test/resources/logback-test.xml @@ -0,0 +1,19 @@ + + + + + %d{HH:mm:ss.SSS} [%thread] %-5level %logger{36} - %msg%n + + + + + + + + + + + + + + \ No newline at end of file diff --git a/spring-kafka/README.md b/spring-kafka/README.md index ed6c3bf8d7..a6d646c131 100644 --- a/spring-kafka/README.md +++ b/spring-kafka/README.md @@ -9,8 +9,6 @@ This module contains articles about Spring with Kafka - [Monitor the Consumer Lag in Apache Kafka](https://www.baeldung.com/java-kafka-consumer-lag) - [Send Large Messages With Kafka](https://www.baeldung.com/java-kafka-send-large-message) - [Kafka Streams With Spring Boot](https://www.baeldung.com/spring-boot-kafka-streams) -- [Get the Number of Messages in an Apache Kafka Topic](https://www.baeldung.com/java-kafka-count-topic-messages) -- [Sending Data to a Specific Partition in Kafka](https://www.baeldung.com/kafka-send-data-partition) - [Implementing Retry in Kafka Consumer](https://www.baeldung.com/spring-retry-kafka-consumer) ### Intro