Skip to content

Tags: elodina/go_kafka_client

Tags

v0.4.1.0

Toggle v0.4.1.0's commit message
Merge pull request #171 from xiocode/master

fix bug. make sure all data has consumed in successChan

v0.4.0.0

Toggle v0.4.0.0's commit message
Merge pull request #169 from pfischermx/master

Allow consumer configs to set the numWorkers and use full set of byte slices to check the partition number (for fixedpartiioner)

v0.3.5.3

Toggle v0.3.5.3's commit message
Merge pull request #169 from pfischermx/master

Allow consumer configs to set the numWorkers and use full set of byte slices to check the partition number (for fixedpartiioner)

v0.3.5.2

Toggle v0.3.5.2's commit message
Merge pull request #142 from stealthly/workers-gouroutines

Attempt to reduce amount of worker goroutines.

v0.3.5.1

Toggle v0.3.5.1's commit message
Merge pull request #143 from CrowdStrike/master

Various fixes to make re-balancing and partition ownership more stable.

v0.3.5.0

Toggle v0.3.5.0's commit message
Merge pull request #136 from spenczar/fix_workermanager_memory_leak

Allocate a new taskBatch for each batch of tasks in the WorkerManager

v0.3.0.0

Toggle v0.3.0.0's commit message
Merge pull request #63 from stealthly/roundrobin-fix

Roundrobin fix