diff --git a/whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/kafka/KafkaConsumer.java b/whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/kafka/KafkaConsumer.java
index 6a5349bf2530006071b9acd913be45e92870036d..05a2e2d55acdbebaf83aee07b6a01e0e0f171364 100644
--- a/whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/kafka/KafkaConsumer.java
+++ b/whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/kafka/KafkaConsumer.java
@@ -35,10 +35,10 @@ public class KafkaConsumer {
         StringDecoder keyDecoder = new StringDecoder(new VerifiableProperties());
         StringDecoder valueDecoder = new StringDecoder(new VerifiableProperties());
 
-        Map<String, List<KafkaStream<String, String>>> consumerMap =
+        Map<String, List<KafkaStream<Object, Object>>> consumerMap =
                 consumer.createMessageStreams(topicCountMap, keyDecoder, valueDecoder);
-        KafkaStream<String, String> stream = consumerMap.get("TestTopic").get(0);
-        ConsumerIterator<String, String> it = stream.iterator();
+        KafkaStream<Object, Object> stream = consumerMap.get("TestTopic").get(0);
+        ConsumerIterator<Object, Object> it = stream.iterator();
         while (it.hasNext()) {
             System.out.println(it.next().message());
         }