カフカ実習2

環境の構築

$ git clone https://github.com/wurstmeister/kafka-docker
$ cd [git clone한 위치]
# (저장용) 내컴퓨터에서는 cd ~/kafka_practice/kafka-docker 에 위치
$ vim docker-compose-single-broker.yml
$ docker-compose -f docker-compose-single-broker.yml up -d

コンテナ(カフカ-ドックステーションkafka 1、カフカ-ドックステーションzookeeeper 1)

(参照)docker-compose-single-broker。yml最終状態

version: '2'
services:
  zookeeper:
    image: wurstmeister/zookeeper
    ports:
      - "2181:2181"
  kafka:
    build: .
    ports:
      - "9092:9092"
    environment:
      KAFKA_ADVERTISED_HOST_NAME: 127.0.0.1
      KAFKA_CREATE_TOPICS: "test:1:1"
      KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
    volumes:
      - /var/run/docker.sock:/var/run/docker.sock

プロデューサー/コンシューマ簡易テスト

# kafka 깔려있는 곳으로 이동
$ cd ~/kafka_practice/temp/kafka_2.13-2.7.0/bin

# 프로듀서 띄우기
$ ./kafka-console-producer.sh --bootstrap-server localhost:9092 --topic test
# 컨슈머 띄우기
$ ./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test

(Practice 1)プロデューサーを起動してjavaファイルsimple-Kafka-commerをテストする

# 프로듀서 띄우기
$ ./kafka-console-producer.sh --bootstrap-server localhost:9092 --topic test

を実行してレコードを取得

(実践2)Kafka-commer-auto-commit練習

(実践3)Kafka-commer-auto-commit練習

以前のファイルとは異なり、2つの「コレクターWithMultiThread」、「コレクターWorker」ファイルがあります.

実習の時、次のスクリーンショット部分thread-2万は、1つのパーティションしかないので.
-そのため、実習前に3つのパーティションが正しいことを確認してください.