蛹

也许是过期了

我刚才连续测试了很多遍，可以拿到完整的消费，是正常：

kafka@kafka-0:/$ kafka-console-consumer.sh --bootstrap-server 172.30.55.63:9092 --topic test --from-beginning
test
test1
test2
test3
test4
test5
^CProcessed a total of 6 messages
kafka@kafka-0:/$ kafka-console-consumer.sh --bootstrap-server 172.30.55.63:9092 --topic test --from-beginning
test
test1
test2
test3
test4
test5
^CProcessed a total of 6 messages
kafka@kafka-0:/$ kafka-console-consumer.sh --bootstrap-server 172.30.55.63:9092 --topic test --from-beginning
test
test1
test2
test3
test4
test5
^CProcessed a total of 6 messages

测试的kafka版本是2.8.0

也许是你等的时间不够长，数据还没返回回来？

半兽人大大，问个白痴一点的问题，怎么把 KAFKA_OPTS里面的这些参数带入到JVM环境中呢？在客户端时

你把前面2篇SSL和SASL的看完了，就知道了。

您好，那么我该如何指定生产者或者消费者的username呢？