Kafka常用指令速查手冊：高效工作必備

Kafka 指令一覽：快速提升工作效率

Apache Kafka 是一款流行的訊息佇列服務，它可以幫助您建立高吞吐量、低延遲的應用程式.如果您需要在應用程式中使用 Kafka，則需要熟悉 Kafka 的各種命令。

本文將為您提供一個 Kafka 指令一覽，幫助您快速提升工作效率。

1. 生產者命令

• kafka-console-producer：此命令允許您從命令列向 Kafka 中發送資料。
• kafka-producer：此指令可讓您使用 Java API 向 Kafka 中傳送資料。

2. 消費者指令

• 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- admin 管理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中文網其他相關文章！