druid/extensions-core/kafka-indexing-service
AmatyaAvadhanula fb23e38aa7
Fix messageGap emission (#13346)
* Fix messageGap emission

* Do not emit messageGap after stopping reading events

* Refactoring

* Fix tests
2022-11-10 17:50:19 +05:30
..
2022-11-10 17:50:19 +05:30
2022-10-10 20:34:38 +08:00