如何解决我们可以承认还是不喜欢kafka worker线程
@KafkaListener(containerFactory = "sampleListenerContainerFactory",topics = "${sample.topic.name}")
public void receive(SampleKafkaMessage sampleKafkaMessage,Acknowledgment acknowledgment) throws Exception {
try {
String logId = LoggerUtil.getLogId();
executor.execute(new Runnable() {
@Override
public void run() {
try {
if(sampleKafkaMessage != null) {
sampleService.generateInvoice(sampleKafkaMessage);
acknowledgment.acknowledge();
}
}catch (Exception e){
logger.error(String.format("Error fetching invoice with Exception = %s",e.getMessage()));
acknowledgment.nack(10000);
}
}
});
}
catch (Exception e) {
logger.error(String.format("[sampleKafkaConsumer] [receive] Exception payload = %s,e.message = %s",sampleKafkaMessage,e.getMessage()));
acknowledgment.nack(10000);
}
我有这个代码。当我尝试使用kafka worker线程的后台时,出现错误。我的问题是在kafka worker线程上进行确认是否正确。 请给我解释一下。我是kafka的新手。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。