github.com/lovoo/goka

Full Changelog

Implemented enhancements:

• Add blocking recovered method #80
• Emit messages with headers #77

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)

Full Changelog

Full Changelog

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

Full Changelog

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)

Full Changelog

Fixed bugs:

• Using a tester with an emitter doesn't seem to be working #188

Merged pull requests:

• feature 195: Add a rebalance callback to the processor. #196 (gmather)

Full Changelog

Implemented enhancements:

• Proposal: log progress of recovery #182
• start logging while recovering #183 (TheL1ne)

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)

Full Changelog

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)

Full Changelog

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