spring boot kafka:Spring Boot Kafka示例代码 源码

带Kafka的样本Spring Boot 公开了一个使用json消息并发布到kafka主题中的api 要通过泊坞窗启动zookeeper和kafka,请执行以下操作: docker-compose up 生成应用程序映像 docker build --no-cache -t sample_kafka:0.0.1 . -f docker\Dockerfile 创建主题: bin/kafka-topics.sh --create --zookeeper zookeeper:2181 --replication-factor 1 --partitions 1 --topic test 要开始制作,请执行以下操作: bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test 要启动消费者: bin