Почему потребительские показатели Kafka медленные?

У меня есть одна простая тема и один простой потребитель и производитель Kafka, использующий конфигурацию по умолчанию.Программа очень простая, у меня две те...

Какая команда показывает все темы и смещения разделов в Кафке?

мониторинг kafka с использованием JMX при запуске kafka в докере в boot2docker

Как контролировать брокера Kafka с помощью jmxtrans?

Кафка 0.8.1.1 (кафка_2.8.0-0.8.1.1.tgz)Я использую jmxtrans для мониторинга JMX экземпляра Kafka (который работает в Docker). К сожалению, показатели Кафки н...

Как использовать Flink's KafkaSource в Scala?

java.lang.ClassNotFoundException: kafka.api.OffsetRequest

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

Хотите реализовать отложенного потребителя, используя пользовательский API высокого уровнясмысл:генерировать сообщения по ключу (каждое сообщение содержит ме...

Как отправить вывод двух разных носиков на один и тот же болт?

У меня есть два носика Kafka, значения которых я хочу отправить на один и тот же болт.Является ли это возможным ?

Kafka Spring Integration: заголовки не для потребителя kafka

Я использую Kafka Spring Integration для публикации и использования сообщений с использованием kafka. Я вижу, что полезная нагрузка правильно передается от п...

Кафка на Кубернетесе многоузловая

Поэтому моя цель здесь - создать кластер из нескольких kafka-брокеров распределенным способом. Но я не вижу способа, чтобы брокеры знали друг о друге.Насколь...