У меня есть файл журнала темы и соответствующий файл .index.Я хотел бы читать сообщения в потоковом режиме и обрабатывать его.Как и с чего мне начать?
- Должен ли я загрузить эти файлы производителю Kafka и прочитать из темы?
- Могу ли я напрямую написать потребителю прочитать данные из файла и обработать их?
Я просматривал веб-сайт Kafka и везде он использует предварительно созданные производители и потребители Kafka в примерах.Итак, я не мог получить достаточного руководства.
Я хочу читать потоковым способом на Java.
Текст выглядит зашифрованным, поэтому я не публикую входные файлы.
Любая помощь очень ценится.