springboot-kafka一个简单例子

1、引入springboot-kafka的jar包依赖。 2、在application.properties添加配置信息，本机安装的kafka的ip和端口号，9092默认端口。消费者的组名称。 3、创建生产者服务，声明成spring组件，注入KafkaTemplate，send方法的第一个参数是topic的名称，第二个参数是数据。 4、创建消费者服务，开启监听，如果获取到数据，则输出接受到的数据。

>>阅读原文<<