 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 |
|
Evan Huus
|
0d4e4a2ea0
go fmt
|
11 years ago |
|
Evan Huus
|
5fbffdc5fa
stub creation of producer/consumer
|
11 years ago |
|
Evan Huus
|
ec1f0c8ea0
Initial checkpoint
|
11 years ago |
