Kafka 共通コマンド クイック リファレンス マニュアル: 効率的な作業に不可欠

Kafka コマンドの概要: 作業効率をすばやく向上させる

Apache Kafka は、高スループット、低遅延のアプリケーション プログラムの構築に役立つ人気のメッセージ キュー サービスです。 。アプリケーションで Kafka を使用する必要がある場合は、Kafka のさまざまなコマンドに精通している必要があります。

この記事では、作業効率をすぐに向上させるのに役立つ Kafka コマンドの概要を説明します。

1. プロデューサー コマンド

• kafka-console-Producer: このコマンドを使用すると、コマンド ラインから Kafka にデータを送信できます。
• kafka-Producer: このコマンドを使用すると、Java API を使用して Kafka にデータを送信できます。

2. Consumer コマンド

• kafka-console-consumer: このコマンドを使用すると、コマンド ラインから Kafka からデータを読み取ることができます。
• kafka-consumer: このコマンドを使用すると、Java API を使用して Kafka からデータを読み取ることができます。

3. 管理コマンド

• kafka-topics: このコマンドを使用すると、Kafka のトピックを管理できます。
• kafka-brokers: このコマンドを使用すると、Kafka でブローカーを管理できます。
• kafka-admin: このコマンドを使用すると、Kafka でクラスターを管理できます。

4. ツール コマンド

• kafka-cat: このコマンドを使用すると、Kafka でメッセージを表示できます。
• kafka-diff: このコマンドを使用すると、Kafka でクラスターを区別できます。
• kafka-mirror-topics: このコマンドを使用すると、Kafka のトピックを別のクラスターにミラーリングできます。

5. 設定コマンド

• kafka-configs: このコマンドを使用すると、Kafka でクラスターの設定ファイルを管理できます。

具体的なコマンドの例

1. kafka-console-Producer を使用して Kafka にデータを送信します

bin/kafka-console-producer --broker-list localhost:9092 --producer-property parse.key=true --producer-property key.separator=, --producer-property print.key=true --producer-property value.serializer=StringEncoder --producer-property key.serializer=StringEncoder --producer-config config/producer.config --request-required-ACKS=1

2. kafka-console-consumer を使用して Kafka から読み取りますデータの取得

bin/kafka-console-consumer --broker-list localhost:9092 --consumer-property auto.offset.reset=earlies --consumer-property group.id=my-consumer-group --consumer-property key.deserializer=StringDecoder --consumer-property value.deserializer=StringDecoder --consumer-config config/consumer.config --from-beginning --max-message-count 10

3. kafka-topics を使用して Kafka のトピックを管理します

bin/kafka-topics --create --zookeeper localhost:2181 --replication-failover-replication-set 3 --replication-failover-max-retries 10 --replication-failover-backoff-ms 1000 --default-replication-factors 1 --num-replicas 1 --partitions 1 --describe --list --delete --assignment --authorized-operators

4. kafka-brokers を使用して Kafka

bin/kafka-brokers --describe --create-topics --delete-topics --add-replicas-to-broker --remove-replicas-from-broker --enable-controller --shutdown --update-config --config

5 のブローカーを管理します。管理者は Kafka でクラスターを管理します

bin/kafka-admin --create-topics --delete-topics --describe-topics --create-users --delete-users --describe-users --create-acls --delete-acls --describe-acls --describe-config --config

概要

この記事では、作業効率を迅速に向上させるのに役立つ Kafka コマンドの概要を説明します。これらのコマンドは、Kafka でトピック、ブローカー、クラスター、データを管理するのに役立ちます。

Kafka についてさらに詳しく知りたい場合は、Kafka の公式ドキュメントを参照してください。

以上がKafka 共通コマンド クイック リファレンス マニュアル: 効率的な作業に不可欠の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。