Kafka

kafka(集群) 是一个分布式 的 高可用 的发布/订阅 消息队列

官网 https://kafka.apache.org/

安装

docker run --name kafka -p 9092:9092 -d apache/kafka:latest


# 监控会收到高级listen控制
java  kafka-ui-api-v0.7.2.jar --spring.config.additional-location=config.yaml

> config.yaml
kafka:
  clusters:
    - name: local
      bootstrapServers: "localhost:9092"

常用命令

# 创建主题
./kafka-topics.sh --bootstrap-server localhost:9092 --create --topic my_topic

# 生产者
./kafka-console-producer.sh --bootstrap-server localhost:9092 --topic my_topic

# 消费者
#  --from-beginning 表示从头开始读取消息
#  --group my_group 消费者组
#  --property print.partition=true 打印消息来源分区
./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic my_topic

UI管理界面

# 还可设置动态配置
java -jar kafka-ui-api-v0.7.2.jar --spring.config.additional-location=./config.yaml

> ./config.yaml
kafka:
  clusters:
    - name: local
      bootstrapServers: "localhost:9092"