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
}
});