Modulesยง
- fetch_
latest_ ๐offset - flush ๐
- produce ๐
Structsยง
- Background
Producer ๐Worker - Pending
Request ๐ - Produce
Request ๐ - Produce
Result ๐Handle - Receives the committed offsets when data has been committed to Kafka or an unrecoverable error has been encountered.
- Produce
Result ๐Receiver
Enumsยง
- Worker
Request ๐