当消息无法处理时，我们将消息放在死信主题上。由于应用程序中的一个bug，我们现在有几百条关于死信主题的消息放在那里。既然我们已经修复了导致错误的原因，那么将所有消息从死信主题“移”回要重新处理的正常主题的最简单方法是什么？在rabbitmq中，您只需通过rabbitmq Jmeter 板移动消息；在kafka中是否有一个等价的应用程序，或者需要编写一个单独的应用程序来移动消息？
q1qsirdb1#
假设您无法重放原始主题（您可以通过重置偏移量来实现），那么您将需要一种机制来从dlt（死信主题）重放
没有这样的功能-可用的用户界面类似于兔子的“移动消息”铲功能。我们也偶然发现了这一点，并最终构建了一个控制台工具来“铲”消息：源-目标主题。记住，Kafka的默认保留期，我相信是7天。虽然这样的工具可以很快实现，但是它很短。我们决定在我们的环境中摆脱死信机制，它与快速部署（和固定）单元一起工作得出奇地好。如果您有ksql或kafka流可用，那么这也是一个选项。但仍然没有现成的rabbitmq。
1条答案
按热度按时间q1qsirdb1#
假设您无法重放原始主题（您可以通过重置偏移量来实现），那么您将需要一种机制来从dlt（死信主题）重放
坏消息
没有这样的功能-可用的用户界面类似于兔子的“移动消息”铲功能。我们也偶然发现了这一点，并最终构建了一个控制台工具来“铲”消息：源-目标主题。
记住，Kafka的默认保留期，我相信是7天。虽然这样的工具可以很快实现，但是它很短。
我们决定在我们的环境中摆脱死信机制，它与快速部署（和固定）单元一起工作得出奇地好。
如果您有ksql或kafka流可用，那么这也是一个选项。但仍然没有现成的rabbitmq。