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.

Usage

rpk topic produce [TOPIC] [flags]

Flags

Value Type Description

--acks

int

Number of acks required for producing (-1=all, 0=none, 1=leader) (default -1)

--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 REDPANDA_BROKERS environment variable with the comma-separated list of broker addresses.

--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: SCRAM-SHA-256, SCRAM-SHA-512.

--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 false).