Goka is a compact yet powerful distributed stream processing library for Apache Kafka written in Go.
Fixing the processor and view state in the monitoring web-ui.
Add Commit() to MockConsumerGroupSession and cgSession to be compatible with ConsumerGroupSession interface.
With this release we integrate sarama consumer group into goka and remove the sarama-cluster dependency. These changes enable users to use goka with recent sarama versions.
removed race condition in stats tracking fixed panic in View.Get for uninitialzed state call Open on storage after init
Major changes:
See #239 for details