rpk topic produce
Produce records to a topic.
Producing records reads from STDIN, parses input according to --format, and
produce records to Redpanda. The input formatter understands a wide variety of
formats.
Parsing input operates on either sizes or on delimiters, both of which can be specified in the same formatting options. If using sizes to specify something, the size must come before what it is specifying. Delimiters match on an exact text basis. This command will quit with an error if any input fails to match your specified format.
Flags
| Value | Type | Description |
|---|---|---|
--acks |
int |
Number of acks required for producing ( |
--allow-auto-topic-creation |
- |
Auto-create non-existent topics; requires auto_create_topics_enabled on the broker |
--delivery-timeout |
duration |
Per-record delivery timeout, if non-zero, min 1s |
-H, --header |
stringArray |
Headers in format key:value to add to each record (repeatable) |
-h, --help |
- |
Help for produce |
-k, --key |
string |
A fixed key to use for each record (parsed input keys take precedence) |
-p, --partition |
int32 |
Partition to directly produce to, if non-negative (also allows %p parsing to set partitions) (default -1) |
-Z, --tombstone |
- |
Produce empty values as tombstones |
--brokers |
strings |
Comma-separated list of broker <ip>:<port> pairs
(for example,
` --brokers '192.168.78.34:9092,192.168.78.35:9092,192.179.23.54:9092' `
). Alternatively, you may set the |
--config |
string |
Redpanda config file, if not set the file will be searched for in the default locations. |
--password |
string |
SASL password to be used for authentication. |
--sasl-mechanism |
string |
The authentication mechanism to use.
Supported values: |
--tls-cert |
string |
The certificate to be used for TLS authentication with the broker. |
--tls-enabled |
- |
Enable TLS for the Kafka API (not necessary if specifying custom certs). |
--tls-key |
string |
The certificate key to be used for TLS authentication with the broker. |
--tls-truststore |
string |
The truststore to be used for TLS communication with the broker. |
--user |
string |
SASL user to be used for authentication. |
-v, --verbose |
- |
Enable verbose logging (default |