 Dominic Evans
|
48ba0ca84f
feat: protocol support for V11 fetch w/ rackID
|
%!s(int64=4) %!d(string=hai) anos |
 Diego Alvarez
|
b74b4a28b9
Adds back Consumer.Offsets.CommitInterval to fix API
|
%!s(int64=4) %!d(string=hai) anos |
|
Diego Alvarez
|
052b8500ca
fix error message s/CommitInterval/AutoCommit.Interval
|
%!s(int64=4) %!d(string=hai) anos |
|
Dominic Evans
|
5160d7db71
fix: retry topic request on ControllerNotAvailable
|
%!s(int64=4) %!d(string=hai) anos |
|
Diego Alvarez
|
30e70940f1
Merge pull request #1574 from Shopify/diego_zstd-support-kafka-2_1_0_0
|
%!s(int64=4) %!d(string=hai) anos |
|
Dominic Evans
|
10a6db55e9
Add SASL AuthIdentity to SASL frames (authzid)
|
%!s(int64=5) %!d(string=hai) anos |
|
Diego Alvarez
|
37faed7ffc
enables zstd bumping the right things
|
%!s(int64=4) %!d(string=hai) anos |
 Kjell Tore Fossbakk
|
72a629d7d1
Allow the Consumer to disable auto-commit offsets (#1164)
|
%!s(int64=5) %!d(string=hai) anos |
 Kevin Gillette
|
65e4c5f990
comment typo: ChanneBufferSize -> ChannelBufferSize
|
%!s(int64=5) %!d(string=hai) anos |
 Prune Sebastien THOMAS
|
c82066c158
added SASLVersion in config (#1410)
|
%!s(int64=5) %!d(string=hai) anos |
 Ruben Vargas
|
3ec45e581a
Add kerberos support
|
%!s(int64=5) %!d(string=hai) anos |
 Sebastien Launay
|
fe1b1849d0
Support timeout when fetching metadata
|
%!s(int64=6) %!d(string=hai) anos |
 Vlad Gorodetsky
|
2a49b70a5c
Merge pull request #1349 from mrsinham/sasl_client_datarace
|
%!s(int64=5) %!d(string=hai) anos |
 Julien LEFEVRE
|
5722d69b8e
[sasl] use a SCRAM client for each connection
|
%!s(int64=5) %!d(string=hai) anos |
|
Vlad Gorodetsky
|
957d261728
Merge pull request #1326 from bakaoh/proxy
|
%!s(int64=5) %!d(string=hai) anos |
|
Vlad Gorodetsky
|
da02f5b7f6
Merge pull request #1337 from tormoder/staticcheck-base-pkg
|
%!s(int64=5) %!d(string=hai) anos |
 Tormod Erevik Lea
|
c8f961f633
Address a few staticcheck suggestions
|
%!s(int64=5) %!d(string=hai) anos |
 bakaoh
|
fb6f6f5065
Add proxy config
|
%!s(int64=5) %!d(string=hai) anos |
 FrancoisPoinsot
|
d6fc544fdf
config validation + test
|
%!s(int64=5) %!d(string=hai) anos |
|
FrancoisPoinsot
|
559a3ceebb
not working, handle only single message transaction
|
%!s(int64=5) %!d(string=hai) anos |
 Iyed Bennour
|
55578535cf
Add SASL SCRAM-SHA-512 and SCRAM-SHA-256 mechanismes
|
%!s(int64=5) %!d(string=hai) anos |
 Varun
|
6a7bac87a0
Merge pull request #1160 from thomaslee/tom_backoff_func
|
%!s(int64=5) %!d(string=hai) anos |
|
Vlad Gorodetsky
|
e6c029ff1a
Revert "Synced error names and descriptions with the kafka's protocol"
|
%!s(int64=5) %!d(string=hai) anos |
|
Vlad Gorodetsky
|
04e4286cc1
Merge pull request #1218 from nrvnrvn/match-error-codes-and-descriptions
|
%!s(int64=5) %!d(string=hai) anos |
 Nick Revin
|
a0f0d8fcdf
synced error codes and descriptions with the kafka's protocol
|
%!s(int64=6) %!d(string=hai) anos |
 Mike Kaminski
|
d47ce2db92
Move extensions from configuration to access token struct
|
%!s(int64=5) %!d(string=hai) anos |
|
Mike Kaminski
|
741ad00c46
Add support for extensions
|
%!s(int64=5) %!d(string=hai) anos |
|
Mike Kaminski
|
28b9633c7c
Rewrite tests using mock broker
|
%!s(int64=5) %!d(string=hai) anos |
|
Mike Kaminski
|
6ea761527c
Implement SASL/OAUTHBEARER support
|
%!s(int64=6) %!d(string=hai) anos |
|
Mike Kaminski
|
e2a956cef6
Implement SASL/OAUTHBEARER support
|
%!s(int64=6) %!d(string=hai) anos |
