可靠的消息传递

Question

抱歉，我需要先解释一下，然后再谈这个问题。

异步：

我可以使用Kafka producer async send with with callback，如果向Kafka发送消息时出现错误，那么通知JMS使用者不确认消息消耗将为时已晚。为了克服这个问题，我想出的唯一办法是，如果有异常，在回调中保留消息，然后尝试稍后发送消息。但我认为那会是太多的开销。

有没有其他方法可以使用异步调用来处理这种情况？

使用同步调用，对Producer.send（）返回的future调用get()，如果在向Kafka发送消息时出现任何问题，就会引发异常，并且可以将异常报告给JMS消费者，这样它就不会确认消息并在以后重试它。

很明显，这将对性能产生影响，因为这将是一个阻塞调用，而且糟糕的是，由于Kafka将确认每条消息，因此不会对消息进行批处理。

我倾向于同步调用，因为我不想要额外的持久性。

有没有什么方法或配置，我可以使用同步调用，并最大限度地减少同步调用的影响？我所做的一个配置是拥有一个JMS消费者池。

Answer 1

异步道：

除了坚持，别无他法。你要为表现做一个交易。

您收到了来自JMS的消息。承认你读了。当试图推到Kafaka的一个话题时，由于某种原因失败了。您需要做两件事，这是可靠的。

null

我不确定在这种情况下你怎样才能提高性能。如果性能在应用程序中不是问题，我建议您采用这种方法，因为这是最快和最简单的方法。

我不明白你坚持回调是什么意思。如果您的意思是将消息存储在内存中，这是一个坏主意，因为如果应用程序由于某种原因关闭或停止，您将丢失消息。