如何处理Kafka流中的处理异常

Question

在Kafka流中处理异常是一个类似的问题，但公认的答案只涉及productionException。如何处理处理过程中发生的异常，从而控制手动偏移提交。

Answer 1

您需要手动处理它们，即使用自己的try-catch块并对它们做出相应的反应。

Answer 2

您可能会发现这个库的使用对Kafka Streams中的错误处理很有帮助。它提供了各种包装器和DLQ处理。在流处理器中处理消息时，我自己使用它来获取异常。我看到的唯一差距是当您希望在拓扑中处理多个操作的情况时。