Skip to main content

Module worker

Module worker 

Source

Modulesยง

fetch_latest_offset ๐Ÿ”’
flush ๐Ÿ”’
produce ๐Ÿ”’

Structsยง

BackgroundProducerWorker ๐Ÿ”’
PendingRequest ๐Ÿ”’
ProduceRequest ๐Ÿ”’
ProduceResultHandle ๐Ÿ”’
Receives the committed offsets when data has been committed to Kafka or an unrecoverable error has been encountered.
ProduceResultReceiver ๐Ÿ”’

Enumsยง

WorkerRequest ๐Ÿ”’