 Evan Huus
|
bd61cae2be
Prep for v1.10.1
|
%!s(int64=9) %!d(string=hai) anos |
|
Evan Huus
|
e0c3cfa5ce
Merge pull request #735 from Shopify/consumer/compressed-relative-offsets
|
%!s(int64=9) %!d(string=hai) anos |
|
Evan Huus
|
16da292b17
Consumer: handle compressed relative offsets
|
%!s(int64=9) %!d(string=hai) anos |
|
Evan Huus
|
94895118af
Merge pull request #734 from ChannelMeter/fix/timer-reset-logic
|
%!s(int64=9) %!d(string=hai) anos |
 Nimi Wariboko Jr
|
f0f5b0ae1a
Consumer: fix deadlock - if the timer had already expired, don't try to read the channel again.
|
%!s(int64=9) %!d(string=hai) anos |
|
Evan Huus
|
1639c3e2fd
Merge pull request #733 from ChannelMeter/fix/timer-reset-race
|
%!s(int64=9) %!d(string=hai) anos |
|
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.
|
%!s(int64=9) %!d(string=hai) anos |
|
Evan Huus
|
4f47ee4924
Merge pull request #730 from mistsys/master
|
%!s(int64=9) %!d(string=hai) anos |
 Nicolas S. Dade
|
906ed729ae
fix erronous errTimedOut ("abandoned subscription...because consuming was taking too long")
|
%!s(int64=9) %!d(string=hai) anos |
|
Evan Huus
|
f4a626377c
client: don't abort creation on auth failure
|
%!s(int64=9) %!d(string=hai) anos |
 Julian Nadeau
|
a0554bb10f
[dev.yml] automated update by dev-map
|
%!s(int64=9) %!d(string=hai) anos |
|
Evan Huus
|
8eb9752774
Fix documentation for HashPartitioner
|
%!s(int64=9) %!d(string=hai) anos |
|
Evan Huus
|
9bb4a68d57
Prep for v1.10
|
%!s(int64=9) %!d(string=hai) anos |
|
Evan Huus
|
e8020bffa1
Merge pull request #713 from Shopify/match-upstream-offset-manager
|
%!s(int64=10) %!d(string=hai) anos |
|
Evan Huus
|
ccab789d44
OffsetManager: match upstream mark/next behaviour
|
%!s(int64=10) %!d(string=hai) anos |
|
Evan Huus
|
fde67d3335
Merge pull request #712 from Shopify/reduce-timer-allocations
|
%!s(int64=10) %!d(string=hai) anos |
|
Evan Huus
|
9d159b4cf0
Consumer: reduce timer allocations
|
%!s(int64=10) %!d(string=hai) anos |
|
Evan Huus
|
146ec3d7f7
Merge pull request #710 from Shopify/fix-706
|
%!s(int64=10) %!d(string=hai) anos |
|
Evan Huus
|
0d77a1d392
Offset Manager: report unknown topic errors
|
%!s(int64=10) %!d(string=hai) anos |
|
Evan Huus
|
366453c3e3
Update changelog for #709
|
%!s(int64=10) %!d(string=hai) anos |
|
Evan Huus
|
4124e963cb
Merge pull request #709 from ttapjinda/fix-hash-partitioner-negative-result
|
%!s(int64=10) %!d(string=hai) anos |
 Tayida Tapjinda
|
0b1355f294
Fix HashPartitioner's negative result by applying modulo before checking negative
|
%!s(int64=10) %!d(string=hai) anos |
|
Evan Huus
|
7fbb591e57
Update changelog with changes in master
|
%!s(int64=10) %!d(string=hai) anos |
|
Evan Huus
|
daa549b755
Merge pull request #699 from fanhattan/non_zero_producer_message_timestamp
|
%!s(int64=10) %!d(string=hai) anos |
 yingnanliu
|
16a22e0995
Don't propagate zero timestamp to ProducerMessage
|
%!s(int64=10) %!d(string=hai) anos |
|
Evan Huus
|
7f0fe2ddaf
Don't try and parse a timestamp of -1
|
%!s(int64=10) %!d(string=hai) anos |
|
Evan Huus
|
d234b743b3
Merge pull request #695 from lindenlab/produce-timestamp-v0.10
|
%!s(int64=10) %!d(string=hai) anos |
 Don Kjer
|
e2146fdafd
Passing ProducerMessage.Timestamp to broker when producing to v0.10
|
%!s(int64=10) %!d(string=hai) anos |
|
Evan Huus
|
1baff7ce02
Move a method used only in tests into the test file
|
%!s(int64=10) %!d(string=hai) anos |
|
Evan Huus
|
12de47f52f
Merge pull request #687 from jacksilv/checkMessages
|
%!s(int64=10) %!d(string=hai) anos |
