Кафка-потребитель смещает максимальное значение?

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

Как настроить / подключить распределенных брокеров, производителей и потребителей Kafka в локальной сети?

Я установил Apache Kafka и подтвердил, что производители и потребители работают на локальном хосте.Как настроить Кафку так, чтобы:несколько производителей пе...

разница между groupid и consumerrid в Kafka

Я новичок в Кафке. Я заметил, что в конфигурации Consumer есть два идентификатора. один - group.id (обязательный), а второй - consumer.id (не обязательный). ...

невозможно подключиться к серверу кафки

Я пытаюсь использовать Kafka с версией 0.9.0 с портом 9092. Если я использую telnet, я успешно подключаюсь к этому адресу, но мне не удается подключиться к с...

Karaf - Kafka OSGI bundle - Выпуск производителя

Я пытаюсь создать простой пакет для производителя Kafka в Apache Karaf версии 4.0.3.Вот мой код Java

Когда клиент Apache Kafka генерирует исключение «Batch Expired»?

Используя Java-клиент Apache Kafka (0.9), я пытаюсь отправить длинный ряд записей брокеру, используяКафка Продюсер класс.Асинхронныйотправить метод Немедленн...

Как передать данные из Kafka в Spark Streaming?

Я пытаюсь передать данные из Кафки в потоковое зажигание.Это то, что я сделал до сих пор:Установлены оба

Связь между Apache Kafka и JMS

Как позволить различным контейнерам Docker общаться друг с другом, не открывая порты всему миру

Мне нужно было проверить мой

Могут ли несколько потребителей Kafka прочитать одно и то же сообщение из раздела

Мы планируем написать потребитель Kafka (java), который читает очередь Kafka для выполнения действия, которое содержится в сообщении.Поскольку потребители ра...