rpk topic
Manage Kafka topics, including creating, deleting, and configuring topics. Also includes commands for producing and consuming messages.
Subcommands
| Command | Description |
|---|---|
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 |
|
Create one or more Kafka topics with configurable partitions, replication factor, and topic-level settings. |
|
Delete one or more Kafka topics. This operation is irreversible and removes all data in the topics. |
|
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 cloud storage status of a topic, including storage mode, offset availability, segment sizes, and synchronization state. |
|
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 |
|
Trim records from topics by setting the LogStartOffset for partitions to the requested offset. All segments whose base offset is less than the requested offset are deleted, and any records within the segment before the requested offset can no longer be read. |
Global flags
| Value | Type | Description |
|---|---|---|
|
string |
Redpanda or |
|
stringArray |
Override |
|
bool |
Ignore |
|
string |
|
|
bool |
Enable verbose logging. |