MAPREDUCE服务 MRS-Consumer消费数据失败,Consumer一直处于等待状态:解决办法
解决办法
- 配置自定义参数“allow.everyone.if.no.acl.found”参数为“true”,重启Kafka服务。
- 采用具有权限用户登录。
例如:
kinit test_user
或者赋予用户相关权限。
需要使用Kafka管理员用户(属于kafkaadmin组)操作。
例如:
kafka-acls.sh --authorizer-properties zookeeper.connect=10.5.144.2:2181/kafka --topic topic_acl --consumer --add --allow-principal User:test --group test
[root@10-10-144-2 client]# kafka-acls.sh --authorizer-properties zookeeper.connect=8.5.144.2:2181/kafka --list --topic topic_acl Current ACLs for resource `Topic:topic_acl`: User:test_user has Allow permission for operations: Describe from hosts: * User:test_user has Allow permission for operations: Write from hosts: * User:test has Allow permission for operations: Describe from hosts: * User:test has Allow permission for operations: Write from hosts: * User:test has Allow permission for operations: Read from hosts: *
- 用户加入Kafka组或者Kafkaadmin组。
- MapReduce服务_什么是Kafka_如何使用Kafka
- MapReduce服务_什么是ZooKeeper_如何使用ZooKeeper
- GaussDB实例状态_GaussDB数据库实例状态_高斯数据库实例状态_华为云
- 华为云数据库 RDS for MySQL常见故障排除_华为云
- RabbitMQ如何保证消息的可靠性_分布式消息系统_分布式消息RabbitMQ-华为云
- MapReduce服务_什么是HDFS_HDFS特性
- MapReduce服务_什么是Yarn_如何使用Yarn
- kafka是什么_kafka介绍_分布式消息服务Kafka版
- 消息队列_数据交换问题_处理异步任务-华为云
- 什么是域名转出-域名转出费用-域名转出如何操作-域名转出流程