today

SASL的验证我没看到额，最好命令验证通过之后，客户端在进行调试吧。

贴一下你配置，和你参考的例子，让我清楚你的步骤。
https://www.orchome.com/170

有大佬可以帮忙看看吗？是验证方式不对吗？还是什么？

能，命令带上认证就可以了。

https://www.orchome.com/1960#item-0-4

周边几篇文章都是，选择正确的加密算法就可以了。

大佬，咨询下，有台能连上对方kafka的电脑，我安装个kafka。对方kafka是有账号验证的。能通过命令来查看到一些消费信息这些的吗？

就是说我能拿到几条消息了应该就不是权限的问题了。客户是有新的消息产生的，有新推消息。我试过重置偏移量到最新开始读

consumer.poll(0); consumer.seekToBeginning(consumer.partitionsFor(kafkaTopic).stream() .map(partitionInfo -> new TopicPartition(kafkaTopic, partitionInfo.partition())) .collect(Collectors.toList()));

也还是读到6的偏移量那边。我再修改代码看看吧。谢谢了