kafka生產者只能成功發送一部分資訊，topic是有3個磁區的
不知道為什么只有一個磁區的時候生產者發的好好的，磁區一多就不行了
java代碼
import org.apache.kafka.clients.producer.*;
import java.util.Properties;
public class CallBackProducer {
public static void main(String[] args) {
//創建配置資訊
Properties properties = new Properties();
properties.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG,"172.16.29.115:9092");
properties.put(ProducerConfig.LINGER_MS_CONFIG,50);
properties.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG,"org.apache.kafka.common.serialization.StringSerializer");
properties.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG,"org.apache.kafka.common.serialization.StringSerializer");
//創建生產者物件
KafkaProducer<String, String> producer = new KafkaProducer<>(properties);
//發送資料
for(int i=0;i<20;i++){
producer.send(new ProducerRecord<>("bzzb2", "xuan?" + i), (metadata, exception) -> {
if(exception==null){
System.out.println(metadata.partition()+"--"+metadata.offset());
}
else{
exception.printStackTrace();
}
});
}
//關閉資源
producer.close();
}
}
控制臺
磁區詳情
消費者消費結果
uj5u.com熱心網友回復：
目前看來是只能訪問一個broker上的磁區，暫時不清楚無法訪問其它兩個磁區的原因轉載請註明出處，本文鏈接：https://www.uj5u.com/qita/83928.html
標籤：分布式計算/Hadoop
上一篇：有能脫殼的師傅嗎，我想拜師
下一篇：注冊測繪師證書都能從事什么作業？