重要なファイルとディレクトリ
- Kafka のメイン インストール ディレクトリ:
/opt/kafka - Kafka ブローカー構成ファイル:
/opt/kafka/config/server.properties - Kafka ログ ディレクトリ (ブローカー ログ、保持されたイベント):
/opt/kafka/logs - Kafka バイナリと CLI ツール (
kafka-topics.sh,kafka-console-producer.sh、など）：/opt/kafka/bin - Kafka を管理するための Systemd サービス ユニット:
/etc/systemd/system/kafka.service
カフカサービス
sudo systemctl restart kafka
sudo systemctl enable kafka
sudo systemctl status kafka
トピックを作成する
/opt/kafka/bin/kafka-topics.sh --create --topic quickstart-events --bootstrap-server localhost:9092
トピックの詳細を確認します。
/opt/kafka/bin/kafka-topics.sh --describe --topic quickstart-events --bootstrap-server localhost:9092
イベント（メッセージ）の生成
/opt/kafka/bin/kafka-console-producer.sh --topic quickstart-events --bootstrap-server localhost:9092
1 行に 1 つのイベントを入力します。
プレス Ctrl+C 終了します。
イベントの消費
/opt/kafka/bin/kafka-console-consumer.sh --topic quickstart-events --from-beginning --bootstrap-server localhost:9092
プレス Ctrl+C 読むのをやめる。
イベントは、複数のクライアントによって複数回使用される可能性があります。
ログとトラブルシューティング
- Kafka のログ:
/opt/kafka/logs - Systemd ジャーナル:
sudo journalctl -u kafka -f - ポートの確保
9092（ブローカー）と9093（コントローラー）が開いています。
