#apache-kafka #apache-storm
Вопрос:
Существует топология, которая считывает данные из кафки и обрабатывает их. Когда я проверяю лаг с помощью инструмента кафка, я вижу проблему в обновлении смещения для одного раздела из 6 разделов. Даже я вижу, что топология также обрабатывает последние сообщения из этого раздела. похоже, смещение, сохраненное в Storm для потребителя Storm, повреждено.
Комментарии:
1. Посмотрите на журналы потребителей. Может быть, в этом разделе есть запись о ядовитых таблетках
2. Я повторно развертываю топологию… но все еще проблема не решена, и снова тот же раздел-3 показывает задержку, однако другие в порядке. Пожалуйста, помогите мне решить эту проблему.
3. Как я уже сказал, определенное сообщение может препятствовать развитию этого раздела, и ваши журналы должны быть в состоянии объяснить вам, почему