Я пытаюсь отправить sh некоторые старые сообщения, которые находятся в kafka, снова в микросервис. Я могу получить эти сообщения из kafka с помощью следующей команды
bin / kafka-console-consumer. sh - bootstrap -server broker_ip: 9092 --topi c UA_Topi c --offset 25486296 --partition 0 --max-messages 10
Всего будет около 60 K сообщений Но я не могу понять, как их сделать sh. Я пробовал использовать утилиту kafka-magi c, но не нашел для этого. Может ли кто-нибудь предложить способ pu sh снова прочитать сообщение от потребителя консоли kafka в топи kafka c