 Edoardo Comar
|
4e5d477980
Idempotent Producer - batch retry logic
|
преди 5 години |
 Mickael Maison
|
8e2b04b363
Added support for Idempotent Producer
|
преди 6 години |
 Dimitrij Denissenko
|
c80d82cf6c
Simplify code. Run heartbeat for as long as possible
|
преди 5 години |
|
Dimitrij Denissenko
|
113ce2c044
Implement a higher-level consumer group
|
преди 6 години |
 Andy PENG
|
f3829d3df4
feat: add Timeout for ClusterAdmin
|
преди 6 години |
|
Dimitrij Denissenko
|
9f431f4dd8
Add custom offset commit retry config
|
преди 6 години |
 Phil Sorber
|
0f655c0014
Add LocalAddr to Config struct and honor in broker.Open().
|
преди 6 години |
 Maxim Vladimirskiy
|
e42dc76c4e
Add missing Kafka versions
|
преди 6 години |
 Ivan Babrou
|
624d43877c
Validate gzip compression level support early
|
преди 6 години |
|
Ivan Babrou
|
1f78d8a7f1
Add support for compression levels, closes #1042
|
преди 6 години |
 Behrooz Shafiee
|
a1cfcca530
changed Fetch.default value from 32KB to 1MB
|
преди 6 години |
 Evan Huus
|
298679cecd
Merge pull request #933 from wmille/timer_performance
|
преди 6 години |
|
Evan Huus
|
38673c0ce0
Add a config option to store only minimal metadata
|
преди 6 години |
 Vagrant User
|
9112d76399
Use a ticker instead of a timer to detect timeouts
|
преди 6 години |
|
Vagrant User
|
87e4033a66
Optionally use a ticker instead of a timer to detect timeouts
|
преди 6 години |
|
Vagrant User
|
7bbb175476
Add an optional fast checker to (*partitionConsumer).responseFeeder
|
преди 7 години |
 Max Jonas Werner
|
42e8e51845
closes #854 clear up doc confusion on producer config
|
преди 7 години |
|
Evan Huus
|
686609495c
Add a config warning for unusual flushes
|
преди 7 години |
 Kostas Christidis
|
d3ebd12522
Fix incorrect "larger than MaxRequestSize" message, closes #836
|
преди 7 години |
|
Evan Huus
|
e6df07fb9c
Merge pull request #786 from rtreffer/master
|
преди 7 години |
 Rene Treffer
|
dc5a7b89a1
Simplify version check for lz4 and kafka 0.10.0.0.
|
преди 7 години |
|
Evan Huus
|
c4cc2603da
Rebase fixes for metrics changes
|
преди 7 години |
|
Rene Treffer
|
645b0298c1
Guard against using LZ4 with old kafka protocol versions
|
преди 7 години |
 Sebastien Launay
|
3f8bfbafab
Use a local registry for metrics
|
преди 7 години |
|
Sebastien Launay
|
3ea3cb2edb
Minor changes
|
преди 8 години |
|
Sebastien Launay
|
f8d8342ace
Expose broker metrics with go-metrics
|
преди 8 години |
|
Evan Huus
|
88a4afb3d1
Misc minor lint changes
|
преди 8 години |
|
Evan Huus
|
90a4cc632e
Fix race in broker version check
|
преди 8 години |
|
Evan Huus
|
5e8b6ff817
Support configuring target kafka version
|
преди 8 години |
|
Sebastien Launay
|
666bedf384
Moving constant to client.go and making it private
|
преди 8 години |
