kafka操作
第一个窗口
cd /root/software/kafka
bin/zookeeper-server-start.sh config/zookeeper.properties
最后这种就是成功了
Zookeeper 启动:
- Zookeeper 是 Kafka 集群的协调服务,启动 Kafka 之前必须确保 Zookeeper 正在运行。
第二个窗口:有时候一次没成功得是第二次第三次
cd /root/software/kafka
bin/kafka-server-start.sh config/server.properties
Kafka 服务器启动:
- 在启动 Kafka 服务器时,确保 Zookeeper 已经成功启动。
- 如果 Kafka 服务器启动失败,查看日志文件以确定失败原因,可能是配置错误或端口冲突。
第三个窗口
cd /root/software/kafka
#创建一个主题topic,在这里我们可以进行别的操作
bin/kafka-topics.sh --create --topic _demo --bootstrap-server localhost:9092
#查看已经有的主题
bin/kafka-topics.sh --list --bootstrap-server localhost:9092
#查看使用 --describe 参数来获取特定主题
bin/kafka-topics.sh --describe --topic demo1 --bootstrap-server localhost:9092
开始给话题发送命令
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic _demo
bin/kafka-console-producer.sh
:这是启动 Kafka 生产者客户端的脚本文件。--broker-list localhost:9092
:指定 Kafka 集群的地址列表。在这里,它连接到运行在本地主机(localhost)的 Kafka 服务器,默认端口为 9092。--topic _demo
:指定目标 Kafka 主题,即你想要发送消息的主题。在这个例子中,主题名称为_demo
。
第四个窗口
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic _demo
bin/kafka-console-consumer.sh
:这是启动 Kafka 消费者客户端的脚本文件。--bootstrap-server localhost:9092
:指定 Kafka 集群的地址。在这里,它连接到运行在本地主机(localhost)的 Kafka 服务器,默认端口为 9092。--topic _demo
:指定要消费消息的 Kafka 主题。在这个例子中,主题名称为_demo
。
运行此命令后,控制台将开始显示从主题 _demo
接收到的消息。这是一种实时监控 Kafka 主题消息的便捷方式。
关闭 Kafka 集群的顺序相当重要,以确保所有组件都可以优雅地关闭,避免数据丢失或损坏。一般建议的关闭顺序是:
- 先关闭 Kafka 生产者和消费者客户端:
- 确保所有发送到 Kafka 的消息都已经被处理,并且没有新的消息被发送。
- 关闭 Kafka 服务器:
- 执行 Kafka 服务器的关闭脚本。这将确保 Kafka 服务器优雅地关闭,提交所有必要的数据到磁盘。
- 最后关闭 Zookeeper 服务器:
- 由于 Kafka 依赖于 Zookeeper 进行协调,因此 Zookeeper 应该在 Kafka 服务器完全关闭之后才关闭。
- 关闭 Zookeeper 可以通过执行 Zookeeper 关闭脚本来实现。
按照这个顺序关闭 Kafka 集群可以最大程度地减少关闭过程中可能出现的问题,比如数据不一致或者服务无法正常回复。