Kafka

分散型イベントフロー管理プラットフォーム

Kafka設定

docker環境でKafkaを設定する
docker-composeインストール
dockerで

kafkaを実行するには、docker-ccomposeをインストールする必要があります.
カフカは常にzookeeeperを実行する必要があり、docker-composeで実行するのが便利です.

Docker-githubからダウンロードして合成を使用

git clone https://github.com/wurstmeister/kafka-docker.git

ダウンロード後、compose.ymlファイルを修正する必要があります.brokerファイルを1つだけアップロードしてテストを行う場合は、docker-compose-single-broker.ymlファイルを修正する必要があります.そうしないと、docker-compose.ymlファイルを修正します.

version: '2'
services:
  zookeeper:
    image: wurstmeister/zookeeper
    ports:
      - "2181:2181"
  kafka:
    image: wurstmeister/kafka
    ports:
      - "9092:9092"
    environment:
      KAFKA_ADVERTISED_HOST_NAME: [IP]
      KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
    volumes:
      - /var/run/docker.sock:/var/run/docker.sock

[IP]にIPアドレスを作成します.
上記の合成ファイルから見ると、kafkaおよびzookeeperおよびportの設定があり、これらの内容を保存してcompose.ymlファイルを実行する必要がある.

docker-compose -f docker-compose.yml up

上記のコマンドを実行すると、kafakaとzookeeperコンテナが実行されていることがわかります.

docker ps

Topicの作成と検証

containerが実行されている場合は、Kafka shellにアクセスする必要があります.次のコマンドでアクセスできます.

docker exec -it 4ed /bin/bash

kafkaコマンドを使用するには、/opt/kafka/binに移動する必要があります.
上のパスに移動する場合は、topicを作成するコマンドを入力します.

bash-5.1# ./kafka-topics.sh --bootstrap-server localhost:9092 --topic kafka_chatting --create

kafka_chatting -トピック名(このセクションに必要なトピック名を入力してください)

topicを作成したら、次のコマンドを使用して生成したtopicを表示できます.

bash-5.1# ./kafka-topics.sh --bootstrap-server localhost:9092 --list

TEST

作成

生産者

docker exec -it 4ed kafka-console-producer.sh --topic test --broker-list localhost:9092

作成

消費者

docker exec -it 4ed kafka-console-consumer.sh --topic test --bootstrap-server localhost:9092

Producer

Consumer