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 |
-partition | Partition to consume from (used in conjunction with the |
-partition-count | Number of partitions to create (used in conjunction with the |
-password | Password for SASL PLAIN authentication |
-records | Double comma (,,) separated strings to produce as records (used in conjunction with the |
-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 |
Last updated