如何存档Kafka消息,例如,如果我们想将特定消息发送到某个主题,以便我们存档该消息并发送到该主题或其他主题?
- 我们可以将这一消息重播到主题中吗?
- 我们可以根据特定的偏移量重播吗?
向某个主题发送特定消息
这是一个常规的生产者发送请求
我们将该消息存档
Kafka 将数据自行保留可配置的时间量。默认值为一周
发送到该主题或其他主题
同样,生产者请求可以发送到特定主题。如果需要,Kafka Streams 或 MirrorMaker 可以发送到其他主题
将该消息重播到主题
㗵。。。从哪里重播?通常,阅读消息并生成主题
基于特定偏移的重播
是的,您可以从 Kafka 中的给定 TopicPartition + Offset 坐标消费