MAPREDUCE服务 MRS-SparkStreaming消费Kafka消息失败,提示“Error getting partition metadata”:解决办法
解决办法
- 修改或者添加自定义配置“allow.everyone.if.no.acl.found”参数为“true”,重启Kafka服务。
- 删除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
- MapReduce服务_什么是Kafka_如何使用Kafka
- kafka是什么_kafka介绍_分布式消息服务Kafka版
- MapReduce服务_什么是ZooKeeper_如何使用ZooKeeper
- 分布式消息系统Kafka_分布式消息系统_分布式消息kafka可以解决什么问题-华为云
- 分布式消息服务有哪些_分布式消息服务哪个好_分布式消息-华为云
- 分布式消息服务Kafka版与分布式消息服务RocketMQ版的区别_Kafka与RocketMQ对比_Kafka与RocketMQ差异
- Kafka与其他消息队列的对比_什么是Kafka_分布式消息系统-华为云
- 分布式消息中间件实战_分布式消息实战_分布式消息-华为云
- 分布式消息服务优势_分布式消息服务_消息队列-华为云
- MapReduce服务_什么是Flume_如何使用Flume