生产者
<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-producer/src/test/java/kafa/producer/test/KafkaProducerTest.java</code></pre>
<p>二.集成运行</p>
<pre><code>1.请把组件安装到maven仓库
<dependency>
<groupId>com.nisbos</groupId>
<artifactId>nisbos-kafka-producer</artifactId>
<version>1.0-SNAPSHOT</version>
</dependency>
2.将如下的kafka配置复制到需要集成的springboot项目的yml文件中
nisbos-kafka-producer/src/main/resources/application.yml
3.注释掉如下文件的@SpringBootApplication注解
nisbos-kafka-producer/src/main/java/com/nisbos/kafka/producer/KafkaProducerApplication.java
4.参照测试用例:
nisbos-kafka-producer/src/test/java/kafa/producer/test/KafkaProducerTest.java
5.示例:
@Autowired
private KafkaTemplate<String, String> kafkaTemplate;
kafkaTemplate.send("test", "key", "异步发送值1");</code></pre>