Add ACK channel to commit Kafka messages

petabi / eventio

A Collection of Event I/O Processors

Apache License 2.0

1 stars 1 forks source link

Add ACK channel to commit Kafka messages #3

Closed msk closed 5 years ago

msk commented 5 years ago

A message is consumed when an ack message for the last Entry in ForwardMode is received, and committed when there is no incoming ack message in the channel.

Requires Rust>=1.34 to use TryInto.