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.

ArgumentDescription

-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