You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
This commit was created on GitHub.com and signed with GitHub’s verified signature.
What's Changed
Epam.Kafka
The default implementation of IKafkaFactory.GetOrCreateClient now uses a producer configuration named shared, so its behavior can be customized.
Consumers, producers, and client created by the default IKafkaFactory implementation can now be casted to IObservable<Error> to receive notifications from the error handler and to IObservable<string> to receive statistics.
Epam.Kafka.HealthChecks
Added a new package containing the WithHealthCheck extension method for registering a cluster health check.
Epam.Kafka.PubSub
Fixed topic partition pausing and resuming in subscription background service.
Added commit offsets to Kafka when assigning a partition if external state storage is used and the parameters allow it.
[Breaking Change] Background subscription service no longer use auto.offset.reset=earliest, isolation.level=read_commited, partition.assignment.strategy=CooperativeSticky as default values in the consumer config.
Added description to metrics.
Epam.Kafka.PubSub.EntityFramework(Core/6)
Fixed DbContextPublicationHandler not taking batch size into account when selecting queued objects from the database.