What's Changed
Epam.Kafka
- Added dependency to
System.Text.Json
v9.0.0. - Added classes to deserialize statistics emitted by librdkafka (see https://github.com/epam/epam-kafka/blob/main/src/Epam.Kafka/Statistics.cs)
- Added metrics based on statistics (see https://github.com/epam/epam-kafka/wiki/Low-level-consumer,-producer,-and-admin-client#metrics)
- Added
DebugContext
enum to be able to set predefined values fordebug
config property usingSetDebugContexts
extension method.
Epam.Kafka.PubSub
- Added
Type
tag to metrics fromEpam.Kafka.PubSub.Status
andEpam.Kafka.PubSub.Health
meters. - Default
max.poll.interval.ms
for subscription consumer calculated based on handler timeouts of all enabled subscriptions within concurrency group.