Commit History

Author SHA1 Message Date
  Diego Alvarez 33aa349ead Merge pull request #1581 from matthewloring/deadlock-fix 4 years ago
  antshbean 0cce202975 Merge remote-tracking branch 'shopify_sarama/master' 4 years ago
  Matt Loring 7f8505057a Fix deadlock in consumer group Close 4 years ago
  antshbean fd421dc812 solve call Consumer function agin, will generate more than loopCheckPartitionsNumber Coroutine 4 years ago
  antshbean bd430e62d8 fixed ConsumerGroup flooding logs with client/metadata update req #1544 4 years ago
  Robert Laszczak e56a4a9baa added comments for handleError 5 years ago
  Robert Laszczak 93f4001ec3 fixed race conditions and nil panic on calling registerBroker after close 5 years ago
  antsbean bdbb7771f7 fixed Add a new partition during the consumer group running,but the cousumer group not rebalance。 #1462 5 years ago
  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 years ago
  Scott Kidder 01915cf82e Add sticky partition assignor 5 years ago
  Vlad Gorodetsky 9522409b7f Merge pull request #1231 from thomaslee/tom_fix_coordinator_changes 5 years ago
  coldWater b4d38af3f3 fixed handle cleanup error 5 years ago
  Nelz 6c354b8b3c reduce client close bookkeeping 5 years ago
  Andreas Schneider 6c949c05b2 fixed potential deadlock when a heartbeat request fails 5 years ago
  Vlad Gorodetsky e6c029ff1a Revert "Synced error names and descriptions with the kafka's protocol" 5 years ago
  Vlad Gorodetsky 04e4286cc1 Merge pull request #1218 from nrvnrvn/match-error-codes-and-descriptions 5 years ago
  Nick Revin a0f0d8fcdf synced error codes and descriptions with the kafka's protocol 6 years ago
  Tom Lee 4ff43dddea RefreshCoordinator() will handle closing the coordinator if necessary 6 years ago
  Tom Lee bad65e751a Retry ErrNotCoordinatorForConsumer in ConsumerGroup.newSession 6 years ago
  Varun 8cc8678245 fixed the function call with changed parameter ordering 6 years ago
  Varun 12fa6736bd fixed some typo and added some comments 6 years ago
  Varun e71aa456c3 fixed a go vet suggestion in consumer group file 6 years ago
  Dimitrij Denissenko a318f6ee7d CI test fixes 6 years ago
  Dimitrij Denissenko ed8fd54181 Better documentation and examples 6 years ago
  Dimitrij Denissenko c80d82cf6c Simplify code. Run heartbeat for as long as possible 6 years ago
  Dimitrij Denissenko 7170045d9b Use context for session cancellation 6 years ago
  Dimitrij Denissenko fde71cc31f Fix race 6 years ago
  Dimitrij Denissenko dfeba0fb8f Better documentation, extend test timeout 6 years ago
  Dimitrij Denissenko 6fd7e304e7 Adapt for the latest offset manager implementation 6 years ago
  Dimitrij Denissenko 113ce2c044 Implement a higher-level consumer group 6 years ago