 Mathieu Payeur Levallois
|
f66f2deeff
Add Consumer.HighWaterMarks()
|
7 years ago |
 Evan Huus
|
16da292b17
Consumer: handle compressed relative offsets
|
7 years ago |
 Nimi Wariboko Jr
|
f0f5b0ae1a
Consumer: fix deadlock - if the timer had already expired, don't try to read the channel again.
|
7 years ago |
|
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.
|
7 years ago |
 Nicolas S. Dade
|
906ed729ae
fix erronous errTimedOut ("abandoned subscription...because consuming was taking too long")
|
8 years ago |
|
Evan Huus
|
9d159b4cf0
Consumer: reduce timer allocations
|
8 years ago |
|
Evan Huus
|
d41f123b4a
Consumer: fix possible tight loop
|
8 years ago |
|
Evan Huus
|
10d06c2fe7
Plumb through v0.10 support for consumer/fetch
|
8 years ago |
 Mariano Gappa
|
bbe99d8b16
occured -> occurred
|
8 years ago |
|
Evan Huus
|
68920ff1be
Merge pull request #616 from Shopify/error-handling-audit
|
8 years ago |
|
Evan Huus
|
528741686b
Put "no consumergroups" in the docs more times
|
8 years ago |
|
Evan Huus
|
bed560f780
Add additional error handling based on spec
|
8 years ago |
|
Evan Huus
|
6facece8ef
Wrap godoc to 80 chars, round 2
|
8 years ago |
|
Evan Huus
|
93c1f7437d
Wrap all godoc at 80 characters
|
8 years ago |
|
Evan Huus
|
cdd80eb39a
Fix consumer race panic on close
|
8 years ago |
 yangfan
|
d7c5c53e31
Update consumer.go
|
8 years ago |
 Jeremy Schlatter
|
18dcb68ce3
fix typo
|
8 years ago |
|
Evan Huus
|
292f3b0aa1
consumer: don't block on undrained partitions
|
9 years ago |
|
Evan Huus
|
7e4b74b20d
Move the consumer's channel send slightly
|
9 years ago |
|
Evan Huus
|
8a91a50ecd
consumer: fix another race pointed out by Maxim
|
9 years ago |
|
Evan Huus
|
4a7c496a1c
Fix hypothetical consumer deadlock, attempt 3
|
9 years ago |
|
Evan Huus
|
7c4fa7452a
Document consumergroup repo location
|
9 years ago |
|
Evan Huus
|
0e02258ac8
Feed consumer responses to the user asynchronously
|
9 years ago |
|
Evan Huus
|
cfef09e46e
Refer to brokerConsumers consistently
|
9 years ago |
 Willem van Bergen
|
5f78d90083
Add high water mark offset support to the consumer.
|
9 years ago |
 Willem van Bergen
|
2052bd96dc
Add Topics() and Partitions to Consumer, and mock Consumer.
|
9 years ago |
|
Evan Huus
|
d82cd1f99d
Update godoc
|
9 years ago |
|
Evan Huus
|
c8b3e2e53f
consumer: shut down on OffsetOutOfRange
|
9 years ago |
|
Willem van Bergen
|
d629146c3e
Consumer: check offset before returning ConsumePartition.
|
9 years ago |
|
Evan Huus
|
e71403d050
Put `handleResponse` method on partitionConsumer
|
9 years ago |
