在Kafka中，可以通过使用访问控制列表（ACLs）对多个主题进行权限控制。ACLs允许您为特定的用户或用户组分配特定的操作，如读取、写入、删除等。以下是如何在Kafka中设置和管理ACLs的步骤：
创建用户和用户组：
首先，您需要创建用于访问Kafka集群的用户和用户组。这些信息通常存储在Kafka的配置文件kafka_server_properties.properties中的users.properties文件中。
user1=password1,read,write
user2=password2,read
group1=grouppassword1,read,write
创建主题：
创建您希望进行权限控制的主题。例如，创建两个主题topic1和topic2。
kafka-topics.sh --create --topic topic1 --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1
kafka-topics.sh --create --topic topic2 --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1
配置ACLs：
使用kafka-acls.sh脚本创建ACLs。以下是一些示例命令，用于为用户和用户组分配不同的权限：
# 为用户user1分配对主题topic1的读写权限
kafka-acls.sh --add --allow --user user1 --operation ReadWrite --topic topic1
# 为用户group1分配对主题topic2的读权限
kafka-acls.sh --add --allow --group group1 --operation Read --topic topic2
# 为用户user2分配对主题topic1的读权限
kafka-acls.sh --add --allow --user user2 --operation Read --topic topic1
验证ACLs：
使用kafka-acls.sh脚本验证ACLs是否正确设置。
kafka-acls.sh --list --authorizer-properties zookeeper.connect=localhost:2181
应用ACLs：
确保在Kafka服务器启动之前，ACLs已经正确配置并应用到Kafka集群中。通常，这可以通过在kafka_server_properties.properties文件中设置以下属性来实现：
authorizer.class.name=kafka.security.auth.SimpleAclAuthorizer
通过以上步骤，您可以为Kafka中的多个主题设置和管理权限控制。这样，不同用户和用户组可以根据分配的权限对主题执行相应的操作。
