Kafka 공통 명령 빠른 참조 매뉴얼: 효율적인 작업에 필수

Kafka 명령 개요: 작업 생산성을 빠르게 향상

Apache Kafka는 처리량이 높고 대기 시간이 짧은 애플리케이션을 구축하는 데 도움이 되는 인기 있는 메시지 대기열 서비스입니다. 애플리케이션에서 Kafka를 사용해야 하는 경우 Kafka의 다양한 명령에 익숙해져야 합니다.

이 문서에서는 작업 효율성을 빠르게 향상시키는 데 도움이 되는 Kafka 명령에 대한 개요를 제공합니다.

1. 생산자 명령

• kafka-console-producer: 이 명령을 사용하면 명령줄에서 Kafka로 데이터를 보낼 수 있습니다. 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-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에서 데이터를 읽습니다. 🎜

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 중국어 웹사이트의 기타 관련 기사를 참조하세요!