Spring Kafka客户端无法从启用Kerberos的Kafka代理主题获取消息
我们最近对我们的Kafka集群进行了Kerbertic化，我们开始在阅读来自代理上的主题的消息时遇到问题。
我们使用的是spring kafka 1.1.2版本和kafka client 0.10.0.1。
在研究了Apache Kafka文档中的建议之后，我在项目中做了以下更改。
- 在使用者属性中添加了security.protocol SASL_PLAINTEXT。
- 添加了适当的JAAS文件，并在VM参数中提供了路径。
- 添加了krb5.conf并在VM参数中提供了路径。
- 我也在JAAS文件中创建并提供了适当的keytab项。
是否有什么我遗漏的或任何其他方法我可以排除故障？
共有1个答案
好的-我们现在已经解决了这个问题，让kafka管理员为kerberos主体为正确的使用者组和正确的主题设置正确的ACL（权限）。
有关更多信息，请参阅https://cwiki.apache.org/confluence/display/kafka/kafka+authorization+command+line+interface
-
我有以下情况：我使用Kafka模板，以便与Kafka交互，但我希望能够以编程方式防止Kafka客户端从某个主题读取消息，但仍然能够产生到其他主题。有没有办法实现这一点？
-
我在远程机器上设置了Kafka和动物园管理员。在那台机器上，我可以看到下面使用官方网站上的测试方法工作。 但是当我使用本地消费者脚本时，它就不起作用了： 我试着把它改成： 然后运行客户端使用者脚本，它会给出错误： [2017-08-11 15:49:01,591]获取相关id为3的元数据时警告错误：{listings-incoming=leader_not_available}(org.apach
-
出于特殊原因，我需要同时使用 （又名高级消费者）和 （又名低级消费者）来读取 Kafka。对于 ，我使用基于 ZooKeeper 的配置，并且对此完全满意，但 需要实例化种子代理。 我不想同时保留动物园管理员和经纪人主机的列表。因此，我正在寻找一种方法，从ZooKeeper中自动发现特定主题的经纪人。 由于一些间接的信息，我相信这些数据存储在ZooKeeper中的以下路径之一： < li > <代
-
我的用例是，从生产者端，它将一行数据(大约100字节)作为一条消息发布到kafka topic，从消费者端，我希望一次消费5条消息，并将其提供给我的消费者逻辑。 我做了一个简单的例子，它总是得到一个消息并打印在控制台上。请建议我任何需要的配置更改，以实现这一点。 请在下面找到源代码。 使用以下命令启动生产者 /kafka生产者性能测试——num记录500——主题测试——吞吐量10——有效负载文件测
-
您可以get get client-go的一个版本，例如get get k8s.io/client-go/1.4/...或者获取k8s.io/client-go/1.4/kubernetes。 现在当我这么做的时候。这是输出- 警告：“k8s.io/client-go/1.4/...”匹配的无包无法加载包：包。：/users/shubhadeeproychowdhury/projects/Go/s
-
我有一个Kafka集群（版本：0.10.1.0），有9个代理和10个分区。 我尝试使用camel kafka从java应用程序中获取消息。这是我的pom。xml 这只是我使用的与骆驼Kafka相关的依赖项。下面是骆驼Kafka消费者代码。 我正在使用文档中指定的KafkaURIhttps://camel.apache.org/components/latest/kafka-component.ht