java - kafka消息发送不出去
PHPz
PHPz 2017-04-18 10:26:29
0
2
336
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怎么办???

PHPz
PHPz

学习是最好的投资!

熱門教學
更多>
最新下載
更多>
網站特效
網站源碼
網站素材
前端模板
關於我們 免責聲明 Sitemap
PHP中文網:公益線上PHP培訓,幫助PHP學習者快速成長!