search

zalando / nakadi

A distributed event bus that implements a RESTful API abstraction on top of Kafka-like queues
https://nakadi.io
MIT License
952 stars 292 forks source link

pool kafka consumers for timelag checker, only for test #1506

Closed adyach closed 1 year ago

adyach commented 1 year ago

at the moment time lag service generates hundreds of consumers to calculate lag, because Kafka consumer is created per partition. the change brings pool of consumers which should avoid constant generation of new consumers.

adyach commented 1 year ago

👍

a1exsh commented 1 year ago

:+1: