What happened
When the request of producer has more than one batch.
The producer only sends back the base offset of the first batch. Therefore batch metadata is not resolved for the batches that are after the first one.
Expected behavior
record metadata in:
let produce_output = producer.send(RecordKey::NULL, value).await?;
let record_metadata = produce_output.wait().await?;
should not fail with : receiving from an empty and closed channel
How to reproduce it (as minimally and precisely as possible)
Steps to reproduce the behavior:
- Run the command:
fluvio topic create topicname
fluvio produce topicname -f input.txt
with this file:
input.txt