Kafkaクラスタ構築02-Kafkaクラスタ展開

zookeeperクラスタの配置を完了したら、kafkaクラスタの配置を継続します.1.インストール構成:a.同じ3台のLinux Server Redhat 7.2

[root@kafka-pr opt]# more /etc/hosts
10.170.195.12   kafka-con2
10.170.194.98   kafka-con1
10.170.197.16   kaka-pro 

b.kafka 0.10(http://mirrors.tuna.tsinghua.edu.cn/apache/kafka/0.10.0.0/kafka_2.11-0.10.0.0.tgz)2.設置と配置a.まずkafka-prでkafkaパッケージを伸張する:

[root@kafka-pr opt]# pwd
/opt
[root@kafka-pr opt]# tar -zvxf kafka_2.11-0.10.0.0.tgz

b.kafkaメッセージディレクトリを作成する:

[root@kafka-pr kafka_2.11-0.10.0.0]# mkdir kafkalog/

c.server.propertiesファイルを設定します.以下のパラメータをserver.propertiesに追加します.

broker.id=0
*#broker        *
log.dirs=/opt/kafka_2.11-0.10.0.0/kafkalog
*#      *
listeners=PLAINTEXT://10.170.197.16:9092
*#broker   IP   *
replica.fetch.max.bytes=5048576
*#broker            *
max.message.bytes=5048576
*#server            *
default.replication.factor=2
*#     *
zookeeper.connect=10.170.197.16:2181,10.170.194.98:2181,10.170.195.12:2181
*# zookeeper  ip   *

kafka-con 1では、kafka-con 2でa-cステップを実行します.特別な注意:server.propertiesの中でbrook er.idの値はそれぞれ違っています.その他は同じです.kafka-con 1:brook er.id=2 kafka-con 2:brook er.id=3
3.クラスタaを起動します.それぞれkafka-pr、kafka-con 1、kafka-con 2でkafka-server-start.shを実行します.

[root@kafka-pr bin]# pwd
/opt/kafka_2.11-0.10.0.0/bin
[root@kafka-pr bin]# ./kafka-server-start.sh -daemon ../config/server.properties

[root@kafka-con1 bin]# pwd
/opt/kafka_2.11-0.10.0.0/bin
[root@kafka-con1 bin]# ./kafka-server-start.sh -daemon ../config/server.properties

[root@kafka-con2 bin]# pwd
/opt/kafka_2.11-0.10.0.0/bin
[root@kafka-con2 bin]# ./kafka-server-start.sh -daemon ../config/server.properties

4.topic aを購読します.kafka-prでleontestというtopicを購読します.

[root@kafka-pr bin]# ./kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 2 --partitions 1 --topic  looniest

b.topic購読成功を確認する:

[root@kafka-pr bin]# ./kafka-topics.sh --list --zookeeper localhost:2181
looniest

5.クラスタメッセージ送受信:a.消費者起動kafka-con 1:

[root@kafka-con1 bin]# ./kafka-console-consumer.sh --zookeeper localhost:2181 --topic leontest --from-beginning

kafka-con 2を起動します

[root@kafka-con2 bin]# ./kafka-console-consumer.sh --zookeeper localhost:2181 --topic leontest --from-beginning

kafka-pr生産者を起動します.

[root@kafka-pr bin]# ./kafka-console-producer.sh --broker-list localhost:9092 --topic leontest

メッセージを送る消費者は皆受信できる: