风起云涌

0 声望

这家伙太懒,什么都没留下

个人动态
  • 风起云涌 回复 tiiimokafka实战SASL/SCRAM 中 :

    微信bisaluo_tao

    3年前
  • tiiimo 回复 风起云涌kafka实战SASL/SCRAM 中 :

    就是加上了 SCRAM权限,就报这样的错误

    [root@cdh_app_server02 kafka_2.12-2.2.0]# bin/kafka-consumer-groups.sh --bootstrap-server 172.19.27.16:9092,172.19.27.46:9092,172.19.27.65:9092 --describe --group cjfGroupzhs
    Error: Executing consumer group command failed due to org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.
    java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.
        at org.apache.kafka.common.internals.KafkaFutureImpl.wrapAndThrow(KafkaFutureImpl.java:45)
        at org.apache.kafka.common.internals.KafkaFutureImpl.access$000(KafkaFutureImpl.java:32)
        at org.apache.kafka.common.internals.KafkaFutureImpl$SingleWaiter.await(KafkaFutureImpl.java:89)
        at org.apache.kafka.common.internals.KafkaFutureImpl.get(KafkaFutureImpl.java:260)
        at kafka.admin.ConsumerGroupCommand$ConsumerGroupService.collectGroupOffsets(ConsumerGroupCommand.scala:331)
        at kafka.admin.ConsumerGroupCommand$ConsumerGroupService.describeGroup(ConsumerGroupCommand.scala:251)
        at kafka.admin.ConsumerGroupCommand$.main(ConsumerGroupCommand.scala:59)
        at kafka.admin.ConsumerGroupCommand.main(ConsumerGroupCommand.scala)
    Caused by: org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.
    

    能加您个微信 或者qq吗

    3年前
  • 风起云涌 回复 tiiimokafka实战SASL/SCRAM 中 :

    怎么运行?怎么样的报错呢?是不是安装有问题啊?

    3年前
  • tiiimo 回复 风起云涌kafka实战SASL/SCRAM 中 :

    大佬 有什么方法吗,各种.sh 都报错

    3年前
  • 风起云涌 回复 半兽人kafka实战SASL/SCRAM 中 :

    想问下,我最近在学习kafka2.5.0配置sasl/scram,看了文档有一些疑问:
    1、kafka_server_jaas.conf文件里配置了org.apache.kafka.common.security.plain.PlainLoginModule required,是必须的吗?还是写错了
    2、sasl/scram整个配置中,需要对zookeeper进行配置吗?我看文档里没有,如果需要,要如何配置?
    3、kafka配置了sasl/scram,工具kafka tool,kafka eagle等,如何连接集群进行管理?

    4年前