@@ -61,6 +61,7 @@ public class KafkaAnalyzeProducer {
kafkaTemplate.send(topic, message).get(10, TimeUnit.SECONDS);
}
+
/**
* producer 异步方式发送数据 通用回调
*