Goka Versions Save

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

v1.1.1

2 years ago

What's Changed

New Contributors

Full Changelog: https://github.com/lovoo/goka/compare/v1.1.0...v1.1.1

v1.1.0

2 years ago

What's Changed

New Contributors

Full Changelog: https://github.com/lovoo/goka/compare/v1.0.6...v1.1.0

v1.1.0-beta.4

2 years ago

Small fix that allows modifying loop/table suffixes when generating the group graph.

v1.1.0-beta.3

2 years ago

Bugfix: ignore stats for partitions where fetch-stats timed out (was set to nil before)

v1.1.0-beta.2

2 years ago

v1.1.0-beta.1

2 years ago
  • Improved error handling and processor shutdown on failure. Solves issue #330 , #334
  • Use hashicorp/go-multierror instead of multierr.Errors.

v1.1.0-beta.0

2 years ago

Pre-release of breaking changes regarding header handling and logging.

v1.0.6

3 years ago

Improvements

  • add sending headers option to context by @AlecY
  • topic manager check topic configuration with configurable behavior on mismatch

v1.0.5

3 years ago

Bugfixes

  • leveldb ressource leak by @mrahs
  • fix race conditions
  • avoid panic by removing direct storage access in view

Improvements

  • unexport finish method of promise
  • print consumer errors only once
  • add getter for Graph-Group in context
  • tolerate different sets of topics

Random

  • remove logo for ASF tradmark violations

v1.0.4

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