This library only exposes the PartitionConsumer which is actually marked as depreciated in Rust version and consumer_with_config is suggested. Also it is very confusing on how this consumer consumes messages on restart does it start from first message how do i do manual offset commit strategy ?
This library only exposes the
PartitionConsumerwhich is actually marked as depreciated in Rust version andconsumer_with_configis suggested. Also it is very confusing on how this consumer consumes messages on restart does it start from first message how do i do manual offset commit strategy ?