java110-utils/src/main/java/com/java110/utils/kafka/KafkaFactory.javaold mode 100644 new mode 100755
@@ -27,4 +27,14 @@ public static void sendKafkaMessage(String topic,String key,Object message) throws Exception{ getKafkaTemplate().send(topic,key,message); } /** * 发送kafka消息 * @param topic * @param message * @throws Exception */ public static void sendKafkaMessage(String topic,Object message) throws Exception{ getKafkaTemplate().send(topic,"",message); } }