风起云涌

0 声望

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

个人动态
  • 风起云涌 回复 tiiimo 在 kafka实战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年前
  • 风起云涌 回复 tiiimo 在 kafka实战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等，如何连接集群进行管理？

    3年前