重要なファイルとディレクトリ
- 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
Kafkaサービス
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(コントローラー)が開いています。