2016-02-29 1 views
0

Я установил Кафка-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-consumer-groups.sh можно приобрести только у 0.9.

Каждая тема (не брокер) состоит из разделов, поэтому проверить разделы темы, которые можно использовать: /bin/kafka-topics.sh --zookeeper localhost:2181 --describe --topic your_topic_name

Я не знаю об установке заварной Кафки, поскольку я использую Докер, где у вас установлена ​​одна команда, и вы не связываетесь с локальной файловой системой. Я искренне предлагаю вам попробовать (я могу предоставить вам более подробную информацию об этом, если вы решите пойти по пути докеров).

+0

Спасибо. Когда я запустил вышеприведенную команду, он дал число разделов как «1» ... могу ли я считать это по умолчанию числом разделов, так как я не настроил какие-либо разделы во время установки kafka..если нужно увеличить число разделов для темы ... должен ли я использовать «kafka-reassign-partitions.sh», пожалуйста, дайте понять, что образец commad для достижения того же ?? – shiv455

+0

'./bin/kafka-topics.sh --zookeeper localhost: 2181 --alter --topic your_topic_name --partitions 10' –

+0

BTW' имя группы потребителей' - это то, что вы задали, когда потребляете у Kafka, используя высокоуровневые (также называемый групповым) потребителем (или используемый вами инструмент использует высокоуровневого потребителя, например, fluentd или logstash). Если N потребителей являются частью группы, все они получают 1/N подмножество сообщений из темы (используемой для увеличения параллелизма, даже с использованием пользователей на разных хостах). –