 Sebastien Lavoie
|
a74c07e4d6
Return the response error in heartbeatLoop
|
4 年之前 |
 Diego Alvarez
|
8b72385c90
adds a note about consumer groups Consume method
|
4 年之前 |
 Al DeLucca
|
46f804e149
Address review comments
|
4 年之前 |
|
Al DeLucca
|
bf1b8fb51e
Allow BalanceStrategy to provide custom assignment data
|
4 年之前 |
|
Diego Alvarez
|
33aa349ead
Merge pull request #1581 from matthewloring/deadlock-fix
|
4 年之前 |
 antshbean
|
0cce202975
Merge remote-tracking branch 'shopify_sarama/master'
|
4 年之前 |
 Matt Loring
|
7f8505057a
Fix deadlock in consumer group Close
|
4 年之前 |
|
antshbean
|
fd421dc812
solve call Consumer function agin, will generate more than loopCheckPartitionsNumber Coroutine
|
4 年之前 |
|
antshbean
|
bd430e62d8
fixed ConsumerGroup flooding logs with client/metadata update req #1544
|
4 年之前 |
 Robert Laszczak
|
e56a4a9baa
added comments for handleError
|
5 年之前 |
|
Robert Laszczak
|
93f4001ec3
fixed race conditions and nil panic on calling registerBroker after close
|
5 年之前 |
|
antsbean
|
bdbb7771f7
fixed Add a new partition during the consumer group running，but the cousumer group not rebalance。 #1462
|
5 年之前 |
 Scott Kidder
|
78d3678f40
Make the partition strategy assignment names constants, and compare the active strategy name against the sticky balance strategy name when handling a sync group request to allow for easy extension of the sticky balance strategy
|
5 年之前 |
|
Scott Kidder
|
01915cf82e
Add sticky partition assignor
|
5 年之前 |
 Vlad Gorodetsky
|
9522409b7f
Merge pull request #1231 from thomaslee/tom_fix_coordinator_changes
|
5 年之前 |
 coldWater
|
b4d38af3f3
fixed handle cleanup error
|
5 年之前 |
 Nelz
|
6c354b8b3c
reduce client close bookkeeping
|
5 年之前 |
 Andreas Schneider
|
6c949c05b2
fixed potential deadlock when a heartbeat request fails
|
5 年之前 |
|
Vlad Gorodetsky
|
e6c029ff1a
Revert "Synced error names and descriptions with the kafka's protocol"
|
5 年之前 |
|
Vlad Gorodetsky
|
04e4286cc1
Merge pull request #1218 from nrvnrvn/match-error-codes-and-descriptions
|
5 年之前 |
 Nick Revin
|
a0f0d8fcdf
synced error codes and descriptions with the kafka's protocol
|
6 年之前 |
 Tom Lee
|
4ff43dddea
RefreshCoordinator() will handle closing the coordinator if necessary
|
6 年之前 |
|
Tom Lee
|
bad65e751a
Retry ErrNotCoordinatorForConsumer in ConsumerGroup.newSession
|
6 年之前 |
 Varun
|
8cc8678245
fixed the function call with changed parameter ordering
|
6 年之前 |
|
Varun
|
12fa6736bd
fixed some typo and added some comments
|
6 年之前 |
|
Varun
|
e71aa456c3
fixed a go vet suggestion in consumer group file
|
6 年之前 |
 Dimitrij Denissenko
|
a318f6ee7d
CI test fixes
|
6 年之前 |
|
Dimitrij Denissenko
|
ed8fd54181
Better documentation and examples
|
6 年之前 |
|
Dimitrij Denissenko
|
c80d82cf6c
Simplify code. Run heartbeat for as long as possible
|
6 年之前 |
|
Dimitrij Denissenko
|
7170045d9b
Use context for session cancellation
|
6 年之前 |
