0
ответов

Как проверить, работает ли Kafka Server?

Я хочу убедиться, что сервер kafka запущен или нет перед запуском производственных и потребительских заданий. Это в среде Windows, и вот мой код сервера kafka в затмении ... Свойства kafka = ...
вопрос задан: 20 June 2016 12:38
0
ответов

Apache kafka: не удалось получить блокировку файла .lock в логах tmp / kafka

В соответствии с официальной документацией kafka после команды bin / kafka-topics.sh --create --zookeeper localhost: 2181 --replication-factor 3 --partitions 1 - топическая ошибка выброса сервера my-replicated-theme "...
вопрос задан: 18 May 2016 19:07
0
ответов

Каковы ограничения имени темы Apache Kafka?

Я только что попытался создать тему Kafka "user: создал" и увидел эту ошибку в журналах Kafka: недопустимый символ ':' в части значения свойства. Я гуглил и обнаружил, что в списке рассылки люди разговаривают ...
вопрос задан: 6 May 2016 01:42
0
ответов

Как происходит перебалансирование потребителей в Кафке?

Когда новый потребитель / посредник добавляется или выходит из строя, Kafka запускает операцию восстановления баланса. Является ли Кафка ребалансировкой операции блокировки? Блокируются ли потребители Kafka, когда происходит операция по восстановлению бал
вопрос задан: 17 July 2015 18:01
0
ответов

Эффективная стратегия, позволяющая избежать дублирования сообщений в Apache Kafka.

Я изучаю apache kafka уже месяц. Я, однако, застрял в точке сейчас. Мой пример использования: у меня два или более пользовательских процессов, запущенных на разных машинах. Я провел несколько тестов, в которых я ...
вопрос задан: 15 April 2015 10:20
0
ответов

Репликация кафки-брокера не синхронизирована, поскольку сообщение не получено

У нас есть кластер из 3 брокеров (id: 0,1,2). версия: 0.8.1 Перезапускаем (просто используем stop.sh и start.sh в каталоге bin) брокер 1. Брокер успешно стартовал. Тем не менее, лидер всех разделов ...
вопрос задан: 26 February 2015 02:15
0
ответов

Как читать данные, используя Kafka Consumer API с самого начала?

Кто-нибудь может подсказать, как с самого начала читать сообщения, используя Kafka Consumer API, каждый раз, когда я запускаю потребительский jar.
вопрос задан: 17 February 2015 12:13
0
ответов

Apache KAFKA и поддерживаемые платформы

Основной вопрос, какие платформы и языки поддерживает Apache KAFKA в настоящее время.
вопрос задан: 26 July 2012 05:58
0
ответов

Kafka Сериализация объекта

Я начал играть с Кафкой. Я установил конфигурацию zookeeper, и мне удалось отправлять и использовать сообщения String. Сейчас пытаюсь передать Объект (в java ), но почему-то при разборе...
вопрос задан: 15 July 2012 14:32
0
ответов

Потребитель kafka в R

Я хочу собрать вместе потребителя kafka на Python или R (предпочтительно R). Используя потребителя консоли kafka, я могу grep найти строку и получить соответствующие данные, но я не понимаю, когда это происходит ...
вопрос задан: 9 May 2012 11:59
0
ответов

kafka NoClassDefFoundError kafka/Kafka

Относительно Apache -Очередь сообщений Kafka. Я скачал Apache Kafka со страницы загрузки Kafka. Я распаковал его в /opt/apache/installed/kafka -0.7.0 -, инкубируя -src. На странице быстрого запуска сказано...
вопрос задан: 4 May 2012 20:08