v1.1.0
What's Changed
- Example for defer commit by @frairon in #301
- Improve goka.Context docs by @adw1n in #303
- fixed tests by @frairon in #309
- Initial support for headers in tester by @wwaldner-amtelco in #308
- issue #312 append headers on emit instead of replacing them by @frairon in #313
- #156 processor hot standby by @frairon in #283
- Improve headers implementation by @mrahs in #315
- Bugfix draining consumer message. by @frairon in #319
- Expose headers via the root package by @mrahs in #324
- Remove Prefix from logging, moved logging package to goka #305 by @frairon in #310
- add go report card by @frairon in #326
- storage improvements by @frairon in #328
- Added GetTableKeys to tester by @juandes in #327
- tester.Catchup() added, removed partitions in tester.Topicmanager by @frairon in #333
- hotfix: panic after activating debug logging by @frairon in #336
- partition table: always store offset by @frairon in #337
- Fix TopicManager docstring replication factor by @frairon in #340
- #318 avoid losing an element in leveldb seeker by @mrahs in #320
- Visitor Tool implementation by @frairon in #341
- fixed comments from PR #341, added unit tests for action by @frairon in #345
- topic manager wait by @frairon in #348
- improving processor error handling/shutdown by @frairon in #353
- Expose Processor State With StateReader Interface by @jomaresch in #354
- skip nil-values for partitions where stats timed out by @frairon in #358
- Add setter functions to allow changing
tableSuffix
andloopSuffix
. by @chin8628 in #359 - tester: implement listing topics and partitions + getoffset by @frairon in #360
- Improved failure handling fully remove multierr.Errors system test for testing connection errors bugfix issue 350 View.Get fails on reconnecting view bugfix processor freeze on error (334) by @frairon in #361
- Visitor/Tests imrovement by @frairon in #363
New Contributors
- @wwaldner-amtelco made their first contribution in #308
- @juandes made their first contribution in #327
- @chin8628 made their first contribution in #359
Full Changelog: v1.0.6...v1.1.0