X-Git-Url: http://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2FApplicationConfiguration.java;h=a8b3e1dc2da4a6a49a98fc3ecc7909fe0262f98a;hb=435497f0e0836d8a81052ef0fc73d06cc2f67762;hp=62d61a20905dd8c4e31089199f38bc11a5b92332;hpb=4cb45d59008b5388d593f2c87e152acc23b7fb86;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)
   {