Kafka常用命令

kafka acl 新增权限

/opt/kafka/bin/kafka-acls.sh --authorizer-properties
zookeeper.connect=zookeeper:2181 --add --allow-principal
User:"cwyic7736428119" --operation Read --topic "tttt"

kafka acl 删除权限

/opt/kafka/bin/kafka-acls.sh --authorizer-properties
zookeeper.connect=zookeeper:2181 --remove --allow-principal
User:"cwyic7736428119" --operation Describe --topic "tttt"

kafka acl 查看权限

/opt/kafka/bin/kafka-acls.sh --authorizer-properties
zookeeper.connect=zookeeper:2181 --list --topic 'tttt'

kafka kafka-topics.sh 常用命令：

创建topic

/opt/kafka/bin/kafka-topics.sh --create --bootstrap-server
kafka1:9092,kafka2:9092 --topic topicName --partitions 2
--replication-factor 1

查看指定topic

/opt/kafka/bin/kafka-topics.sh --describe --bootstrap-server
kafka1:9092,kafka2:9092 --topic topicName

查看topic列表

/opt/kafka/bin/kafka-topics.sh --list --bootstrap-server
kafka1:9092,kafka2:9092

删除topic

/opt/kafka/bin/kafka-topics.sh --delete --bootstrap-server
kafka1:9092,kafka2:9092 --topic topicName