Spring Stream Kafka, improvements

diff --git a/SpringJava/Kafka/SpringCloudStream/spring-cloud-stream-kafka-consumer-example/src/main/java/de/example/spring/kafka/ReceiverConfig.java b/SpringJava/Kafka/SpringCloudStream/spring-cloud-stream-kafka-consumer-example/src/main/java/de/example/spring/kafka/ReceiverConfig.java
index 1979559..5a9d1e2 100644 (file)
--- a/SpringJava/Kafka/SpringCloudStream/spring-cloud-stream-kafka-consumer-example/src/main/java/de/example/spring/kafka/ReceiverConfig.java
+++ b/SpringJava/Kafka/SpringCloudStream/spring-cloud-stream-kafka-consumer-example/src/main/java/de/example/spring/kafka/ReceiverConfig.java
@@ -26,7 +26,7 @@ public class ReceiverConfig {
   @Bean
   public MessageConverter avroMessageConverter() throws IOException {
       AvroSchemaMessageConverter converter = new AvroSchemaMessageConverter(MimeType.valueOf("avro/bytes"));
-      converter.setSchemaLocation(new ClassPathResource("schemas/User.avro"));
+      //converter.setSchemaLocation(new ClassPathResource("schemas/User.avro"));
       return converter;
     }
 }

diff --git a/SpringJava/Kafka/SpringCloudStream/spring-cloud-stream-kafka-consumer-example/src/main/resources/application.yml b/SpringJava/Kafka/SpringCloudStream/spring-cloud-stream-kafka-consumer-example/src/main/resources/application.yml
index 7f56b28..ce733c8 100644 (file)
--- a/SpringJava/Kafka/SpringCloudStream/spring-cloud-stream-kafka-consumer-example/src/main/resources/application.yml
+++ b/SpringJava/Kafka/SpringCloudStream/spring-cloud-stream-kafka-consumer-example/src/main/resources/application.yml
@@ -4,18 +4,13 @@ logging:
       springframework: info
     ROOT: info
 
-spring:
-  main:
-    banner-mode: "off"
-
 kafka:
   topic: test
   messageKey: keyTest
 
-
-
-# *************************** BINDERS CONFIGURATION ***************************
 spring:
+  main:
+    banner-mode: "off"
   cloud:
     stream:
       bindings:
@@ -29,11 +24,12 @@ spring:
             partitioned: false
             headerMode: raw
             maxAttempts: 3
-            backOffInitialInterval:
+            backOffInitialInterval: 1000
       instanceCount: 1
       instanceIndex: 0
       kafka:
         binder:
+          zkNodes: "kafka:2181"
           brokers: "kafka:9092,kafka:9093,kafka:9094"
           autoCreateTopics: true
 

diff --git a/SpringJava/Kafka/SpringCloudStream/spring-cloud-stream-kafka-example-bom/pom.xml b/SpringJava/Kafka/SpringCloudStream/spring-cloud-stream-kafka-example-bom/pom.xml
index fc6113b..ebbd9eb 100644 (file)
--- a/SpringJava/Kafka/SpringCloudStream/spring-cloud-stream-kafka-example-bom/pom.xml
+++ b/SpringJava/Kafka/SpringCloudStream/spring-cloud-stream-kafka-example-bom/pom.xml
@@ -46,6 +46,11 @@
             <artifactId>spring-cloud-stream-schema</artifactId>
             <version>1.1.1.RELEASE</version>
         </dependency>
+        <dependency>
+            <groupId>org.apache.avro</groupId>
+            <artifactId>avro</artifactId>
+            <version>1.8.1</version>
+        </dependency>
     </dependencies>
        <build>
                <plugins>

diff --git a/SpringJava/Kafka/SpringCloudStream/spring-cloud-stream-kafka-producer-example/src/main/resources/application.yml b/SpringJava/Kafka/SpringCloudStream/spring-cloud-stream-kafka-producer-example/src/main/resources/application.yml
index a072392..4d37c02 100644 (file)
--- a/SpringJava/Kafka/SpringCloudStream/spring-cloud-stream-kafka-producer-example/src/main/resources/application.yml
+++ b/SpringJava/Kafka/SpringCloudStream/spring-cloud-stream-kafka-producer-example/src/main/resources/application.yml
@@ -7,11 +7,6 @@ logging:
 spring:
   main:
     banner-mode: "off"
-
-
-
-# *************************** BINDERS CONFIGURATION ***************************
-spring:
   cloud:
     stream:
       bindings:
@@ -24,6 +19,7 @@ spring:
       instanceIndex: 0
       kafka:
         binder:
+          zkNodes: "kafka:2181"
           brokers: "kafka:9092,kafka:9093,kafka:9094"
           autoCreateTopics: true