CLI Tools Shipped With Confluent Platform
Confluent Platform provides several command-line (CLI) tools, which includes the Kafka CLI tools and additional Confluent Platform-specific tools.
All of these tools can be found in the Confluent Platform bin directory. The
confluent tool can be installed separately, but it is recommended that you use
the version provided with Confluent Platform.
You can find versions of some of these tools for use with Windows (.bat files), under CONFLUENT_HOME/bin/windows/.
Note that if you are using a Kafka CLI tool that is provided with Confluent Platform,
the tool does not have an .sh extension.
Search by tool name
Tool list
confluent
This tool manages Confluent Cloud and Confluent Platform, including RBAC, secrets, and the ability to deploy a single-node Confluent Platform instance as well as creating, updating, and deleting topics. For more information, see Confluent CLI.
confluent-hub
This tool installs and manages connectors. For more information, see Confluent Hub Command Reference.
confluent-rebalancer
This tool balances data and partitions between brokers. For more information, see Quick Start for Auto Data Balancing in Confluent Platform.
connect-distributed
This tool runs Connect in distributed mode. For more information, see Getting Started with Kafka Connect.
connect-standalone
This tool runs Connect in standalone mode. For more information, see see Getting Started with Kafka Connect.
control-center-console-consumer
This tool starts the Control Center (Legacy) console consumer. For more information, see Monitor Production and Consumption Using Control Center (Legacy) in Confluent Platform.
control-center-export
This tool exports data from Control Center (Legacy) to an output file.
control-center-reset
This tool resets Control Center (Legacy) and deletes all data. For more information, see Manage Control Center (Legacy) for Confluent Platform.
control-center-run-class
This tool is a thin wrapper around the Control Center (Legacy) Java class. It is mainly used by the start and stop scripts and should not be run by itself.
control-center-set-acls
This tool is used to set the Control Center (Legacy) ACLs. For more information, see Configure HTTP Basic Authentication with Control Center (Legacy) on Confluent Platform.
control-center-start
This tool starts Control Center (Legacy). For a usage example, see Control Center (Legacy).
control-center-stop
This tool stops Control Center (Legacy). For a usage example, see Enable and disable dynamic editing of broker configurations.
kafka-acls
This tool adds, removes, and lists ACLs. For more information, see Manage Access Control Lists (ACLs) for Authorization in Confluent Platform.
kafka-add-brokers
This tool describes the status of the Confluent Balancer broker addition operations. For more information, see Add a broker (restart).
kafka-avro-console-consumer
This tool receives Avro data in JSON format from the console. For more information, see Formats, Serializers, and Deserializers.
kafka-avro-console-producer
This tool sends Avro data in JSON format to the console. For more information, see Formats, Serializers, and Deserializers.
kafka-broker-api-versions
This tool displays the API versions of all nodes in the cluster.
kafka-cells-admin
This tool manages cells in a Kafka cluster.
kafka-configs
This tool updates broker configs and topic configs. For more information, see Dynamically change broker settings and Modifying topics.
kafka-client-metrics
This tool enables you to describe and change client metric configuration values. For example, use the following command to list client metrics.
kafka-client-metrics --bootstrap-server <host:port> --list
kafka-cluster
Use this tool to get the ID of a cluster or unregister a cluster. For more information, see Generate and format IDs.
kafka-cluster-links
This tool creates and manages Cluster Linking between Confluent Enterprise and Confluent Cloud clusters.
kafka-console-consumer
This tool reads data from Kafka topics and sends output to STDOUT. For more information, see Kafka Consumer for Confluent Platform.
kafka-console-producer
This tool sends data to Kafka topics. For more information, see Kafka Producer for Confluent Platform.
kafka-consumer-groups
This tool gets a list of the active groups in the cluster. For more information, see Kafka consumer group tool.
kafka-consumer-perf-test
This tool tests the consumer performance for the Kafka cluster.
kafka-delegation-tokens
This tool creates, renews, expires, and describes delegation tokens. For more information, see Use Delegation Tokens for Authentication in Confluent Platform.
kafka-delete-records
This tool deletes partition records.
kafka-dump-log
This tool parses a log file and dumps its contents to the console. This is useful for debugging log segments. For more information, see Debug log segments.
kafka-features
This tool manages feature flags to disable or enable functionality at runtime in Kafka.
kafka-get-offsets
This tool provides an interactive shell for getting topic-partition offsets.
kafka-json-schema-console-producer
This tool sends JSON schema data in JSON format from the console. For more information, see Formats, Serializers, and Deserializers.
kafka-json-schema-console-consumer
This tool receives JSON schema data in JSON format from the console. For more information, see Formats, Serializers, and Deserializers.
kafka-leader-election
This tool initiates leader election for topic partitions.
kafka-leader-exclusion
This tool makes calls to Leadership Priority API. It changes leadership priority and describes demoted brokers. Demoted brokers will be less preferred as partition leaders compared to brokers with normal leadership priority.
kafka-log-dirs
This tool gets a list of replicas per log directory on a broker.
kafka-metadata-quorum
This tool describes the metadata quorum status. This tool is useful when you are debugging a cluster in KRaft mode. For more information, see Describe runtime status.
kafka-metadata-shell
This tool enables you to interactively examine the metadata stored in a KRaft cluster. For more information, see Inspect the metadata partition.
kafka-mirror-maker
This tool runs MirrorMaker. For more information, see Mirroring data between clusters in the Kafka Documentation.
kafka-mirrors
This tool creates and manages identical mirror topics between clusters using Cluster Linking.
kafka-mqtt-run-class
This tool is a thin wrapper around the MQTT Proxy Java class. It is mainly used by the start and stop scripts and should not be run by itself. For more information, see MQTT Proxy for Confluent Platform.
kafka-mqtt-start
This tool starts MQTT Proxy. For more information, see MQTT Proxy for Confluent Platform.
kafka-mqtt-stop
This tool stops MQTT Proxy. For more information, see MQTT Proxy for Confluent Platform.
kafka-preferred-replica-election
This tool transfers the leadership for each partition back to the “preferred replica”
and is used to balance leadership among the servers. For more information, see the
Apache Kafka wiki.
This tool has been deprecated in Kafka 2.4 and was replaced by kafka-leader-election.
kafka-producer-perf-test
This tool tests the producer performance for the Kafka cluster. For more information, see Quick Start for Auto Data Balancing in Confluent Platform.
kafka-protobuf-console-producer
This tool sends Protobuf data in JSON format to the console. For more information, see Formats, Serializers, and Deserializers.
kafka-protobuf-console-consumer
This tool receives Protobuf data in JSON format from the console. For more information, see Formats, Serializers, and Deserializers.
kafka-reassign-partitions
This tool moves topic partitions between replicas. For more information, see Scaling the cluster (adding a node to a Kafka cluster).
kafka-rebalance-cluster
This tool provides visibility into the status of the SBC component, informing whether the component is disabled, starting up, or ready to serve requests. For more information, see Monitoring the balancer with kafka-rebalance-cluster.
kafka-remove-brokers
This tool executes and describes broker removal operations. For more information, see kafka-remove-brokers.
kafka-replica-exclusions
This tool sets, removes and describes broker replica placement exclusion.
kafka-replica-status
This tool prints out the replica status of partitions.
kafka-replica-verification
This tool validates that all replicas for a set of topics have the same data.
kafka-rest-run-class
This tool is a thin wrapper around the REST Proxy Java class. It is mainly used by the start and stop scripts and should not be run by itself. For more information, see Confluent REST Proxy for Apache Kafka.
kafka-rest-start
This tool starts the REST Proxy. For more information, see Confluent REST Proxy for Apache Kafka.
kafka-rest-stop
This tool stops the REST Proxy. For more information, see Confluent REST Proxy for Apache Kafka.
kafka-rest-stop-service
This tool stops all running instances of the REST Proxy. For more information, see Confluent REST Proxy for Apache Kafka.
kafka-run-class
This tool is a thin wrapper around the Kafka Java class. It is mainly used by the start and stop scripts and should not be run by itself.
kafka-server-start
This tool starts Kafka.
kafka-server-stop
This tool stops an Kafka broker or controller. Use the process-role parameter to specify a broker or controller.
kafka-storage
This tool generates a Cluster UUID and format storages with the cluster ID when running Kafka in KRaft mode.
kafka-streams-application-reset
This tool resets an application and forces it to reprocess its data from the beginning. For more information, see Reset Kafka Streams Applications in Confluent Platform.
kafka-topics
This tool is used to create, delete, describe, or change a Kafka topic. For more information, see Adding topics.
kafka-transactions
This tool lists and describes transactions. Use to detect and abort hanging transactions.
kafka-verifiable-consumer
This tool consumes messages from a topic and emits consumer events as JSON objects to STDOUT. For example, group rebalances, received messages, and offsets committed.
kafka-verifiable-producer
This tool produces increasing integers to the specified topic and prints
JSON metadata to STDOUT on each “send” request. This makes externally
visible which messages have been acked and which have not.
ksql
This tool runs ksqlDB. For more information, see Configure ksqlDB CLI.
ksql-datagen
This tool generates test data that complies with a custom schema that you define. For more information, see kafka-connect-datagen.
ksql-migrations
This tool manages metadata schemas for your ksqlDB clusters by applying statements from migration files to your ksqlDB clusters. For more info, see Manage metadata schemas.
ksql-restore-command
This tool restores the command topic.
ksql-run-class
This tool is a thin wrapper around the ksqlDB Java class. It is mainly used by the start and stop scripts and should not be run by itself.
ksql-server-start
This tool starts the ksqlDB server. For more information, see Starting the ksqlDB Server.
ksql-server-stop
This tool stops the ksqlDB server. For more information, see Operate ksqlDB for Confluent Platform.
ksql-stop
This tool stops the ksqlDB CLI. For more information, see Install ksqlDB for Confluent Platform.
ksql-test-runner
This tool is a ksqlDB testing tool that can test a set of KSQL statements.
replicator
This tool runs Replicator. For more information, see Overview of Multi-Datacenter Deployment Solutions on Confluent Platform.
replicator-verifier
This tool verifies the Replicator configuration. For more information, see Verify Replicator Configuration for Confluent Platform.
schema-registry-run-class
This tool is a thin wrapper around the Schema Registry Java class. It is mainly used by the start and stop scripts and should not be run by itself. For more information, see Schema Registry API Usage Examples for Confluent Platform.
schema-registry-start
This tool starts Schema Registry. For more information, see Schema Registry API Usage Examples for Confluent Platform.
schema-registry-stop
This tool stops Schema Registry. For more information, see Schema Registry API Usage Examples for Confluent Platform.
schema-registry-stop-service
This tool stops all running instances of the Schema Registry. For more information, see Schema Registry API Usage Examples for Confluent Platform.
security-plugins-run-class
This tool is a thin wrapper around the Confluent Security Plugins Java class. It is mainly used by the start and stop scripts and should not be run by itself.
sr-acl-cli
This tool runs the Schema Registry ACL CLI tool. For more information, see Schema Registry ACL Authorizer for Confluent Platform.
trogdor
This tool is a test framework for Kafka. Trogdor can run benchmarks and other workloads. Trogdor can also inject faults in order to stress test the system.
zookeeper-security-migration
This tool is used to update the ACLs of znodes as part of the process of setting up ZooKeeper authentication. For more information, see Adding security to a running ZooKeeper cluster.
zookeeper-server-start
This tool starts ZooKeeper. For more information, see Install Confluent Platform using ZIP and TAR Archives.
As of Confluent Platform 7.5, ZooKeeper is deprecated for new deployments. Confluent recommends KRaft mode for new deployments. For more information, see KRaft Overview for Confluent Platform.
zookeeper-server-stop
This tool stops ZooKeeper. For more information, see Install Confluent Platform using ZIP and TAR Archives.
zookeeper-shell
This tool connects to the ZooKeeper shell.