 Burke Libbey
|
843a3d9642
Use sarama.Logger.Println rather than log.Println
|
11 years ago |
|
Burke Libbey
|
6b1f0878c1
Update docs to reflect actual behaviour of MaxWaitTime=0
|
11 years ago |
|
Burke Libbey
|
27bf0b4e67
Revise message re: code review
|
11 years ago |
|
Burke Libbey
|
4b108b6689
Warn if Consumer is naively configured in a way that will cause busy-looping
|
11 years ago |
 Simon Eskildsen
|
3f1ee04b51
Add error handling for empty topics
|
11 years ago |
 Antoine Grondin
|
07ce59b43f
Revert `go vet` incompatible changes (go1.0). More magic numbers.
|
11 years ago |
|
Antoine Grondin
|
b08596183c
Flatten nested ifs with DeMorgan.
|
11 years ago |
|
Antoine Grondin
|
41e849837f
Fix `go vet` errors.
|
11 years ago |
|
Antoine Grondin
|
893044d278
Fix Golint errors, except for all the missing comments.
|
11 years ago |
|
Burke Libbey
|
9d5c25779a
Fix a logic bug that occurs when a broker is down.
|
11 years ago |
 Evan Huus
|
d1bbdae1d5
Make Client.Leader() public.
|
11 years ago |
|
Evan Huus
|
39a2698e08
Expose some client methods.
|
11 years ago |
|
Evan Huus
|
2dc6a7d564
Drop unnecessary type and iota
|
11 years ago |
|
Evan Huus
|
aeff5a9a6c
Add consumer OFFSET_METHOD_OLDEST
|
11 years ago |
|
Evan Huus
|
f0314fab75
Let the user configure the buffer in the consumer events channel
|
11 years ago |
 Evan Huus
|
96599c4142
Merge pull request #22 from Shopify/consumer_latest_flag
|
11 years ago |
|
Evan Huus
|
0522caa404
Match names correctly
|
11 years ago |
|
Evan Huus
|
2bdf59c479
Tweak naming and docs to hopefully be more comprehensible
|
11 years ago |
|
Evan Huus
|
6b3b02e129
Fix nil-pointer panic in consumer.
|
11 years ago |
|
Evan Huus
|
2565bc81b7
Add an OffsetMethod that permits specifying other methods of determining the offset, such as querying the broker
|
11 years ago |
|
Evan Huus
|
228a7e2b9f
Use a single consumer channel instead of two
|
11 years ago |
|
Evan Huus
|
541ea31b79
Add a StartingOffset config to the Consumer
|
11 years ago |
|
Evan Huus
|
043cdae0b7
Close method consistency
|
11 years ago |
|
Evan Huus
|
fd19279439
Take config pointers, and treat nil as all-defaults.
|
11 years ago |
|
Evan Huus
|
eef2be2e6c
Consumer configuration.
|
11 years ago |
|
Evan Huus
|
e4ff187a56
go 1.0 compatibility; all we lose is ipv6 zones
|
11 years ago |
|
Evan Huus
|
4969d24fa1
kafka->sarama
|
11 years ago |
|
Evan Huus
|
4957421f9e
Just return the messageblock, rather than smooshing the offset into the message
|
11 years ago |
|
Evan Huus
|
799b00cdad
Finish refactor to remove namespacing
|
11 years ago |
|
Evan Huus
|
9047579808
Split into two packages, one low-level, one high
|
11 years ago |
