Implemented enhancements:
- Migration guide #249
- View: expose view and connection state #248
- PartitionTable backoff on errors #247
Closed issues:
- Examples
simplestandclickspanic with "non-positive interval for NewTicker" #258 - panic: non-positive interval for NewTicker #255
Merged pull requests:
v0.9.0-beta3 (2020-04-09)
Implemented enhancements:
Closed issues:
- cannot run multiple consumers in the same group #204
Merged pull requests:
- stats-tracking improved #245 (frairon)
- return trackOutput if stats are nil #244 (R053NR07)
- added lots of godoc, fixed many linter errors, added Open call when c… #243 (frairon)
- Open Storage in PartitionTable when performing Setup #242 (frairon)
- updated readme for configuration, added changelog #240 (frairon)
v0.9.0-beta2 (2020-03-20)
v0.9.0-beta1 (2020-03-19)
Implemented enhancements:
- Update Kafka consumer group library #187
Closed issues:
- Does goka support kafka 2.2.1 #233
- Go get error #213
- Samara-cluster dependency seems to have an issue #211
- Dropping message while rebalancing #207
- Lost lots of messages due to async produce #192
- processor gets stuck in shutdown after error #176
- Proposal: support static partitioning #163
- Proposal: add tracing support #160
v0.1.4 (2020-01-22)
Closed issues:
- How can I debug a "negative WaitGroup counter" in a processor? #198
- View is empty, if log forced the keys/values come back #197
- Question: Rebalancing callback? #195
Merged pull requests:
- Remove unused channels #215 (heltonmarx)
- Adding header on message #214 (toninho09)
- repeating messages from input stream after recover #208 (WideLee)
- revert in memory locks #203 (TheL1ne)
- protect storage writes #200 (TheL1ne)
- Tester tolerate unconsumed queues #199 (TheL1ne)
v0.1.3 (2019-06-28)
Fixed bugs:
- Using a tester with an emitter doesn't seem to be working #188
Merged pull requests:
v0.1.2 (2019-06-18)
Implemented enhancements:
Closed issues:
- Lookup not working with multi-partitioned topics #186
- How can I config multiple consumer for 1 Topic #184
- multi_iterator looks broken #178
- Rebalancing error #172
Merged pull requests:
- bugfix #188: tester for emitter #190 (frairon)
- storage: merge iterator implementation #185 (SamiHiltunen)
- 178 multi_iterator looks broken #180 (frairon)
- Groupgraphhook option #175 (frairon)
- Tester deadlock workaround #173 (frairon)
v0.1.1 (2019-01-29)
Implemented enhancements:
- Improve tester implementation #145
Fixed bugs:
- Updates broke go get #152
- zookeeper address with trailing "/" fails #126
- Running processor without prior topics fails #125
Closed issues:
- How to improve performance? #164
- Question: Scanning a Joined Topic #159
- Removal of db7/kazoo-go and subsequent repo deletion breaks previous builds #154
- error on recovering view does not restart #141
- review errors to fail on #140
- Processor failures: expected rebalance OK but received rebalance error #131
- unable to get goka running with the following error. #119
Merged pull requests:
- fixed bindata for web templates #170 (frairon)
- add logo #169 (frairon)
- add Context() method to goka.Context #166 (db7)
- terminate tester when one of the queue consumers died #165 (frairon)
- fix integration tests #162 (frairon)
- fixes wrong commit for queue tracker #158 (frairon)
- remove proto and go-metrics direct dependencies #157 (db7)
- add ensure config to check topic #155 (db7)
- clean trailing slashes in zookeeper chroot #153 (db7)
- update mocks to latest sarama #150 (db7)
- ensure topic exists as more flexible topic creation option #149 (db7)
- fix processor tests #148 (db7)
- cleanup processor rebalance #147 (db7)
- improve tester implementation #146 (frairon)
- use default kazoo-go #144 (db7)
v0.1.0 (2018-08-03)
Implemented enhancements:
- Proposal: replace Start() and Stop() with Run(context.Context) #120
- Support badgeDB #55
- Question: Accessing a goka.View concurrently? #53
- Remove snapshot from storage #30
Fixed bugs:
- Prevent offset commit in case of panic #129
- Failing view was not added #113
- Don't check copartitioning for lookup topics #109
- Getting error from Emitter #103
- Initial offset handling #97
- Allow passing custom hasher for graph dependencies #84
- monitoring panics on stateless processor #62
- a view never becomes ready on an empty topic #35
- access group table without goka.Persist(...) #18
Closed issues:
- View should have option to fallback to local-only mode #102
- Question: Same topic as input and join #95
- Proposal: Add joins with watermarks #94
- Goka is production ready? #93
- Issues getting value from view #83
- HowToX : Is it possible to iterate on View with a subset ? #82
- Proposal: Implement message keys as bytes instead of strings #81
- Provide examples of lookups #79
- goka does not work latest bsm/sarama-cluster #68
- Reduce metrics overhead #57
- panic: runtime error: invalid memory address or nil pointer dereference #49
- Consume nil messages should be an option #41
- Organizing/modeling Views #32
- print error on failure right away #10
- panic on error. like a double-close #2
Merged pull requests:
- Fix passing opts to LevelDB in BuilderWithOptions #139 (mhaitjema)
- Expose partition and offset on the callback context #136 (burdiyan)
- typo fix in tester code #135 (frairon)
- bugfix tester, improve emitter and mock #134 (frairon)
- make iteration order deterministic #133 (db7)
- if context panics, finish context with error #130 (db7)
- Feature/run context #127 (db7)
- fixing multi-iterator test cases #122 (db7)
- fix only first two iters checked #121 (j0hnsmith)
- Feature/move kafkamock #118 (db7)
- trying with go 1.9 #117 (db7)
- Update mocks #116 (db7)
- Adding TopicManagerBuilderWithConfig to allow custom Sarama config #115 (andrewmunro)
- mostly complying with gometalinter #114 (db7)
- Feature/errgroup #111 (db7)
- Allow non-copartitioned lookup tables #110 (db7)
- guarantee partition goroutines finished before stop() returns #107 (db7)
- fix embarrasing dead unlock #106 (db7)
- add restartable view support #105 (db7)
- bugfix #103: propagate error in Emitter.EmitSync #104 (frairon)
- consume streams from newest #100 (db7)
- Bugfix/fix stalled partitions #98 (db7)
- added redis storage option #96 (heltonmarx)
- Make builders builders #92 (db7)
- forward options to lookup views #91 (db7)
- finished monitoring-example readme #90 (frairon)
- add testcase for regression testing of already fixed issue 18. Resolv… #89 (frairon)
- messaging example #88 (db7)
- added support for Seek on iterator and IteratorWithRange on storage #85 (jbpin)
- Bugfix/stalled partition recovery #78 (frairon)
- initial time in stats #76 (db7)
- stop partition while marking recovered #75 (db7)
- Confluent kafka go #74 (db7)
- use default channel size from sarama in kafka package #73 (db7)
- Join web views #71 (frairon)
- support for new notifications in sarama-cluster #70 (SamiHiltunen)
- speed up stats collection #69 (db7)
- use AsyncClose in simple consumer #67 (db7)
- stop-partition bugfix #66 (frairon)
- return stats immediately when partition marking storage recovered #65 (db7)
- forward partition consumer errors #64 (SamiHiltunen)
- web/monitoring: removed tableName in template which fails on statelesss processors and was unused. Fixes #62 #63 (frairon)
- reset stats after load finished #61 (db7)
- web-components regenerated, refresh-interval reduced #60 (frairon)
- Webinterface #59 (frairon)
- Lightweight partition stats #58 (db7)
- change table suffix to -table #54 (db7)
- removing codec from storage #52 (db7)
- deletes partition consumer from map even on errors #51 (db7)
- nil pointer panic when closing producer #50 (db7)
- disable partition consumption delay once done #47 (db7)
- timestamp passing in simple consumer #46 (SamiHiltunen)
- nil handling options #45 (db7)
- methods for checking recovery status #44 (SamiHiltunen)
- properly stop goroutines on Close() #43 (db7)
- Evict method for Views #42 (SamiHiltunen)
- return after deleting in DefaultUpdate #40 (SamiHiltunen)
- Ignore nil message #39 (db7)
- deletion semantics #38 (SamiHiltunen)
- passing client id to builders #37 (db7)
- let producerBuilder set partitioner in sarama.Config #36 (db7)
- simplify context and move set offset to context commit #34 (db7)
- view iterator #33 (SamiHiltunen)
- snapshot and batching removal, recovery transactions #31 (SamiHiltunen)
- iterator offset key skipping #29 (SamiHiltunen)
- Expose message timestamp and metrics improvements #28 (SamiHiltunen)
- option to provide metrics registry #27 (SamiHiltunen)
- Bugfix/shutdown on errors #26 (frairon)
- logger interface and options #25 (SamiHiltunen)
- examples #24 (frairon)
- Readme update #23 (db7)
- Dependency fixes #22 (SamiHiltunen)
- Readme #19 (frairon)
- isolate concurrent gets in snapshot #17 (db7)
- Fail in partition view #16 (db7)
- expect emit in correct order. Added expectall-function #15 (frairon)
- inputs for multiple topics #14 (frairon)
- renaming producer to emitter #13 (db7)
- String types for Table, Stream and Group #12 (db7)
- Sync recover #11 (db7)
- adding lookup tables #9 (db7)
* This Changelog was automatically generated by github_changelog_generator