Scott Kidder
|
79f734c100
Initialize slice of consumers for a topic partition using an empty string slice literal
|
5 years ago |
Scott Kidder
|
e52742d7de
PR feedback
|
5 years ago |
Scott Kidder
|
ae8e47f3da
Fix comments
|
5 years ago |
Scott Kidder
|
df5d0c0ba1
Sort the assignment priority queue in descending order using member-id if the assignment counts are identical
|
5 years ago |
Scott Kidder
|
7f26806906
Use priority queue to sort consumer group members by number of partition assignments
|
5 years ago |
Artem Denisov
|
43f1fb8c69
cluster admin from client (#1415)
|
5 years ago |
Dominic Evans
|
9f8650a8fa
fix brokerProducer goroutine leak (#1442)
|
5 years ago |
Symeon Meichanetzoglou
|
49309c8ce1
TRIVIAL: fmt indentation fix
|
5 years ago |
Symeon Meichanetzoglou
|
8c12b175c4
Set the Kafka version in ListAcls method
|
5 years ago |
Varun
|
6996f4c70e
fixed race in consumer group example (#1434)
|
5 years ago |
Diego Alvarez
|
46c83074a0
changelog for 1.23.1
|
5 years ago |
evazca
|
6fce0f9c8d
fix bug deleteRecord (#1425)
|
5 years ago |
Vlad Gorodetsky
|
d1948414ad
Merge pull request #1428 from mkaminski1988/master
|
5 years ago |
Mike Kaminski
|
6c040e14fe
Issue #1423 - Handle SASL/OAUTHBEARER broker challenge
|
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 |
Vlad Gorodetsky
|
dde3ddda8b
Merge pull request #1419 from Shopify/changelog-1.23
|
5 years ago |
Vlad Gorodetsky
|
b3b39c5bfd
Add changelog for sarama 1.23.0
|
5 years ago |
Vlad Gorodetsky
|
d9dbc20e79
Merge pull request #1374 from dwi-di/consumer-group-offsets-nil
|
5 years ago |
Vlad Gorodetsky
|
2e586779ca
Merge pull request #1418 from Shopify/kafka230
|
5 years ago |
Vlad Gorodetsky
|
1d96adfc42
Add support for kafka 2.3.0
|
5 years ago |
Vlad Gorodetsky
|
09dc31db2d
Merge pull request #1417 from birdayz/admin_delete_consumer_group
|
5 years ago |
Johannes Brüderl
|
ce981d1544
admin: add DeleteConsumerGroup
|
5 years ago |
andrewhao888
|
c50148e0a8
fetch size overflow (#1376)
|
5 years ago |
Scott Kidder
|
01915cf82e
Add sticky partition assignor
|
5 years ago |
Prune Sebastien THOMAS
|
c82066c158
added SASLVersion in config (#1410)
|
5 years ago |
Vlad Gorodetsky
|
93e48db375
Merge pull request #1406 from worms/master
|
5 years ago |
Vlad Gorodetsky
|
4154a59639
Merge pull request #1404 from skidder/sk-fix-shutdown-for-consumer-group-example
|
5 years ago |
Ian Wormsbecker
|
20c7a58bc6
Add consume ability to sasl_scram_client example
|
5 years ago |
Scott Kidder
|
5ad743b184
Use log.Panicf to provide more context to panic errors
|
5 years ago |
Scott Kidder
|
aea5ab960e
Fix shutdown and race-condition in consumer-group example
|
5 years ago |