apache-kafka - 如何归档 Kafka 消息？

Question

如果我们想将特定消息发送到某个主题，那么如何归档 Kafka 消息，以便我们归档该消息并发送到该主题或其他主题？

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

标签： apache-kafkaapache-kafka-connect

Answer 1

向某个主题发送特定消息

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

我们存档该消息

Kafka 会自行将数据持久化一段可配置的时间。默认为一周

发送到该主题或其他主题

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

将该消息重播到主题

不清楚...从哪里重播？通常，阅读消息并产生到一个主题

基于特定偏移重放

是的，您可以在 Kafka 中使用给定的 TopicPartition + Offset 坐标