 Tom Lee
|
7d903c1bb8
Add Config.Producer.Retry.BackoffFunc
|
6 years ago |
 Andy PENG
|
f3829d3df4
feat: add Timeout for ClusterAdmin
|
6 years ago |
 Dimitrij Denissenko
|
9f431f4dd8
Add custom offset commit retry config
|
6 years ago |
 Phil Sorber
|
0f655c0014
Add LocalAddr to Config struct and honor in broker.Open().
|
6 years ago |
 Maxim Vladimirskiy
|
e42dc76c4e
Add missing Kafka versions
|
6 years ago |
 Ivan Babrou
|
624d43877c
Validate gzip compression level support early
|
6 years ago |
|
Ivan Babrou
|
1f78d8a7f1
Add support for compression levels, closes #1042
|
6 years ago |
 Behrooz Shafiee
|
a1cfcca530
changed Fetch.default value from 32KB to 1MB
|
6 years ago |
 Evan Huus
|
298679cecd
Merge pull request #933 from wmille/timer_performance
|
7 years ago |
|
Evan Huus
|
38673c0ce0
Add a config option to store only minimal metadata
|
7 years ago |
 Vagrant User
|
9112d76399
Use a ticker instead of a timer to detect timeouts
|
7 years ago |
|
Vagrant User
|
87e4033a66
Optionally use a ticker instead of a timer to detect timeouts
|
7 years ago |
|
Vagrant User
|
7bbb175476
Add an optional fast checker to (*partitionConsumer).responseFeeder
|
7 years ago |
 Max Jonas Werner
|
42e8e51845
closes #854 clear up doc confusion on producer config
|
7 years ago |
|
Evan Huus
|
686609495c
Add a config warning for unusual flushes
|
7 years ago |
 Kostas Christidis
|
d3ebd12522
Fix incorrect "larger than MaxRequestSize" message, closes #836
|
7 years ago |
|
Evan Huus
|
e6df07fb9c
Merge pull request #786 from rtreffer/master
|
8 years ago |
 Rene Treffer
|
dc5a7b89a1
Simplify version check for lz4 and kafka 0.10.0.0.
|
8 years ago |
|
Evan Huus
|
c4cc2603da
Rebase fixes for metrics changes
|
8 years ago |
|
Rene Treffer
|
645b0298c1
Guard against using LZ4 with old kafka protocol versions
|
8 years ago |
 Sebastien Launay
|
3f8bfbafab
Use a local registry for metrics
|
8 years ago |
|
Sebastien Launay
|
3ea3cb2edb
Minor changes
|
8 years ago |
|
Sebastien Launay
|
f8d8342ace
Expose broker metrics with go-metrics
|
8 years ago |
|
Evan Huus
|
88a4afb3d1
Misc minor lint changes
|
8 years ago |
|
Evan Huus
|
90a4cc632e
Fix race in broker version check
|
8 years ago |
|
Evan Huus
|
5e8b6ff817
Support configuring target kafka version
|
8 years ago |
|
Sebastien Launay
|
666bedf384
Moving constant to client.go and making it private
|
8 years ago |
|
Sebastien Launay
|
eb9150647a
Forbid empty ClientID and use 'sarama' as default
|
8 years ago |
 Mariano Gappa
|
bbe99d8b16
occured -> occurred
|
8 years ago |
 Shriram Rajagopalan
|
9d69627aa9
bug fixes
|
8 years ago |
