Skip to content

v2.3.140

Compare
Choose a tag to compare
@IharYakimush IharYakimush released this 16 Jul 09:33
· 78 commits to main since this release
a15a4eb

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.