Как мне заархивировать сообщение Кафки?

Question

Каким образом можно архивировать сообщения Kafka, например, если мы хотим отправить конкретное сообщение в какую-либо тему, чтобы мы заархивировали это сообщение и отправили в эту тему или в другую тему?

1. Можем ли мы воспроизвести это сообщение в теме?
2. Можем ли мы воспроизвести на основе определенного смещения?

Answer 1

отправить конкретное сообщение в какую-то тему

Это обычный запрос от производителя

мы архивируем это сообщение

Кафка самостоятельно сохраняет данные в течение настраиваемого периода времени. По умолчанию это неделя

отправить в эту тему или в другую тему

Опять же, запрос производителя можно отправить по определенной теме. При необходимости Kafka Streams или MirrorMaker могут отправлять в другие темы

воспроизвести это сообщение в теме

Непонятно ... Переиграть откуда? В общем, прочитайте сообщение и произведите в тему

воспроизведение на основе определенного смещения

Да, вы можете использовать указанную координату TopicPartition + Offset в Kafka