设为首页 加入收藏

TOP

Spring boot实现生产者   发送kafka
2019-02-12 02:29:33 】 浏览:32
Tags:Spring boot 实现 生产者   发送 kafka

677807540 java开发交流群

@Autowired
private KafkaTemplate kafkaTemplate;

ListenableFuture send = kafkaTemplate.send("kuaifa_import", Type,
macs);
// outgoingMacService.insertmac(emac1,data.getString("data"),appid,request);
kafkaTemplate.metrics();

kafkaTemplate
.execute(new KafkaOperations.ProducerCallback<String, String, Object>() {

@Override
public Object doInKafka(
Producer<String, String> producer) {

return null;
}
});

// 消息发送的监听器,用于回调返回信息
kafkaTemplate
.setProducerListener(new ProducerListener<String, String>() {

@Override
public void onError(String topic, Integer partition,
String key, String value, Exception exception) {

}

@Override
public boolean isInterestedInSuccess() {
return false;
}

@Override
public void onSuccess(String topic, Integer partition,
String key, String value,
RecordMetadata recordMetadata) {
// TODO Auto-generated method stub

}
});


编程开发网
】【打印繁体】【投稿】【收藏】 【推荐】【举报】【评论】 【关闭】 【返回顶部
上一篇zookeeper 、kafka leader选举 下一篇kafka源码分析(持续更新)

评论

帐  号: 密码: (新用户注册)
验 证 码:
表  情:
内  容:

array(4) { ["type"]=> int(8) ["message"]=> string(24) "Undefined variable: jobs" ["file"]=> string(32) "/mnt/wp/cppentry/do/bencandy.php" ["line"]=> int(214) }