如何进行到Docker容器中运行Kafka：
- docker ps 找到CONTAINER ID 去前三位
- 执行docker exec -it bbd bin/bash进入到docker中
- 进入到/opt/bitnami/kafka/bin中执行kafka脚本
---------------------------------------------------------------------------------------------------------------------------------
1.查看已经创建的所有topics
bin/kafka-topics.sh --list --bootstrap-server kafka1:9093 --command-config ./config/scram_common.properties注意：因为此kafka是加了认证的，必须先读取认证文件里的密码才能查看topics, 如下是认证文件的代码：--command-config ./config/scram_common.properties
该命令通过 Kafka CLI 工具连接到指定的 Kafka 集群（kafka1:9093），使用 SCRAM 认证配置文件（scram_common.properties），列出当前集群中的所有 Topic。
2. 创建topic
bin/kafka-topics.sh --bootstrap-server kafka1:9093 --topic WJ-TEST --create --partitions 1 --replication-factor 3 --command-config ./config/scram_common.properties该命令通过 Kafka CLI 工具在指定的 Kafka 集群（kafka1:9093）中创建一个名为 WJ-TEST 的 Topic，配置为 1 个分区、3 个副本，并使用 SCRAM 认证配置文件（scram_common.properties）进行安全认证。
3.查看已经创建的topic详情
bin/kafka-topics.sh --bootstrap-server kafka1:9093 --topic KAFKA-DIM-TOPIC --command-config ./config/scram_common.properties --describe或者describe放中间也可以：
bin/kafka-topics.sh --bootstrap-server kafka1:9093 --topic WJ-TEST --describe --command-config ./config/scram_common.properties该命令通过 Kafka CLI 工具连接到指定的 Kafka 集群（kafka1:9093），使用 SCRAM 认证配置文件（scram_common.properties），查看名为 WJ-TEST 的 Topic 的详细信息（如分区数、副本数、ISR 等）
4.修改已经建好的topic的分区数（注意这里只能新增，不能减少）
bin/kafka-topics.sh --bootstrap-server kafka1:9093 --topic WJ-TEST --alter --partitions 3 --command-config ./config/scram_common.properties 该命令通过 Kafka CLI 工具连接到指定的 Kafka 集群（kafka1:9093），使用 SCRAM 认证配置文件（scram_common.properties），将名为 WJ-TEST 的 Topic 的分区数从原来的分区数增加到 3（只能增加，不能减少）。
5. 向指定topic中生产消息
bin/kafka-console-producer.sh --bootstrap-server kafka1:9093 --topic WJ-TEST --producer.config ./config/scram_common.properties
该命令通过 Kafka CLI 工具连接到指定的 Kafka 集群（kafka1:9093），使用 SCRAM 认证配置文件（scram_common.properties），向名为 WJ-TEST 的 Topic 中生产消息。
生产的消息：
Hello, Kafka!
This is a test message.
Message 3
6. 向指定的topic消费消息
bin/kafka-console-consumer.sh --bootstrap-server kafka1:9093 --topic WJ-TEST --consumer.config ./config/scram_common.properties --from-beginning该命令通过 Kafka CLI 工具连接到指定的 Kafka 集群（kafka1:9093），使用 SCRAM 认证配置文件（scram_common.properties），从 WJ-TEST Topic 中从头开始（--from-beginning）消费消息，并将消费到的消息打印到控制台。
消费到的消息：
7.删除指定topic
bin/kafka-topics.sh --bootstrap-server kafka1:9093 --delete --topic WJ-TEST --command-config ./config/scram_common.properties该代码通过指定的 scram_common.properties 配置文件，连接到 Kafka1 的 9093 端口，并删除名为 WJ-TEST 的 Kafka 主题。
8. 查看操作主题命令参数
bin/kafka-topics.sh
参数 |
描述 |
--bootstrap-server <String: server toconnect to> |
连接的Kafka Broker主机名称和端口号。 |
--topic <String: topic> |
操作的topic名称。 |
--create |
创建主题。 |
--delete |
删除主题。 |
--alter |
修改主题。 |
--list |
查看所有主题。 |
--describe |
查看主题详细描述。 |
--partitions <Integer: # of partitions> |
设置分区数。 |
--replication-factor<Integer: replication factor> |
设置分区副本。 |
--config <String: name=value> |
更新系统默认的配置。 |
9. 生产者命令行操作
bin/kafka-console-producer.sh
参数 |
描述 |
--bootstrap-server <String: server toconnect to> |
连接的Kafka Broker主机名称和端口号。 |
--topic <String: topic> |
操作的topic名称。 |
10. 消费者命令行操作
bin/kafka-console-consumer.sh
参数 |
描述 |
--bootstrap-server <String: server toconnect to> |
连接的Kafka Broker主机名称和端口号。 |
--topic <String: topic> |
操作的topic名称。 |
--from-beginning |
从头开始消费。 |
--group <String: consumer group id> |
指定消费者组名称。 |