Chipstar Lightのメモ

• ダウンロード・解凍

$ wget http://ftp.tsukuba.wide.ad.jp/software/apache/kafka/0.8.1.1/kafka_2.9.2-0.8.1.1.tgz
$ tar xzvf kafka_2.9.2-0.8.1.1.tgz

• インストールディレクトリ（任意のディレクトリに移動）

$ mv kafka_2.9.2-0.8.1.1 /opt/kafka_2.9.2-0.8.1.1

• config/server.propertiesの変更
  • 以下の内容だけでOK

advertised.host.name=<Kafka Running Machine IP>

起動の順番は1. ZooKeeper 2. Kafka Brokerの順番であること

• ZooKeeperの起動

$ bin/zookeeper-server-start.sh config/zookeeper.properties

• Kafka Brokerの起動

$ bin/kafka-server-start.sh config/server.properties

• topic一覧の確認

$ bin/kafka-topics.sh --list --zookeeper localhost:2181

• ConsumerがOffsetをどこまで消費したかを確認

$ bin/kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --topic <トピック> --group <コンシューマグループ名>

• topicの作成

$ bin/kafka-topics.sh --create --zookeeper localhost:2181 --partitions 1 --topic sample-topic

• messageのput
  • 標準入力に文字列を入力していく

$ bin/kafka-console-producer.sh --broker-list localhost:9092 --topic sample-topic
message1
message2

• messageのpull

$ bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic kafka-sample --from-beginning
message1
message2