我正在使用camel从IBM MQ阅读消息并做一些增强，然后使用spring Kafka模板将消息发送到azure eventhub。由于KafkaTemplate.send是异步进程，camel在实际消息发送到eventhub之前向IBM MQ确认。是否有一种方法可以在消息发布到EventHub之后才向IBM MQ确认？？
olqngx591#
您可以等待KafkaTemplate.send()返回的Future<?>完成（有一个超时）。
KafkaTemplate.send()
Future<?>
1条答案
按热度按时间olqngx591#
您可以等待
KafkaTemplate.send()返回的Future<?>完成（有一个超时）。