rpk topic

Add partitions to existing topics.

Set, delete, add, and remove key/value configs for a topic. This command allows you to incrementally alter the configuration for multiple topics at a time.

Analyze topics. This command consumes records from the specified topics to determine topic characteristics such as batch rate and batch size.

Consume records from topics. Consuming records reads from any amount of input topics, formats each record according to --format, and prints them to STDOUT.

Create one or more Kafka topics with configurable partitions, replication factor, and topic-level settings. All topics created with one invocation have the same number of partitions, replication factor, and key/value configs.

Delete one or more Kafka topics. This command deletes all requested topics, printing the success or fail status per topic.

Print detailed information about topics. There are three potential views: a summary of the topic, the topic configurations, and a detailed partitions section.

Describe the topic storage status. This commands prints detailed information about the cloud storage status of a given topic, the information is divided in 4 sections: SUMMARY.

List topics, optionally listing specific topics. This command lists all topics that you have access to by default.

Produce records to a topic. Producing records reads from STDIN, parses input according to --format, and produces records to Redpanda.

Trim records from topics. This command allows you to trim records from topics, to trim the topics Redpanda sets the LogStartOffset for partitions to the requested offset.

string

Redpanda or rpk config file; default search paths are ~/.config/rpk/rpk.yaml, $PWD/redpanda.yaml, and /etc/redpanda/redpanda.yaml.

stringArray

Override rpk configuration settings; -X help for detail or -X list for terser detail.

bool

Ignore rpk.yaml and redpanda.yaml; use default settings.

string

rpk profile to use.

bool

Enable verbose logging.