Dockerを使用してkafka「ローカル」をインストールする

2990 ワード
docker kafka テキストリンク

設定

  • ドックステーション、ドックステーションから構成されていること.

    • git pull

  • カフカドックイメージ(事実上は標準)の設定.
    *zookeeperとkafkaを同時に設定する
    • $ git clone https://github.com/wurstmeister/kafka-docker.git

    設定


    変更docker-compose-single-broker.ymlの設定
  • KAFKA_ADVERTISED_HOST_NAME127.0.0.1(ローカルホスト)に変更
  • ローカルで簡単なテストを行うためにシングルブローカーを使用

    • コンテナの作成

  • ドックコンピュータコマンドを使用してドック画像&コンテナを生成
    • docker-compose -f docker-compose-single-broker.yml up -d
  • docker ps稼働中のコンテナを確認
  • zookeeperとkafka浮標が2つ必要
    • CONTAINER ID   IMAGE                    COMMAND                  CREATED       STATUS       PORTS                                                NAMES
4596bda0943c   kafka-docker_kafka       "start-kafka.sh"         2 hours ago   Up 2 hours   0.0.0.0:9092->9092/tcp                               kafka-docker_kafka_1
0db297026525   wurstmeister/zookeeper   "/bin/sh -c '/usr/sb…"   2 hours ago   Up 2 hours   22/tcp, 2888/tcp, 3888/tcp, 0.0.0.0:2181->2181/tcp   kafka-docker_zookeeper_1

    実行


    トピックの作成

    docker exec -t 4596 kafka-topics.sh --bootstrap-server localhost:9092 --create --topic test
    発生したtest

    プロキシ接続

    docker exec -it 4596 kafka-console-producer.sh --topic test --broker-list localhost:9092
  • 接続後に伝えるメッセージを入力すればよい
  • testテーマ名でメッセージを伝える
    • hello world
kafka

    消費者接続

    docker exec -it 4596 kafka-console-consumer.sh --topic test --bootstrap-server localhost:9092
  • 消費者を別のbashウィンドウに接続すると仲介者からのメッセージが確認できる
    • hello world
kafka
    "java"コマンドラインツールを使用するには...のポップアップを出さない方法
    多種類のバブルアルゴリズムの時間と効率の比較