Проверьте, подключена ли система к Kafka

Смещения хранятся в Zookeeper или Kafka?

Я немного озадачен тем, где хранятся смещения при использовании Kafka и Zookeeper. Похоже, что смещения в некоторых случаях хранятся в Zookeeper, в других - ...

Как увидеть сохранение для конкретной темы в Кафке

Я хочу увидеть срок хранения, установленный для конкретной темы. Есть ли какая-нибудь команда? Я пробовал с

Не удается найти тему при создании сообщений: UNKNOWN_TOPIC_OR_PARTITION

): Таким образом, с точки зрения потребителя, с точки зрения потребителя, мы используем фиксацию вручную, однако, с точки зрения Kafka Streams, она все еще выполняется автоматически, и нет конфигурации Kafka Streams для ее отключения.

afka Streams, если мы используем низкоуровневый процессор API, мы можем контролировать фиксацию или нет. Так что, если в нашем коде возникают проблемы, и мы ...

Координатор также является тем, кто одобряет / не одобряет коммиты от каждого отдельного потребителя, это правда?

у ссылки на координаторов группы потребителей Kafka и лидеров группы потребителей ...В чем разница?Какая польза от разделения группового управления на два ра...

Вот ключевая часть приведенного выше примера кода (опять же для Kafka 0.10.1), немного адаптированная к вашему вопросу. Обратите внимание, что этот пример демонстрирует OUTER JOIN.

новеApache Kafka Docs

Моя теория состоит в том, что последний потребитель kafka-console, использующий новый Consumer API, получал только сообщения, используя последний формат. В Kafka 0.11.0.0 был внесен ряд изменений формата сообщений.

Как обрабатывать ошибки и не фиксировать при использовании Kafka Streams DSL

аюсь разработать потоковую архитектуру для потоковой аналитики. Требования:RT и NRT потоковый ввод данныхПотоковые процессоры, осуществляющие некоторый финан...

issues.apache.org/jira/browse/KAFKA-4936

ли в Kafka Streams функциональность, позволяющая динамически соединять один входной поток с несколькими выходными потоками?