消费者
<p>说明：</p>
<pre><code>kakfa的消费者使用项目</code></pre>
<p>准备工作：</p>
<pre><code>在nisbos-kafka-producer/src/main/resources/application.ym文件中，修改kafka地址：
servers: ip:port
如果是多个集群地址，用逗号(,)隔开</code></pre>
<p>一.独立测试运行：</p>
<pre><code>直接运行nisbos-kafka-consumer/src/main/java/com/nisbos/kafka/consumer/KafkaConsumerApplication.java</code></pre>
<p>二.集成运行</p>
<pre><code>1.请把组件安装到maven仓库
<dependency>
<groupId>com.nisbos</groupId>
<artifactId>nisbos-kafka-consumer</artifactId>
<version>1.0-SNAPSHOT</version>
</dependency>
2.将如下的kafka配置复制到需要集成的springboot项目的yml文件中
nisbos-kafka-consumer/src/main/resources/application.yml
3.注释掉如下文件的@SpringBootApplication注解
nisbos-kafka-consumer/src/main/java/com/nisbos/kafka/consumer/KafkaConsumerApplication.java
4.参照
nisbos-kafka-consumer/src/main/java/com/nisbos/kafka/consumer/listener/ConsumerListeners.java
将topics改为实际需要监听的值即可
5.示例：
@KafkaListener(id = "listenTestId",topics="test")
public void listenTest(ConsumerRecord<String, String> record) {
System.out.println("消费kafka的key: " + record.key());
System.out.println("消费kafka的value: " + record.value());
}</code></pre>