Результаты поиска по запросу "apache-kafka"

2 ответа

Streamparse wordcount пример

Я давно хотел использовать Apache Storm для потоковой передачи с Kafka. Мне удобнее с Python, поэтому я решил использовать streamparse (https://github.com/Pa...

1 ответ

Кафка: Изменить количество разделов для конкретной темы, используя Java

Я новичок в Kafka и работаю с новыми KafkaProducer и KafkaConsumer, версия: 0.9.0.1Есть ли способ в Java, чтобы изменить / обновить количество разделов для к...

1 ответ

Kafka 0.9.0.1 Java Consumer застрял в awaitMetadataUpdate ()

Я пытаюсь заставить простого Kafka Consumer работать с использованием Java API v0.9.0.1. Сервер kafka, который я использую, является док-контейнером, также р...

ТОП публикаций

1 ответ

Кафка разделов разделов к Spark streaming

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

1 ответ

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

1 ответ

Понимание тем и разделов Кафки

3 ответа

Ошибка: не удалось найти или загрузить основной класс config.zookeeper.properties

Я пытаюсь выполнить пример потребительского приложения-производителя с помощью Apache Kafka. Я скачал это сhttps://www.apache.org/dyn/closer.cgi?path=/kafka/...

1 ответ

Kafka 0.10 Java Client TimeoutException: срок действия пакета, содержащего 1 запись (и), истек

У меня есть один узел, несколько (3) брокер Zookeeper / Kafka. Я использую Java-клиент Kafka 0.10.Я написал следующий простой (на другом сервере, чем Kafka) ...

1 ответ

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

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

5 ответов

как установить имя группы при потреблении сообщений в кафке с помощью командной строки

Любая идея, как установить имя группы при потреблении сообщений в kafka с помощью командной строки.Я попытался с помощью следующей команды: