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.
-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
Last updated