在虛擬機上啟動了一個KAFKA消費者用于接收訊息。
在本地寫了一個生產者demo發送訊息到虛擬機的kafka上，報錯No resolvable bootstrap urls given in bootstrap.servers。
虛擬機的埠、防火墻什么的都已經開啟。
kafka使用的默認配置，只改了個日志路徑。
初次學習kafka,請大佬指點.以下是java代碼：
private static final String brokerlist="192.168.1.5:9092";
private static final String topic = "heima";
Properties properties = new Properties();
//設定key序列化器
properties.put("key.serializer","org.apache.kafka.common.serialization.StringSerializer");
//設定重試次數
properties.put(ProducerConfig.RETRIES_CONFIG,10);
//設定值序列化器
properties.put("value.serializer","org.apache.kafka.common.serialization.StringSerializer");
//設定集群地址
properties.put("bootstrap.servers ",brokerlist);
KafkaProducer<String,String> producer = new KafkaProducer<String, String>(properties);
ProducerRecord<String,String> producerRecord = new ProducerRecord<String,String>(topic,"kafka-demo","hello,kafka");
try{
producer.send(producerRecord);
}catch(Exception ex){
ex.printStackTrace();
}finally {
producer.close();
}
uj5u.com熱心網友回復：
https://blog.csdn.net/qq_36811160/article/details/102765681 這個應該會幫助到你轉載請註明出處，本文鏈接：https://www.uj5u.com/houduan/50850.html
標籤：Java相關