Я хочу убедиться, что сервер kafka запущен или нет перед запуском производственных и потребительских заданий. Это в среде Windows, и вот мой код сервера kafka в затмении ... Свойства kafka = ...
В соответствии с официальной документацией kafka после команды bin / kafka-topics.sh --create --zookeeper localhost: 2181 --replication-factor 3 --partitions 1 - топическая ошибка выброса сервера my-replicated-theme "...
Я только что попытался создать тему Kafka "user: создал" и увидел эту ошибку в журналах Kafka: недопустимый символ ':' в части значения свойства. Я гуглил и обнаружил, что в списке рассылки люди разговаривают ...
Когда новый потребитель / посредник добавляется или выходит из строя, Kafka запускает операцию восстановления баланса. Является ли Кафка ребалансировкой операции блокировки? Блокируются ли потребители Kafka, когда происходит операция по восстановлению бал
Я изучаю apache kafka уже месяц. Я, однако, застрял в точке сейчас. Мой пример использования: у меня два или более пользовательских процессов, запущенных на разных машинах. Я провел несколько тестов, в которых я ...
У нас есть кластер из 3 брокеров (id: 0,1,2). версия: 0.8.1 Перезапускаем (просто используем stop.sh и start.sh в каталоге bin) брокер 1. Брокер успешно стартовал. Тем не менее, лидер всех разделов ...
Я начал играть с Кафкой. Я установил конфигурацию zookeeper, и мне удалось отправлять и использовать сообщения String. Сейчас пытаюсь передать Объект (в java ), но почему-то при разборе...
Я хочу собрать вместе потребителя kafka на Python или R (предпочтительно R).
Используя потребителя консоли kafka, я могу grep найти строку и получить соответствующие данные, но я не понимаю, когда это происходит ...
Относительно Apache -Очередь сообщений Kafka. Я скачал Apache Kafka со страницы загрузки Kafka. Я распаковал его в /opt/apache/installed/kafka -0.7.0 -, инкубируя -src. На странице быстрого запуска сказано...