MAPREDUCE服务 MRS-SparkStreaming消费Kafka消息失败,提示“Error getting partition metadata”:解决办法

时间:2024-08-27 10:23:51

解决办法

  1. 修改或者添加自定义配置“allow.everyone.if.no.acl.found”参数为“true”,重启Kafka服务。
  2. 删除Topic设置的ACL。

    例如:

    kinit test_user

    需要使用Kafka管理员用户(属于kafkaadmin组)操作。

    例如:

    kafka-acls.sh --authorizer-properties zookeeper.connect=10.5.144.2:2181/kafka --remove --allow-principal User:test_user --producer --topic topic_acl

    kafka-acls.sh --authorizer-properties zookeeper.connect=10.5.144.2:2181/kafka --remove --allow-principal User:test_user --consumer --topic topic_acl --group test

support.huaweicloud.com/trouble-mrs/mrs_03_0065.html