Topic konfigurierbar gemacht

diff --git a/README.sh b/README.sh
index 1b1e5ae0a7a19e7a0606763eb3cc6d98f6be87cf..c39fe5b8400736ef89b1cfa7c40dfac8991fd6b2 100755 (executable)
--- a/README.sh
+++ b/README.sh
@@ -10,7 +10,6 @@ then
 fi
 
 docker-compose -f docker/docker-compose.yml up -d --remove-orphans kafka-1 kafka-2 kafka-3
-docker-compose -f docker/docker-compose.yml rm -svf consumer
 
 if [[
   $(docker image ls -q $IMAGE) == "" ||
@@ -28,7 +27,7 @@ docker-compose -f docker/docker-compose.yml run --rm cli cub kafka-ready -b kafk
 
 docker-compose -f docker/docker-compose.yml up -t0 -d cli
 docker-compose -f docker/docker-compose.yml ps
-docker-compose -f docker/docker-compose.yml up -d producer
+docker-compose -f docker/docker-compose.yml up producer
 
 # tag::kafkacat[]
 kafkacat -b :9092 -t test -e -f'topic=%t\tpartition=%p\toffset=%o\tkey=%k\tvalue=%s\n'

diff --git a/docker/docker-compose.yml b/docker/docker-compose.yml
index 7b436cddec41cca92b989f6e0cffd4430b73aa3e..e85482d5212e12b29f3756f5c3a5e5f8200b7f26 100644 (file)
--- a/docker/docker-compose.yml
+++ b/docker/docker-compose.yml
@@ -104,3 +104,4 @@ services:
     environment:
       spring.kafka.bootstrap-servers: kafka:9092
       spring.kafka.client-id: producer
+      spring.kafka.template.default-topic: test

diff --git a/src/main/java/de/juplo/kafka/Application.java b/src/main/java/de/juplo/kafka/Application.java
index 7a23da9981ee2f0fde09ac365c0b8a05ebfa21f7..5e123ddedebfa2acc868e7b669cad2d24a5bfbae 100644 (file)
--- a/src/main/java/de/juplo/kafka/Application.java
+++ b/src/main/java/de/juplo/kafka/Application.java
@@ -28,7 +28,7 @@ public class Application implements ApplicationRunner
       // tag::callback[]
       ListenableFuture<SendResult<String, String>> listenableFuture =
       // tag::supersimple[]
-          kafkaTemplate.send("test", Long.toString(i%10), Long.toString(i));
+          kafkaTemplate.sendDefault(Long.toString(i%10), Long.toString(i));
       // end::supersimple[]
 
       listenableFuture.addCallback(

diff --git a/src/main/resources/application.yml b/src/main/resources/application.yml
index 8d1d29837e08741060bd0a1dd34a6b7e2e13e699..51cc46c72970331b8dd029e9fc3e325c4d4eec73 100644 (file)
--- a/src/main/resources/application.yml
+++ b/src/main/resources/application.yml
@@ -1,3 +1,5 @@
 spring:
   kafka:
     bootstrap-servers: :9092
+    template:
+      default-topic: test