问题记录: kafka producer.send(record) topic可以创建, 确无法从kafka-console-consumer中查看到此topic上的内容

问题描述:

启动kafka服务器后, 在客户端通过api往kafka服务器上添加topic和数据.

使用官网提供的Producer的demo

Properties props = new Properties();
props.put("bootstrap.servers", "172.16.160.115:9092");
props.put("acks", "all");
props.put("retries", 0);
props.put("batch.size", 16384);
props.put("linger.ms", 1);
props.put("buffer.memory", 33554432);
props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");

Producer<String, String> producer = new KafkaProducer<>(props);
for (int i = 0; i < 100; i++) {
ProducerRecord<String, String> record = new ProducerRecord<String, String>("my-topic2", Integer.toString(i), Integer.toString(i));
producer.send(record);

}
producer.close();

去服务器端查看topic ‘my-topic2’是否已经创建. (已创建)

./bin/kafka-topics.sh --zookeeper localhost:2181 --list

......
with negotiated timeout 30000 for client /0:0:0:0:0:0:0:1:35398 (org.apache.zookeeper.server.ZooKeeperServer)
__consumer_offsets
my-topic
my-topic2

在服务器端通过shell 查看主题my-topic2上的消息

./bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic my-topic2 --from-beginning

但是无任何内容被查看到!!  <--  my question

问题解决办法:

TODO