nisbos


生产者

<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仓库 &lt;dependency&gt; &lt;groupId&gt;com.nisbos&lt;/groupId&gt; &lt;artifactId&gt;nisbos-kafka-producer&lt;/artifactId&gt; &lt;version&gt;1.0-SNAPSHOT&lt;/version&gt; &lt;/dependency&gt; 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&lt;String, String&gt; kafkaTemplate; kafkaTemplate.send("test", "key", "异步发送值1");</code></pre>

页面列表

ITEM_HTML