带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
1