 Vagrant User
|
87e4033a66
Optionally use a ticker instead of a timer to detect timeouts
|
8 years ago |
|
Vagrant User
|
7bbb175476
Add an optional fast checker to (*partitionConsumer).responseFeeder
|
8 years ago |
 Michael Herstine
|
45f017b7f4
Docstring change only to PartitionConsumer.
|
8 years ago |
 Evan Huus
|
2fd980e23b
Merge pull request #905 from sp1ff/master
|
8 years ago |
|
Michael Herstine
|
b69551c88b
Add support for FetchRequest API V3.
|
8 years ago |
|
Michael Herstine
|
4d1eceb890
Added support for FetchRequest protocol version 3.
|
8 years ago |
 DV
|
ce6585f068
#885: added BlockTimestamp to ConsumerMessage
|
8 years ago |
|
Evan Huus
|
7f63d35b79
Fix an additional possible alignment issue
|
8 years ago |
 DiSiqueira
|
cecb3d9807
Formating all files with gofmt -s
|
8 years ago |
|
Evan Huus
|
8d739a4669
Tweak some docs
|
9 years ago |
 Mathieu Payeur Levallois
|
b0e729b8e9
Fix HighWaterMarks() comment
|
9 years ago |
|
Mathieu Payeur Levallois
|
f66f2deeff
Add Consumer.HighWaterMarks()
|
9 years ago |
|
Evan Huus
|
16da292b17
Consumer: handle compressed relative offsets
|
9 years ago |
 Nimi Wariboko Jr
|
f0f5b0ae1a
Consumer: fix deadlock - if the timer had already expired, don't try to read the channel again.
|
9 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.
|
9 years ago |
 Nicolas S. Dade
|
906ed729ae
fix erronous errTimedOut ("abandoned subscription...because consuming was taking too long")
|
9 years ago |
|
Evan Huus
|
9d159b4cf0
Consumer: reduce timer allocations
|
9 years ago |
|
Evan Huus
|
d41f123b4a
Consumer: fix possible tight loop
|
9 years ago |
|
Evan Huus
|
10d06c2fe7
Plumb through v0.10 support for consumer/fetch
|
9 years ago |
 Mariano Gappa
|
bbe99d8b16
occured -> occurred
|
9 years ago |
|
Evan Huus
|
68920ff1be
Merge pull request #616 from Shopify/error-handling-audit
|
9 years ago |
|
Evan Huus
|
528741686b
Put "no consumergroups" in the docs more times
|
9 years ago |
|
Evan Huus
|
bed560f780
Add additional error handling based on spec
|
9 years ago |
|
Evan Huus
|
6facece8ef
Wrap godoc to 80 chars, round 2
|
10 years ago |
|
Evan Huus
|
93c1f7437d
Wrap all godoc at 80 characters
|
10 years ago |
|
Evan Huus
|
cdd80eb39a
Fix consumer race panic on close
|
10 years ago |
 yangfan
|
d7c5c53e31
Update consumer.go
|
10 years ago |
 Jeremy Schlatter
|
18dcb68ce3
fix typo
|
10 years ago |
|
Evan Huus
|
292f3b0aa1
consumer: don't block on undrained partitions
|
10 years ago |
|
Evan Huus
|
7e4b74b20d
Move the consumer's channel send slightly
|
10 years ago |
