Goka Versions Save

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

v1.0.4

3 years ago
  • add mutex to codex-map in tester to prevent concurrent map access

v1.0.3

3 years ago
  • Add EmitSyncWithHeaders to Emitter (by @adw1n)
  • Prefix sarama logger with [Sarama] (by @adw1n)
  • Bugfix in example (by @FredrikBakken)

v1.0.2

3 years ago

Fixing the processor and view state in the monitoring web-ui.

v1.0.1

3 years ago

Add Commit() to MockConsumerGroupSession and cgSession to be compatible with ConsumerGroupSession interface.

v1.0.0

3 years ago

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.

v0.9.0-beta3

4 years ago

removed race condition in stats tracking fixed panic in View.Get for uninitialzed state call Open on storage after init

v0.9.0-beta2

4 years ago

v0.9.0-beta1

4 years ago

Major changes:

  • Removed sarama-cluster, replaced with sarama's ConsumerGroup
  • remove package kafka, move remaining files to root
  • introduce go mod
  • removed support for librdkafka

See #239 for details

v0.1.4

4 years ago

v0.1.3

4 years ago