KafkaEx.Protocol.Produce
Summary↑
| create_request(correlation_id, client_id, topic, partition, value, key, required_acks, timeout) |
| parse_response(unknown) |
Functions
create_request(correlation_id, client_id, topic, partition, value, key, required_acks, timeout)