Kafka コマンドの詳細: 初心者から専門家まで

Kafka コマンドの詳細な説明: 初心者からマスターまで

1. はじめに

Apache Kafka は、分散パブリッシュ/サブスクライブ メッセージング システムです。高スループットかつ低遅延でメッセージを送受信します。 Kafka は、リアルタイム データ パイプライン、マイクロサービス アーキテクチャ、ストリーミング アプリケーションの構築に広く使用されています。

2. 基本コマンド

2.1 トピックの作成

kafka-topics --create --topic test-topic --partitions 3 --replication-factor 2

このコマンドは、3 つのパーティションと 2 つのレプリカを持つ test-topic という名前のトピックを作成します。 。

2.2 トピックの一覧表示

kafka-topics --list

このコマンドは、利用可能なすべてのトピックを一覧表示します。

2.3 トピックの詳細の表示

kafka-topics --describe --topic test-topic

このコマンドは、パーティション、レプリカ、メッセージ保持ポリシーなど、test-topic トピックに関する詳細情報を表示します。

2.4 運用メッセージ

kafka-console-producer --topic test-topic

このコマンドは、test-topic トピックにメッセージを送信できる対話型コンソールを起動します。

2.5 メッセージの消費

kafka-console-consumer --topic test-topic --from-beginning

このコマンドは、test-topic トピックからのメッセージを消費できる対話型コンソールを起動します。

3. 高度なコマンド

3.1 トピック パーティションの数を変更する

kafka-topics --alter --topic test-topic --partitions 5

このコマンドは、test-topic トピックのパーティション数を増やします。 5まで。

3.2 トピックのレプリカ数の変更

kafka-topics --alter --topic test-topic --replication-factor 3

このコマンドは、test-topic トピックのレプリカの数を 3 に増やします。

3.3 トピックのメッセージ保持ポリシーの設定

kafka-topics --alter --topic test-topic --config retention.ms=60000

このコマンドは、test-topic トピックのメッセージ保持時間を 60 秒に設定します。

3.4 コンシ​​ューマ グループの作成

kafka-consumer-groups --create --group test-group

このコマンドは、test-group という名前のコンシューマ グループを作成します。

3.5 コンシューマ グループの一覧表示

kafka-consumer-groups --list

このコマンドは、使用可能なすべてのコンシューマ グループを一覧表示します。

3.6 コンシューマ グループの詳細の表示

kafka-consumer-groups --describe --group test-group

このコマンドは、メンバー、オフセット、消費速度など、test-groupコンシューマ グループに関する詳細情報を表示します。

4. トラブルシューティング

4.1 トピックが存在しません

「不明なトピックまたはパーティション」エラーが表示された場合は、トピックが存在しないことを意味します。存在する。 kafka-topics --create コマンドを使用してトピックを作成できます。

4.2 パーティションが存在しません

「不明なパーティション」エラーが表示された場合は、パーティションが存在しないことを意味します。 kafka-topics --alter コマンドを使用して、トピックのパーティション数を変更できます。

4.3 レプリカの数が正しくありません

「レプリケーション係数が範囲外です」エラーを受け取った場合は、トピックのレプリカの数が正しくないことを意味します。 kafka-topics --alter コマンドを使用して、トピックのレプリカの数を変更できます。

4.4 メッセージ保持時間が正しくありません

保持時間が範囲外ですエラーを受け取った場合は、トピックのメッセージ保持時間が正しくないことを意味します。 kafka-topics --alter コマンドを使用して、トピックのメッセージ保持期間を変更できます。

5. 概要

Kafka は、リアルタイム データ パイプライン、マイクロサービス アーキテクチャ、ストリーミング アプリケーションの構築に使用できる強力な分散パブリッシュ/サブスクライブ メッセージング システムです。この記事では、Kafka のいくつかの基本コマンドと高度なコマンド、および一般的な問題のトラブルシューティング方法について説明します。

以上がKafka コマンドの詳細: 初心者から専門家までの詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。