Я установил Кафка-0.8.2.2 с использованием доморощенного, как указано в приведенной ниже ссылке https://dtflaneur.wordpress.com/2015/10/05/installing-kafka-on-mac-osx/Mac: самогон не устанавливая все сценарии Кафка
я настроен только 1 брокер ..
Возможность запуска зоопарка Кафка, потребитель, производитель и публиковать сообщения с помощью консоли производителя и увидеть сообщения в потребительской консоли ...
но когда им пытаются работать ниже сценарий им видящего этот сценарий отсутствует ..
- kafka-consumer-groups.sh
в основном я хочу, чтобы увидеть список
- группы потребителей
- количества разделов, доступных (хотели бы знать количество разделов присутствует в брокере)
и когда я бежал эхо $ KAFKA_HOME i т дает пустой я не имею в виду никакого значения ...
но когда я побежал установку заварить Кафка Предупреждения: Кафка-0.8.2.2 уже установлен
им concerened если Кафка установлен properly..please предложить
в состоянии увидеть ниже сценариев под USR/местные/бен/
kafka-console-consumer.sh
kafka-console-producer.sh
kafka-consumer-offset-checker.sh
kafka-consumer-perf-test.sh
kafka-mirror-maker.sh
kafka-preferred-replica-election.sh
kafka-producer-perf-test.sh
kafka-reassign-partitions.sh
kafka-replay-log-producer.sh
kafka-replica-verification.sh
kafka-run-class.sh
kafka-server-start.sh
kafka-server-stop.sh
kafka-simple-consumer-shell.sh
kafka-topics.sh
не уверен, что если какие-либо другие сценарии были чем которые я указал ...
Спасибо. Когда я запустил вышеприведенную команду, он дал число разделов как «1» ... могу ли я считать это по умолчанию числом разделов, так как я не настроил какие-либо разделы во время установки kafka..если нужно увеличить число разделов для темы ... должен ли я использовать «kafka-reassign-partitions.sh», пожалуйста, дайте понять, что образец commad для достижения того же ?? – shiv455
'./bin/kafka-topics.sh --zookeeper localhost: 2181 --alter --topic your_topic_name --partitions 10' –
BTW' имя группы потребителей' - это то, что вы задали, когда потребляете у Kafka, используя высокоуровневые (также называемый групповым) потребителем (или используемый вами инструмент использует высокоуровневого потребителя, например, fluentd или logstash). Если N потребителей являются частью группы, все они получают 1/N подмножество сообщений из темы (используемой для увеличения параллелизма, даже с использованием пользователей на разных хостах). –