Результаты поиска по запросу "apache-kafka"
Streamparse wordcount пример
Я давно хотел использовать Apache Storm для потоковой передачи с Kafka. Мне удобнее с Python, поэтому я решил использовать streamparse (https://github.com/Pa...
Кафка: Изменить количество разделов для конкретной темы, используя Java
Я новичок в Kafka и работаю с новыми KafkaProducer и KafkaConsumer, версия: 0.9.0.1Есть ли способ в Java, чтобы изменить / обновить количество разделов для к...
Kafka 0.9.0.1 Java Consumer застрял в awaitMetadataUpdate ()
Я пытаюсь заставить простого Kafka Consumer работать с использованием Java API v0.9.0.1. Сервер kafka, который я использую, является док-контейнером, также р...
Кафка разделов разделов к Spark streaming
У меня есть несколько вариантов использования, которые я хотел бы прояснить, о разделении тем Kafka -> использование ресурсов потоковой передачи.Я использ...
Ошибка: не удалось найти или загрузить основной класс config.zookeeper.properties
Я пытаюсь выполнить пример потребительского приложения-производителя с помощью Apache Kafka. Я скачал это сhttps://www.apache.org/dyn/closer.cgi?path=/kafka/...
Kafka 0.10 Java Client TimeoutException: срок действия пакета, содержащего 1 запись (и), истек
У меня есть один узел, несколько (3) брокер Zookeeper / Kafka. Я использую Java-клиент Kafka 0.10.Я написал следующий простой (на другом сервере, чем Kafka) ...
Почему я не могу увеличить session.timeout.ms?
Я хочу увеличить
как установить имя группы при потреблении сообщений в кафке с помощью командной строки
Любая идея, как установить имя группы при потреблении сообщений в kafka с помощью командной строки.Я попытался с помощью следующей команды: