kafka开启kerberos后,如何通过java api获取consumer-group?

hust 发表于: 2018-04-03   最后更新时间: 2018-04-03 17:34:30   3,312 游览
发表于 2018-04-03
添加评论

跟生产者和消费者命令一样呀,把认证带到JVM中。

hust -> 半兽人 6年前

再问一个问题,kerberos认证通过后,为什么任意用户都可以创建topic,不能用acl控制吗?

半兽人 -> hust 6年前

主题创建是不受限制的

hust -> 半兽人 6年前

看官网上添加acl不是可以选择cluster资源,然后添加create权限吗?这不是控制用户是否能创建topic的吗?

半兽人 -> hust 6年前

你试试看。

hust -> 半兽人 6年前

试了不加create权限普通用户也能创建topic

hust -> 半兽人 6年前

kafka用户kerberos认证后运行命令bash kafka-consumer-groups.sh --bootstrap-server node1:9092 --list报错,运行异常:Request METADATA failed on brokers list(node1:9092 (id: -1 rack: null))

半兽人 -> hust 6年前

跟生产者和消费者命令一样,把认证带到JVM中。

hust -> 半兽人 6年前

怎么带啊,能举个例子吗?谢谢了

你的答案

查看kafka相关的其他问题或提一个您自己的问题