Шторм Kafka носик не испуская сообщений

Question

В моей топологии шторма (с 2 отверстиями и 1 болтом) смещение для одного из потребителей кафка-носика продвигается, но сообщения не отправляются через капот кафки на болт. Я вижу в буре ui, что для этого конкретного носика msgs, испущенный и переданный, равен 0. Итак, мой вопрос: как продвигается потребитель, я вижу постепенное увеличение смещения потребителя от клиента zookeeper.

Answer 1

Позже я выяснил, что причиной описанного выше поведения было то, что регистратор сериализатора отфильтровывал все сообщения из очереди kafka, поэтому ни одно сообщение не выдавалось из носика на болт. Это также объясняет, почему смещения группы потребителей темы kafka постепенно увеличивались.