Query Кафка для сообщения (ий) по ключевым

Question

У меня есть простая конфигурация Кафка:

• по умолчанию консоли-производитель записывает на одну тему с одним разделом
• пользовательского процессором (который реализует org.apache.kafka.streams.processor.Processor) читает Кафка и обрабатывать сообщения.

Во время обработки я проверяю пакет сообщений, если проверка не выполняется. Я пишу для записи ключа первого сообщения сбойной партии.
Возможно ли в kafka запросить сообщение с заданным ключом/смещением? Или получите 100 сообщений после этого сообщения?

Answer 1

Действительно можно запросить сообщение с помощью ключа. Существует элегантный командной строки TODO это:

Кафка-консоль потребителя --new-потребитель --bootstrap-сервер ## имя сервера: порт ## --topic имя ## Тема ## --property print.key = true --property key.separator = "-" - from-begin key-p1 | Grep ## ключ сообщение идет здесь ##>## обеспечивают имя выходного файла ##