bugfix stuck fetchstats on slow views/processors

lovoo / goka

Goka is a compact yet powerful distributed stream processing library for Apache Kafka written in Go.

BSD 3-Clause "New" or "Revised" License

2.35k stars 175 forks source link

bugfix stuck fetchstats on slow views/processors #439

Closed frairon closed 10 months ago

frairon commented 11 months ago

This PR removes the channel-based handling of setting/getting stats from partition processors and partition tables. Due to a bug, the channel based solution could get stuck on high-traffic processors/views and never return any stats anymore.