From 5caf781b105573cabc6af600433dc61f8266d0a6 Mon Sep 17 00:00:00 2001
From: Gustavo Martin Morcuende <gu.martinm@gmail.com>
Date: Sun, 29 Jan 2017 09:44:06 +0100
Subject: [PATCH] Spring Stream Kafka, improvements

---
 .../main/java/de/example/spring/kafka/ReceiverConfig.java    |  2 +-
 .../src/main/resources/application.yml                       | 12 ++++--------
 .../spring-cloud-stream-kafka-example-bom/pom.xml            |  5 +++++
 .../src/main/resources/application.yml                       |  6 +-----
 4 files changed, 11 insertions(+), 14 deletions(-)

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
--- 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
--- 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
--- 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
--- 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
 
-- 
2.1.4