如何存档卡夫卡消息?



如何存档Kafka消息,例如,如果我们想将特定消息发送到某个主题,以便我们存档该消息并发送到该主题或其他主题?

  1. 我们可以将这一消息重播到主题中吗?
  2. 我们可以根据特定的偏移量重播吗?

向某个主题发送特定消息

这是一个常规的生产者发送请求

我们将该消息存档

Kafka 将数据自行保留可配置的时间量。默认值为一周

发送到该主题或其他主题

同样,生产者请求可以发送到特定主题。如果需要,Kafka Streams 或 MirrorMaker 可以发送到其他主题

将该

消息重播到主题

㗵。。。从哪里重播?通常,阅读消息并生成主题

基于特定偏移的重播

是的,您可以从 Kafka 中的给定 TopicPartition + Offset 坐标消费

相关内容

  • 没有找到相关文章

最新更新