diff --git a/src/main/java/org/well/well/kafka/KafkaTool.java b/src/main/java/org/well/well/kafka/KafkaTool.java
index 92a274c..7a59e1d 100644
--- a/src/main/java/org/well/well/kafka/KafkaTool.java
+++ b/src/main/java/org/well/well/kafka/KafkaTool.java
@@ -81,7 +81,7 @@
         props.put("buffer.memory", 33554432);
         props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
         props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");
-        Producer<String, String> producer = new KafkaProducer<>(props);
+        Producer<String, String> producer = new KafkaProducer<String, String>(props);
         producer.send(new ProducerRecord<String, String>(topic, "22", content));
         producer.close();
         System.out.println("发送消息成功" + content);