 Willem van Bergen
|
cc01cb4093
Merge pull request #303 from Shopify/split_consumer_events_channel
|
10 rokov pred |
 Willem van Bergen
|
87c89f868c
Also prefix KError instances with Err.
|
10 rokov pred |
|
Willem van Bergen
|
2018fd405e
Prefix error variables with Err
|
10 rokov pred |
|
Willem van Bergen
|
ed24dc91a8
Code review fixes.
|
10 rokov pred |
|
Willem van Bergen
|
fb5ef06e83
Godoc fixes.
|
10 rokov pred |
|
Willem van Bergen
|
2a331e8329
Fix inconsistent naming
|
10 rokov pred |
|
Willem van Bergen
|
2432b5fcf7
Split consumer’s Events() channel into Messages() and Errors()
|
10 rokov pred |
|
Willem van Bergen
|
fdfdc28d62
golint: remove unnecessary _ variable.
|
10 rokov pred |
|
Willem van Bergen
|
07ea9f134a
consumerWorker -> brokerConsumer
|
11 rokov pred |
|
Willem van Bergen
|
cbba3f5c62
Rename some stuff so its meaning is more clear
|
11 rokov pred |
 Evan Huus
|
8fab957db1
Change multi-consumer unexpected error handling
|
11 rokov pred |
|
Evan Huus
|
00b87fe357
Rewrite consumer to support multiple partitions
|
11 rokov pred |
|
Evan Huus
|
39a066ae3d
consumer: add unit test
|
11 rokov pred |
|
Evan Huus
|
6c7468fa03
consumer: more robust handling of message offsets
|
11 rokov pred |
|
Evan Huus
|
64e556f2c9
consumer: silently skip messages already consumed
|
11 rokov pred |
|
Evan Huus
|
affb0b04e0
Only update the stored offset on successful events
|
11 rokov pred |
|
Evan Huus
|
e33b57b271
Validate the offset received from kafka when consuming
|
11 rokov pred |
 Rob Rodgers
|
15782aa08d
Address Evan's comments on the previous version. Add checks for Closed() to a few other locations including consumer.go.
|
12 rokov pred |
|
Willem van Bergen
|
2bae192c12
Use time.Duration values consistently in *Config types.
|
11 rokov pred |
|
Evan Huus
|
5cbd22983e
doc tweaks suggested by golint
|
11 rokov pred |
 Nick Evans
|
01497948eb
Merge pull request #109 from Shopify/add_GetCurrentOffset_to_client
|
11 rokov pred |
|
Nick Evans
|
6352c9917d
add GetCurrentOffset to client
|
11 rokov pred |
|
Evan Huus
|
d99b33ee72
Improve documentation and defaults for consumer configuration
|
11 rokov pred |
|
Willem van Bergen
|
423e478a06
Small fixes
|
11 rokov pred |
|
Willem van Bergen
|
8c789b7d01
Add NewConsumerConfig()
|
11 rokov pred |
|
Willem van Bergen
|
28b289a868
Do the same for ClientConfig and ProducerConfig
|
11 rokov pred |
|
Willem van Bergen
|
9d9be45ad0
Add docs for ConsumerConfig#Validate.
|
11 rokov pred |
|
Willem van Bergen
|
e3a0e2b5e6
Move ConsumerConfig validation to separate method that is exported.
|
11 rokov pred |
|
Willem van Bergen
|
b3e86b9af5
Update docs and sendError
|
11 rokov pred |
|
Willem van Bergen
|
b0c0c68111
Add topic and partition to ConsumerEvent struct
|
11 rokov pred |
