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

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

Кафка: не может создать многопотоковых потребителей

Я только начал работать с Kafka 0.8 beta 1. У меня есть очень простой пример, проблема в том, что я могу заставить работать только одного потребителя сообщен...

Kafka QuickStart, advertised.host.name дает kafka.common.LeaderNotAvailableException

Я могу получить простой одноузловой Kafka (kafka_2.11-0.8.2.1), работающий локально на одной машине с Linux, но когда я пытаюсь запустить продюсер удаленно, ...

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

Как интегрировать Storm и Kafka [закрыто]

Я работал вГроза и разработал базовую программу, которая использует локальный текстовый файл в качестве источника ввода. Но теперь я должен работать над пото...

Прочитайте тему Кафки в пакетном задании Spark

Я встретил ту же проблему и решил ее в соответствии с вашим ответом. Спасибо.

я возникла ситуация, когда spark может транслировать и получать сообщения только из одного раздела темы 2-patition Kafka.Мои темы:

Как настроить параметры Java для Kafka?

Я экспериментировал с Kafka и увидел из документации на основном сайте, что вы можете установить различные параметры для jvm, такие как размер кучи и сборщик...

Почему я не могу увеличить session.timeout.ms?

Я хочу увеличить

Алгоритм перебалансировки потребителей Kafka

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