GET /produce/$TOPIC/$MESSAGE?key=$KEY
:
Sends a single message ($MESSAGE
) to a topic ($TOPIC
) using HTTP GET.
Optionally message key can be appended with a query parameter?key=$KEY
.
Without message key:
[GET | POST] /produce/$TOPIC
:
Produces one or more messages to a single topic ($TOPIC
). Messages are sent
using request body as JSON. Structure of the message JSON is:
value
field is required. partition
, timestamp
, key
and headers
fields are optional. When left blank, partition
and timestamp
fields will
be assigned by Kafka brokers. It’s valid to send a single message or array of
messages as JSON.
[GET | POST] /produce
:
Produces one or more messages to a single or multiple topics. Messages are
sent using request body as JSON. Structure of the message JSON is the same as
the above, there’s only an additional topic
field:
topic
and value
fields are required. partition
, timestamp
, key
and headers
fields are optional. When left blank, partition
and
timestamp
fields will be assigned by Kafka brokers. It’s valid to send a
single message or array of messages as JSON.
acks=all
producer
configuration,
which means the topic partition’s leader will wait for the all in-sync
replicas to acknowledge the produced messages.