CONFLUENT CLI
Create a Kafka topic.
confluent kafka topic create <topic> [flags]
--url string Base URL of REST Proxy Endpoint of Kafka Cluster (include /kafka for embedded Rest Proxy). Must set flag or CONFLUENT_REST_URL. --ca-cert-path string Path to a PEM-encoded CA to verify the Confluent REST Proxy. --client-cert-path string Path to client cert to be verified by Confluent REST Proxy, include for mTLS authentication. --client-key-path string Path to client private key, include for mTLS authentication. --no-auth Include if requests should be made without authentication headers, and user will not be prompted for credentials. --prompt Bypass use of available login credentials and prompt for Kafka Rest credentials. --partitions int32 Number of topic partitions. (default 6) --replication-factor int32 Number of replicas. (default 3) --config strings A comma-separated list of topic configuration ('key=value') overrides for the topic being created. --if-not-exists Exit gracefully if topic already exists. --context string CLI Context name.
-h, --help Show help for this command. -v, --verbose count Increase verbosity (-v for warn, -vv for info, -vvv for debug, -vvvv for trace).
Create a topic named my_topic with default options at specified cluster (providing Kafka REST Proxy endpoint).
my_topic
confluent kafka topic create my_topic --url http://localhost:8082
Create a topic named my_topic_2 with specified configuration parameters.
my_topic_2
confluent kafka topic create my_topic_2 --url http://localhost:8082 --config cleanup.policy=compact,compression.type=gzip