# ..... 忽略 nodeSelector: gitee-repo: "true" tolerations: - key: "gitee-repo" operator: "Equal" effect: "NoSchedule" value: "true" artifactory: # ..... 忽略 storage_xml: | cache 400000000000 false [endpoint] [port] default [AK] [SK] [BUCKET] artifactory/data/filestore 1000 300000 50000 100000000 5242880 0 5000 true ## 查看集群全景 ``` 1. 列出集群中所有的 Broker 节点（这是首要检查项） bin/kafka-broker-api-versions.sh --bootstrap-server <当前节点IP>:9092 # 2. 查看所有 Topic 的详细状态（分区、副本、Leader分布） bin/kafka-topics.sh --bootstrap-server <当前节点IP>:9092 --describe ``` ## kafka 创建topic ``` kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic qiush ``` ## 查看已创建的topic ``` kafka-topics.sh --list --bootstrap-server localhost:9092 # 明细 kafka-topics.sh --bootstrap-server localhost:9092 --topic qiush --describe ``` ## 消息发送 ``` kafka-console-producer.sh --broker-list localhost:9092 --topic qiush ``` ## 消息消费 ``` kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic qiush --from-beginning ``` ## 删除topic ``` kafka-topics.sh --delete --bootstrap-server localhost:9092 --topic ONE_WORKSPACE_CREATE ``` ## 消费者组查看 ``` # 查看所有消费者组 kafka-consumer-groups.sh --bootstrap-server gitee-kafka:9092 --list --command-config /tmp/client.properties # 查看指定消费组状态 kafka-consumer-groups.sh --bootstrap-server localhost:9092 --group notification --describe ``` ## 删除消费组 ``` kafka-consumer-groups.sh --bootstrap-server --delete --group <消费者组名称> ``` ## 设置偏移量 ``` // 重置某个消费组到最早偏移量 kafka-consumer-groups.sh --bootstrap-server --group <消费者组名称> --reset-offsets --to-earliest --execute // 重置某个消费组到最新的偏移量 kafka-consumer-groups.sh --bootstrap-server --group <消费者组名称> --reset-offsets --to-latest --execute ``` ## 带sasl认证处理 ``` $ cat > /tmp/client.properties<