import java.util.Properties; import net.sf.json.JSONObject; import kafka.javaapi.producer.Producer; import kafka.javaapi.producer.ProducerData; import kafka.producer.KeyedMessage; import kafka.producer.ProducerConfig; import kafka.serializer.StringEncoder; //利用線程池 調用類的靜態函數發送消息 但是發布出去 不知道什么原因 public class SendOid2Kafka { private static Producer producer = createProducer(); public static void sendMessage2CMS(JSONObject message) { producer.send(new KeyedMessage("novel.review.topic", message)); System.out.println("send"); //執行不到這里 消息沒發送出去 } private static Producer createProducer() { Properties properties = new Properties(); properties.put("zookeeper.connect","*"); properties.put("serializer.class", StringEncoder.class.getName()); properties.put("metadata.broker.list","*"); properties.put("zookeeper.session.timeout.ms", "15000"); return new Producer(new ProducerConfig(properties)); } } 改為發送String 就發送出去了JSONObject就發送不出去 想發JSONObject怎么辦？？？