■ はじめに

Apache Kafka ～環境構築 / Windows編～
https://dk521123.hatenablog.com/entry/2023/04/23/235534

のLinux版。

【１】構築手順 - 通常版
　０）前提条件
　１）Kafka のインストール
【２】モジュール起動
　１）zookeeper起動
　２）Kafka broker起動
【３】Quick Start
　１）トピックを作成 & 確認
　２）メッセージを送信
　３）メッセージを受信

【１】構築手順 - 通常版

* すごーい、簡単（Windows版と基本変わらない）

０）前提条件

[1] JDK

Linuxの場合
https://dk521123.hatenablog.com/entry/2017/08/01/234900

# より抜粋

sudo apt update
sudo apt install openjdk-11-jre-headless

１）Kafka のインストール

* 以下の公式サイトから、ダウンロードして任意の場所に解凍する
 => 今回は、v3.6.1 - Scala 2.12 版「kafka_2.12-3.6.1.tgz」をダウンロード

https://kafka.apache.org/downloads

Linux(Ubuntu)の場合

# Step1: ダウンロード
# curl -OL {ダウンロードするURL}
curl -OL https://downloads.apache.org/kafka/3.6.1/kafka_2.12-3.6.1.tgz

# Step2: 解凍
tar -xzf kafka_2.12-3.6.1.tgz
sudo mv kafka_2.12-3.6.1 /usr/local/kafka

# Step3: Path を通す
sudo vi /etc/enviroment
~~~~~~~~~~~
# Add /usr/local/kafka/bin:
PATH="/usr/local/kafka/bin:【元の設定】"
~~~~~~~~~~~
source /etc/enviroment

# Step4: 確認
kafka-topics.sh --version
# 今回の場合「3.6.1」が表示される

【２】モジュール起動

１）zookeeper起動

Linuxの場合

# Start the ZooKeeper service
zookeeper-server-start.sh config/zookeeper.properties

２）Kafka broker起動

Linuxの場合

# Start the Kafka broker service
kafka-server-start.sh config/server.properties

【３】Quick Start

* 公式ドキュメントのQuick Startをやってみる
 => Step1-2は、既に上記で行っているので、Step3~Step5。

https://kafka.apache.org/quickstart
日本語版？
http://mogile.web.fc2.com/kafka/kafka200/quickstart.html

１）トピックを作成 & 確認

Linuxの場合

# STEP 3: CREATE A TOPIC TO STORE YOUR EVENTS
kafka-topics.sh --create --topic quickstart-events --bootstrap-server localhost:9092

# 確認
kafka-topics.sh --describe --topic quickstart-events --bootstrap-server localhost:9092

２）メッセージを送信

Linuxの場合

# STEP 4: WRITE SOME EVENTS INTO THE TOPIC
kafka-console-producer.sh --topic quickstart-events --bootstrap-server localhost:9092

# あとは、以下の関連記事の「Windowの場合」を参照

Apache Kafka ～環境構築 / Windows編～
https://dk521123.hatenablog.com/entry/2023/04/23/235534

３）メッセージを受信

Linuxの場合

# STEP 5: READ THE EVENTS
kafka-console-consumer.sh --topic quickstart-events --from-beginning --bootstrap-server localhost:9092

参考文献

http://java-study.blog.jp/archives/1075373530.html

プログラムの超個人的なメモ

Memo for Programming.

【Kafka】Apache Kafka ～環境構築 / Linux編～

■ はじめに

目次

【１】構築手順 - 通常版

０）前提条件

１）Kafka のインストール

【２】モジュール起動

１）zookeeper起動

２）Kafka broker起動

【３】Quick Start

１）トピックを作成 & 確認

２）メッセージを送信

３）メッセージを受信

参考文献

関連記事