 Willem van Bergen
|
f4fc52188a
Naming changes in the producer to be consistent with the consumer.
|
9 years ago |
|
Willem van Bergen
|
2432b5fcf7
Split consumer’s Events() channel into Messages() and Errors()
|
9 years ago |
 Evan Huus
|
888a76082a
Merge pull request #222 from Shopify/consumer-ng
|
9 years ago |
|
Willem van Bergen
|
588d923398
Add a test to make sure connection to a cluster that is completely down wil return an error
|
9 years ago |
|
Evan Huus
|
00b87fe357
Rewrite consumer to support multiple partitions
|
10 years ago |
|
Evan Huus
|
38d4c4754d
Fix bug #179
|
10 years ago |
|
Evan Huus
|
eb42926dd4
Move successes to its own channel
|
10 years ago |
|
Evan Huus
|
430eaee5b4
Actually check the return from Close in our tests
|
10 years ago |
|
Evan Huus
|
d5448f1b9a
New Producer design
|
10 years ago |
|
Evan Huus
|
d3bc825c36
Add Vagrantfile, and provisioning scripts that set up a working 5-node cluster.
|
10 years ago |
|
Evan Huus
|
acd62d54ab
Use the ConstantPartitioner in the functional test
|
10 years ago |
|
Evan Huus
|
414f7d26e6
Close the producer inline instead of deferring it.
|
10 years ago |
|
Evan Huus
|
a321303f68
use Fatalf not Fatal when using format arguments (caught by vet)
|
10 years ago |
|
Willem van Bergen
|
3dc39f7c7c
Code review fixes
|
10 years ago |
|
Willem van Bergen
|
44c40323d2
Only run functional tests when Kafka is available. Require that when ENV[CI] is set.
|
10 years ago |
|
Willem van Bergen
|
2a5ab0515b
Simple functional test
|
10 years ago |
