[Host.Kafka] Fix and improve commit logic

zarusz / SlimMessageBus

Lightweight message bus interface for .NET (pub/sub and request-response) with transport plugins for popular message brokers.

Apache License 2.0

467 stars 78 forks source link

Closed zarusz closed 3 days ago

zarusz commented 1 week ago

There was an issue raised in #131. Doing further investigation I have found:

With EnablePartitionEof set to true, when the partition ended, SMB was committing too advanced a partition index.
The SMB-driven manual commit with the CheckpointAfter(TimeSpan) might not happen after the desired time when there are no protocol events that happen (partition assignment or partition EOF).

Moreover, the Confluent.Kafka library has being upgraded from 2.3.0 to 2.5.2.

sonarcloud[bot] commented 3 days ago