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.
control-center-console-consumer - This tool starts the Control Center console consumer.
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 This tool resets Control Center and deletes all data. For more information, see Control Center Installation.
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.
control-center-start - This tool starts Control Center. For a usage example, see Start 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-alter-broker-health - This tool interacts with the Broker Health API to manage and describe the health status of Kafka brokers. You can use this tool to set a broker component’s health status by specifying the component (for example, UNSPECIFIED, STORAGE, NETWORK, or EXTERNAL_CONNECTIVITY_STARTUP) and applying a desired health status (DEGRADED or HEALTHY). The tool can also provide details on degraded brokers, which are less preferred as partition leaders than healthy brokers.
kafka-avro-console-consumer - This tool receives Avro data in JSON format from the console. For more information, see Formats, Serializers, and Deserializers.
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-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-groups - This tool helps to list groups of all types.
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-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-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-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-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-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-share-groups - This tool helps to list, describe, reset and delete share groups.
kafka-storage - This tool generates a Cluster UUID and format storages with the cluster ID when running Kafka in KRaft mode.
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-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.
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.
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.
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.