X-Git-Url: http://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2FApplicationConfiguration.java;fp=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2FApplicationConfiguration.java;h=a8b3e1dc2da4a6a49a98fc3ecc7909fe0262f98a;hb=fbd2fe7121eea8ce0c25d53dcb80b2565ccc8598;hp=62d61a20905dd8c4e31089199f38bc11a5b92332;hpb=8f14291a52872141ded7ecead6b1f7f9fbc969e4;p=demos%2Fkafka%2Ftraining

diff --git a/src/main/java/de/juplo/kafka/ApplicationConfiguration.java b/src/main/java/de/juplo/kafka/ApplicationConfiguration.java
index 62d61a2..a8b3e1d 100644
--- a/src/main/java/de/juplo/kafka/ApplicationConfiguration.java
+++ b/src/main/java/de/juplo/kafka/ApplicationConfiguration.java
@@ -15,7 +15,7 @@ public class ApplicationConfiguration
 {
   @Bean
   public SimpleConsumer simpleConsumer(
-      Consumer<String, String> kafkaConsumer,
+      Consumer<String, Message> kafkaConsumer,
       KafkaProperties kafkaProperties,
       ApplicationProperties applicationProperties)
   {