Confluent Platform CLI Tools

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 installs and administers a development Confluent Platform environment under localhost. This tool is for development purposes only and is not suitable for a production environment. 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 Installing and Configuring Kafka Connect.
connect-standalone This tool runs Connect in standalone mode. For more information, see see Installing and Configuring 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 Registry Serializer and Formatter.
kafka-avro-console-producer This tool sends Avro data in JSON format to the console. For more information, see Schema Registry Serializer and Formatter.
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-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 Proxy.
kafka-rest-start This tool starts the REST Proxy. For more information, see Confluent REST Proxy.
kafka-rest-stop This tool stops the REST Proxy. For more information, see Confluent REST Proxy.
kafka-rest-stop-service This tool stops all running instances of the REST Proxy. For more information, see Confluent REST Proxy.
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 Application Reset Tool.
kafka-topics This tool is used to create, delete, describe, or change an 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 KSQL. For more information, see Configuring KSQL CLI.
ksql-datagen This tool generates test data that complies with a custom schema that you define. For more information, see Generate Custom Test Data by Using the ksql-datagen tool.
ksql-print-metrics This tool collects JMX metrics from the KSQL server process. For more information, see Check the Health of a KSQL Server.
ksql-run-class This tool is a thin wrapper around the KSQL 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 KSQL server. For more information, see Starting the KSQL Server.
ksql-server-stop This tool stops the KSQL server. For more information, see KSQL Operations.
ksql-stop This tool stops the KSQL CLI. For more information, see Installation and Configuration.
replicator This tool runs Confluent Replicator. For more information, see Replicator for Multi-Datacenter Replication.
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 Using Schema Registry.
schema-registry-start This tool starts Schema Registry. For more information, see Using Schema Registry.
schema-registry-stop This tool stops Schema Registry. For more information, see Using Schema Registry.
schema-registry-stop-service This tool stops all running instances of the Schema Registry. For more information, see Using Schema Registry.
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. For more information, see Sharing Proactive Support Metadata with Confluent manually.
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 Migrating ZooKeeper.
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.