kafka-zookeeperベース構成

Zookeeper
1.tar.gzパッケージを自分でダウンロードしてインストールを解凍してください
2.インストールディレクトリの/confディレクトリの下に入ります.構成パラメータtickTimeの変更:zookeeperサーバとクライアント間のハートビートの維持間隔initLimit:クラスタモードでは、Followerマシンが起動し、Leaderから最新データを同期して、自身のサービス状態を確定する必要があります.同期はinitLimit内で完了する必要があります.すなわち、同期時間が10*2000=20 s(initLimit*tickTime)syncLimit:クラスタモードでは、リーダーがクラスタ内の他の機器Followerと通信する必要がある場合、心拍メカニズムによりFollower状態を検出し、心拍間隔syncLimitを超えると、このFollowerがラインオフすることを示す.ハートビート間隔5*2000=10 s(syncLimit*tickTime)dataDir:zookeeperデータを保存するディレクトリのソース:https://blog.csdn.net/dedekownsoso/article/details/72833094
3.Zookeeperを起動し、binディレクトリの下で以下のコマンドを実行する

zkServer.sh start /usr/local/zookeeper/zookeeper-3.4.5/conf/zoo.cfg

起動時にAddress already in useと言えば.zoo.cfgプロファイルのポートが占有されていることを示します.一般的に2181です.
次のコマンドを使用して、netstat-apn|grep 2181を確認します.確かに存在する場合は、コマンドを使用してプロセスkill-9プロセス番号を殺します.
なぜなら、kafkaインストールディレクトリ/binのzookeeper-server-start.shを起動したからかもしれません.ここにも2181ポートが配置されています.
Kafka
1.自分でkafkaをダウンロードしてインストールする
2.kafkaを起動し、インストールディレクトリのbinディレクトリの下に入り、次のコマンドを実行します.

kafka-server-start.sh  /usr/local/kafka/kafka_2.11-2.1.1/config/server.properties

3.kafkaインストールディレクトリのbinファイルの下に入り、testトピックを作成する

kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

4.topicの表示

kafka-topics.sh --list --zookeeper localhost:2181
test

5.メッセージを送信し、Kafkaはコマンドラインのツールを提供し、入力ファイルまたはコマンドラインからメッセージを読み取り、Kafkaクラスタに送信することができる.各行はメッセージです.Producer(プロバイダ)を実行し、コンソールにサーバにいくつかのメッセージを入力します. 

kafka-console-producer.sh --broker-list localhost:9092 --topic test
message1
message2

5.消費メッセージ、Kafkaも消費メッセージのコマンドラインツールを提供し、格納された情報を出力する.

kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
message1
message2