框架: spring-kafka 1.2.2
生产者端代码
说明:
bootstrapServers: kafka 地址
kafkaTemplate: 服务调用模板
消费端代码:
说明:
@EnableKafka : 开启kafka
bootstrapServers: kafka 地址
groupIdConfig: 群组名称
consumerConfigs(): 客户端配置
consumerFactory():客户端工厂
kafkaListenerContainerFactory(): 配置kafka监听工厂
实际使用:
发送消息:
指定话题和内容,框架会发送到对应的话题
接收消息:
使用
@KafkaListener 注解并加上对应的话题,就可以自动接收相应的消息