SLV Install - Kafka

Kafka Cluster を選ぶ理由

Apache Kafka は高い耐久性とスループットを備えた分散ストリーミングプラットフォームで、リアルタイムデータパイプラインや分散サービス、分析基盤を支えます。slv install を利用すれば、ブローカー設定やトピック初期値、監視連携を統一した状態で Kafka クラスタを簡単に展開できます。

ハイライト

Kafka: https://kafka.apache.org/
毎秒数百万メッセージの処理を高い堅牢性とともに実現。
AKHQ UI を同梱し、トピックの状態確認やコンシューマラグの監視、デバッグを容易に実行可能。

コマンドの実行

Kafka ブローカーを稼働させるホストを指定し、コンポーネント一覧から Kafka Cluster を選択します。

bash
$ slv install -i 1.1.1.1,
🚀 Installing software components...
? Select Software Component to Install (Redis)
  Redis
  TiDB (MySQL Cluster)
  Grafana
  Prometheus
  Node Exporter
❯ Kafka Cluster

注意: 1.1.1.1 の部分は、ご自身のサーバーの IP アドレスに置き換えてください。

実行内容の確認

Ansible 起動前に、インベントリやプレイブックのパスを確認してください。特定ホストに絞りたい場合は --limit を指定します。

bash
🚀 Installing software components...
? Select Software Component to Install (Redis) › Kafka Cluster
✅ You selected: Kafka Cluster

📋 Installation Details:
Software: Kafka Cluster
Inventory: 1.1.1.1,
Playbook: /Users/fumi/.slv/template/0.9.800/ansible/cmn/software/install-kafka.yml
? Do you want to proceed with the installation? (y/N) ›

実行中のログ

承認すると、slv が Kafka ブローカーや systemd サービス、必要に応じて ZooKeeper などの関連コンポーネントを構成します。

bash
🚀 Running ansible: ansible-playbook -i 1.1.1.1, -u solv /Users/fumi/.slv/template/0.9.800/ansible/cmn/software/install-kafka.yml

PLAY [Install and configure Kafka Cluster] ***********************************************************

TASK [Gathering Facts] *******************************************************************************

エンドポイントの確認

完了後、Kafka ブローカーの接続先と AKHQ UI の URL が表示されます。すぐにメッセージの送受信や監視を開始できます。

bash
✅ Installation completed successfully!

🌐 Access Information:

Kafka Broker Endpoint: 1.1.1.1:9092
AKHQ UI: http://1.1.1.1:5000

ダッシュボード

http://1.1.1.1:5000 の AKHQ にアクセスしてトピックやコンシューマグループを管理し、必要に応じて Kafka Exporter などを Prometheus に組み込んで Grafana で可視化すると運用がさらにしやすくなります。