Kafka

By youfang at: 2023-09-12

Kafka

启动服务

  1. 使用Kafka之前需要先启动一个ZooKeeper服务，这里直接使用Kafka中包含的脚本即可，

    script
    1
    PS D:\developer\kafka\kafka_2.12-2.6.0> .\bin\windows\zookeeper-server-start.bat .\config\zookeeper.properties

  2. 启动ZooKeeper服务之后再启动Kafka服务，

    script
    1
    PS D:\developer\kafka\kafka_2.12-2.6.0> .\bin\windows\kafka-server-start.bat .\config\server.properties

Kafka使用

控制台

script
1
2
3
4
5
6
7
8
9
10
11
# 1. 创建Topic
PS D:\developer\kafka\kafka_2.12-2.6.0\bin\windows> .\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
Created topic test.
# 2. 查看Topic
PS D:\developer\kafka\kafka_2.12-2.6.0\bin\windows> .\kafka-topics.bat --list --zookeeper localhost:2181
test
# 3. 发送消息
PS D:\developer\kafka\kafka_2.12-2.6.0\bin\windows> .\kafka-console-producer.bat --broker-list localhost:9092 --topic test
>are you ok?
>hello?
>

消费者：

script
1
2
3
4
# 3. 消费消息
PS D:\developer\kafka\kafka_2.12-2.6.0\bin\windows> .\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning
are you ok?
hello?

Kafka Tool 2

Kafka Tool 2是一款Kafka的可视化客户端工具，可以非常方便的查看Topic的队列信息以及消费者信息以及kafka节点信息。

参考文献