Kafka流重试PAPI和一纸空文

Question

如果发送到原始接收器主题时出现异常，我应该使用什么标准来将消息重新发送到备用接收器主题。这是否可以从生成器异常处理程序中的异常类型推导出来，而不损害Kafka流中内部生成器的事务性质。

如果我们决定在某些不可恢复的错误中从生产异常处理程序产生一个死信队列，那么这是否可以在“EOS”保证的上下文中完成，或者它必须是拓扑不知道的自定义生产者。

Answer 1

Kafka Streams没有内置对死信队列的支持。因此，你要“靠自己”去实现它。

如果发送到原始接收器主题时出现异常，我应该使用什么标准来将消息重新发送到备用接收器主题。

不知道你这是什么意思？你能详细说明一下吗？

而不损害Kafaka流中内部生产者的交易性质。

那是不可能的。您没有访问内部生产者的权限。

如果我们决定在某些不可恢复的错误中从生产异常处理程序产生一个死信队列，那么这是否可以在“EOS”保证的上下文中完成，或者它必须是拓扑不知道的自定义生产者。