在 Kraft 模式下,Kafka 脚本的使用有以下一些关键方面:
一、启动 Kafka 服务
- 启动 Zookeeper(如果未单独部署 Zookeeper 集群,Kafka 内置的 Zookeeper 会被使用):
bin/zookeeper-server-start.sh config/zookeeper.properties
- 启动 Kafka 服务器:
bin/kafka-server-start.sh config/server.properties
二、创建主题
使用以下命令创建一个主题:
bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic my_topic
其中,--replication-factor
指定副本因子,--partitions
指定分区数,--topic
指定主题名称。
三、发送消息
可以使用以下命令向主题发送消息:
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic my_topic
在命令行中输入消息内容,每行一条消息。
四、消费消息
使用以下命令消费主题中的消息:
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic my_topic --from-beginning
--from-beginning
参数表示从主题的开头开始消费消息。
五、查看主题列表
使用以下命令查看当前所有的主题:
bin/kafka-topics.sh --list --bootstrap-server localhost:9092
六、描述主题
可以使用以下命令查看特定主题的详细信息:
bin/kafka-topics.sh --describe --bootstrap-server localhost:9092 --topic my_topic
在使用 Kafka 脚本时,确保配置文件(如server.properties
等)中的参数根据实际需求进行了正确设置,特别是在 Kraft 模式下,一些与存储和网络相关的参数可能需要调整以获得最佳性能。同时,注意监控 Kafka 的日志文件,以便及时发现和解决可能出现的问题。