 Vlad Gorodetsky
|
d9dbc20e79
Merge pull request #1374 from dwi-di/consumer-group-offsets-nil
|
%!s(int64=5) %!d(string=hai) anos |
 Johannes Brüderl
|
ce981d1544
admin: add DeleteConsumerGroup
|
%!s(int64=5) %!d(string=hai) anos |
 Dirk Wilden
|
86644261a2
support ListConsumerGroupOffsets without topicPartition
|
%!s(int64=5) %!d(string=hai) anos |
|
Vlad Gorodetsky
|
a4a1b88c6d
Merge pull request #1318 from drsoares/1311_offline_replicas
|
%!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 |
 drsoares
|
36113c9237
Merge branch 'master' of github.com:Shopify/sarama into 1311_offline_replicas
|
%!s(int64=5) %!d(string=hai) anos |
 Tormod Erevik Lea
|
c8f961f633
Address a few staticcheck suggestions
|
%!s(int64=5) %!d(string=hai) anos |
|
Tormod Erevik Lea
|
a1e43c6a86
Adjust ClusterAdmin godoc comments
|
%!s(int64=5) %!d(string=hai) anos |
|
drsoares
|
e3ecf7b088
added offline replicas operation to client for kafka version >= 1.x
|
%!s(int64=5) %!d(string=hai) anos |
|
Vlad Gorodetsky
|
0cfd4e6fdb
Merge pull request #1154 from dnwe/topic-response-errors
|
%!s(int64=5) %!d(string=hai) anos |
 Dominic Evans
|
ec2cbc3814
Satisfy the error interface in create responses
|
%!s(int64=6) %!d(string=hai) anos |
|
Dominic Evans
|
7289df5416
admin: include ReplicaAssignment in ListTopics()
|
%!s(int64=5) %!d(string=hai) anos |
|
Johannes Brüderl
|
3645a3453d
admin: Add some missing admin methods
|
%!s(int64=6) %!d(string=hai) anos |
|
Dominic Evans
|
0171e3dafb
Add ReplicationFactor to ListTopics response
|
%!s(int64=6) %!d(string=hai) anos |
|
Dominic Evans
|
014bdc85aa
Add missing broker Open() call
|
%!s(int64=6) %!d(string=hai) anos |
|
Dominic Evans
|
dae6d49d70
Add ListTopics func to ClusterAdmin interface
|
%!s(int64=6) %!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 |
 Nick Revin
|
a0f0d8fcdf
synced error codes and descriptions with the kafka's protocol
|
%!s(int64=6) %!d(string=hai) anos |
 Andy PENG
|
f3829d3df4
feat: add Timeout for ClusterAdmin
|
%!s(int64=6) %!d(string=hai) anos |
 chandra deepak kasiraju
|
320229591a
support of admin operations in sarama
|
%!s(int64=6) %!d(string=hai) anos |
