warpstream kcmd

warpstream kcmd

The warpstream kcmd subcommand can be used to interact with a WarpStream cluster. It provides similar capabilities as the Apache Kafka command line tools for administering a Kafka cluster.

The following table displays the available warpstream kcmd arguments.

Argument	Description
-bootstrap-host	Kafka bootstrap host
-bootstrap-port	Kafka bootstrap port
-client-id	Client ID to pass along to WarpStream
-group	Group to perform an operation on
-key	Key to use for the produced kafka records
-offset	Offset to consume from (used in conjunction with the -fetch subcommand) (optional)
-partition	Partition to consume from (used in conjunction with the -fetch subcommand) (optional)
-partition-count	Number of partitions to create (used in conjunction with the -topic -create subcommands) (optional)
-password	Password for SASL PLAIN authentication
-records	Double comma (,,) separated strings to produce as records (used in conjunction with the -produce subcommand)
-timestamp list-offsets	Timestamp to use for the list-offsets request type
-tls	Dial with TLS or not
-topic	Topic name
-type	Can be one of: produce, fetch, diagnose-connection, create-topic, list-topics, delete-topic, fetch-offsets, describe-groups, broker-metadata, commit-offsets, list-groups, describe-group, list-offsets
-username	Username for SASL PLAIN authentication