CLI Tools for Confluent Platform

Confluent Platform provides the following command-line tools. All of these are located in the Confluent Platform bin directory, except for the ccloud tool which is installed separately.

Name Description
ccloud This tool creates and manages Apache Kafka® topics in Confluent Cloud. For more information, see Confluent Cloud CLI.
confluent This tool manages Confluent Platform, including RBAC, secrets, and the ability to deploy a single-node Confluent Platform instance. 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 Auto Data Balancing.
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-3_0_0-reset This tool is used during upgrades from Control Center version 3.0.0. For more information, see Upgrading Control Center.
control-center-3_0_1-reset This tool is used during upgrades from Control Center version 3.0.1. For more information, see Upgrading Control Center.
control-center-console-consumer This tool starts the Control Center console consumer. For more information, see Confluent Monitoring Interceptors.
control-center-export This tool exports data from Control Center to an output file.
control-center-reset This tool resets Control Center and deletes all data. For more information, see Installing and configuring Control Center.
control-center-run-class This tool is a thin wrapper around the Control Center 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 ACLs. For more information, see Control Center UI Authentication.
control-center-start This tool starts Control Center. For a usage example, see Manual Install using ZIP and TAR Archives.
control-center-stop This tool stops Control Center. 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 Authorization using ACLs.
kafka-avro-console-consumer This tool receives Avro data in JSON format from the console. For more information, see Schema Formats, Serializers, and Deserializers.
kafka-avro-console-producer This tool sends Avro data in JSON format to the console. For more information, see Schema Formats, Serializers, and Deserializers.
kafka-broker-api-versions This tool displays the API versions of all nodes in the cluster.
kafka-configs This tool updates broker configs. For more information, see Changing Broker Configurations Dynamically.
kafka-console-consumer This tool reads data from Kafka topics and sends output to STDOUT. For more information, see Kafka Consumer.
kafka-console-producer This tool sends data to Kafka topics. For more information, see Kafka Producer.
kafka-consumer-groups This tool gets a list of the active groups in the cluster. For more information, see Kafka Consumer Group Command 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 Authentication using Delegation Tokens.
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.
kafka-log-dirs This tool gets a list of replicas per log directory on a broker.
kafka-mirror-maker This tool runs MirrorMaker. For more information, see Mirroring data between clusters in the Kafka Documentation.
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 Introduction.
kafka-mqtt-start This tool starts MQTT Proxy. For more information, see Introduction.
kafka-mqtt-stop This tool stops MQTT Proxy. For more information, see Introduction.
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
kafka-producer-perf-test This tool tests the producer performance for the Kafka cluster. For more information, see Auto Data Balancing.
kafka-protobuf-console-producer This tool sends Protobuf data in JSON format to the console. For more information, see Schema Formats, Serializers, and Deserializers.
kafka-protobuf-console-consumer This tool receives Protobuf data in JSON format from the console. For more information, see Schema Formats, Serializers, and Deserializers.
kafka-json-schema-console-producer This tool sends JSON schema data in JSON format from the console. For more information, see Schema Formats, Serializers, and Deserializers.
kafka-json-schema-console-producer This tool receives JSON schema data in JSON format from the console. For more information, see Schema Formats, Serializers, and Deserializers.
kafka-reassign-partitions This tool moves topic partitions between replicas. For more information, see Scaling the Cluster.
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 APIs.
kafka-rest-start This tool starts the REST Proxy. For more information, see Confluent REST APIs.
kafka-rest-stop This tool stops the REST Proxy. For more information, see Confluent REST APIs.
kafka-rest-stop-service This tool stops all running instances of the REST Proxy. For more information, see Confluent REST APIs.
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 Kafka.
kafka-streams-application-reset This tool resets an application and forces it to reprocess its data from the beginning. For more information, see Kafka Streams Application Reset Tool.
kafka-topics This tool is used to create, delete, describe, or change a Kafka topic. For more information, see Adding topics.
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 Generate test data.
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 ksqlDB Operations.
ksql-stop This tool stops the ksqlDB CLI. For more information, see Installing ksqlDB.
replicator This tool runs Replicator. For more information, see Multi-DC Deployment Architectures.
replicator-verifier This tool verifies the Replicator configuration. For more information, see Verifying a Replicator configuration.
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.
schema-registry-start This tool starts Schema Registry. For more information, see Schema Registry API Usage Examples.
schema-registry-stop This tool stops Schema Registry. For more information, see Schema Registry API Usage Examples.
schema-registry-stop-service This tool stops all running instances of the Schema Registry. For more information, see Schema Registry API Usage Examples.
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.
support-metrics-bundle This tool creates the “support metrics bundle” file in the current directory.
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 Manual Install using ZIP and TAR Archives.
zookeeper-server-stop This tool stops ZooKeeper. For more information, see Manual Install using ZIP and TAR Archives.
zookeeper-shell This tool connects to the ZooKeeper shell.