Apache Kafka 是一款流行的消息队列服务,它可以帮助您构建高吞吐量、低延迟的应用程序。如果您需要在应用程序中使用 Kafka,则需要熟悉 Kafka 的各种命令。
本文将为您提供一个 Kafka 命令一览,帮助您快速提升工作效率。
kafka-console-producer
:该命令允许您从命令行向 Kafka 中发送数据。kafka-console-producer
:该命令允许您从命令行向 Kafka 中发送数据。kafka-producer
:该命令允许您使用 Java API 向 Kafka 中发送数据。kafka-console-consumer
:该命令允许您从命令行读取 Kafka 中的数据。kafka-consumer
:该命令允许您使用 Java API 读取 Kafka 中的数据。kafka-topics
:该命令允许您管理 Kafka 中的主题。kafka-brokers
:该命令允许您管理 Kafka 中的代理。kafka-admin
:该命令允许您管理 Kafka 中的集群。kafka-cat
:该命令允许您查看 Kafka 中的消息。kafka-diff
:该命令允许您将 Kafka 中的集群进行差异化。kafka-mirror-topics
:该命令允许您将 Kafka 中的主题镜像到另一个集群。kafka-configs
kafka-producer
:该命令允许您使用 Java API 向 Kafka 中发送数据。kafka-console-consumer
:该命令允许您从命令行读取 Kafka 中的数据。kafka-consumer
:该命令允许您使用 Java API 读取 Kafka 中的数据。kafka-topics
:该命令允许您管理 Kafka 中的主题。kafka-brokers
:该命令允许您管理 Kafka 中的代理。
kafka-admin
:该命令允许您管理 Kafka 中的集群。
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中文网其他相关文章!