J. Brandt Buckley
|
98f7d9f4c1
Fix typo in ErrReplicaNotAvailable
|
9 лет назад |
Evan Huus
|
482c471fbf
Merge pull request #744 from slaunay/enhancement/custom-metric-registry
|
9 лет назад |
Sebastien Launay
|
3f8bfbafab
Use a local registry for metrics
|
9 лет назад |
Evan Huus
|
e03d23b5a4
Merge pull request #701 from slaunay/enhancement/broker-metrics
|
9 лет назад |
Evan Huus
|
bd61cae2be
Prep for v1.10.1
|
9 лет назад |
Evan Huus
|
e0c3cfa5ce
Merge pull request #735 from Shopify/consumer/compressed-relative-offsets
|
9 лет назад |
Evan Huus
|
16da292b17
Consumer: handle compressed relative offsets
|
9 лет назад |
Evan Huus
|
94895118af
Merge pull request #734 from ChannelMeter/fix/timer-reset-logic
|
9 лет назад |
Nimi Wariboko Jr
|
f0f5b0ae1a
Consumer: fix deadlock - if the timer had already expired, don't try to read the channel again.
|
9 лет назад |
Evan Huus
|
1639c3e2fd
Merge pull request #733 from ChannelMeter/fix/timer-reset-race
|
9 лет назад |
Nimi Wariboko Jr
|
779ef6ae4e
Checking Reset()'s active return value is racy according to Golang docs. Docs advice to call Stop inorder to reuse a timer. Should fix #732.
|
9 лет назад |
Evan Huus
|
4f47ee4924
Merge pull request #730 from mistsys/master
|
9 лет назад |
Nicolas S. Dade
|
906ed729ae
fix erronous errTimedOut ("abandoned subscription...because consuming was taking too long")
|
9 лет назад |
Sebastien Launay
|
3ea3cb2edb
Minor changes
|
9 лет назад |
Evan Huus
|
f4a626377c
client: don't abort creation on auth failure
|
9 лет назад |
Julian Nadeau
|
a0554bb10f
[dev.yml] automated update by dev-map
|
9 лет назад |
Evan Huus
|
8eb9752774
Fix documentation for HashPartitioner
|
9 лет назад |
Evan Huus
|
9bb4a68d57
Prep for v1.10
|
9 лет назад |
Evan Huus
|
e8020bffa1
Merge pull request #713 from Shopify/match-upstream-offset-manager
|
9 лет назад |
Evan Huus
|
ccab789d44
OffsetManager: match upstream mark/next behaviour
|
9 лет назад |
Evan Huus
|
fde67d3335
Merge pull request #712 from Shopify/reduce-timer-allocations
|
9 лет назад |
Evan Huus
|
9d159b4cf0
Consumer: reduce timer allocations
|
9 лет назад |
Evan Huus
|
146ec3d7f7
Merge pull request #710 from Shopify/fix-706
|
9 лет назад |
Evan Huus
|
0d77a1d392
Offset Manager: report unknown topic errors
|
9 лет назад |
Evan Huus
|
366453c3e3
Update changelog for #709
|
9 лет назад |
Evan Huus
|
4124e963cb
Merge pull request #709 from ttapjinda/fix-hash-partitioner-negative-result
|
9 лет назад |
Tayida Tapjinda
|
0b1355f294
Fix HashPartitioner's negative result by applying modulo before checking negative
|
9 лет назад |
Sebastien Launay
|
b7f401f9d4
Fix race condition with graceful shutdown of MockBroker
|
9 лет назад |
Sebastien Launay
|
f9642ad29d
Fix unreliable sleep with proper MockBroker close
|
9 лет назад |
Sebastien Launay
|
7340cab460
Fix race condition on MockBroker.history
|
9 лет назад |