 Evan Huus
|
0abdf8c4f0
Move the clientID into the config object
|
9 rokov pred |
|
Evan Huus
|
b97ce78d42
Check for errors in test code
|
9 rokov pred |
 Willem van Bergen
|
91a706483c
Unexport mockbroker.
|
9 rokov pred |
|
Evan Huus
|
113fd78e0a
Add BrokerConfig
|
10 rokov pred |
|
Evan Huus
|
ac43305594
Add broker func for consumer metadata request
|
10 rokov pred |
 Alexey Borzenkov
|
aa133ab822
Fix offset commit/fetch compatibility with kafka 0.8.1
|
10 rokov pred |
 Burke Libbey
|
2f5cf8fd16
Fixed remaining test.
|
11 rokov pred |
|
Burke Libbey
|
38c749201b
uncomment broker test...
|
11 rokov pred |
|
Burke Libbey
|
b7c236d53a
wip
|
11 rokov pred |
|
Burke Libbey
|
fca2325bf4
wip
|
11 rokov pred |
|
Burke Libbey
|
37608277e6
converted the last of the old mockbroker test
|
11 rokov pred |
|
Burke Libbey
|
6c8a7dd28d
wip
|
11 rokov pred |
|
Burke Libbey
|
96d86eca56
wip
|
11 rokov pred |
|
Burke Libbey
|
3a0483dc2b
Allow configuration of per-broker concurrency.
|
11 rokov pred |
|
Willem van Bergen
|
9f4fc55ccc
Use a package level Logger.
|
11 rokov pred |
|
Willem van Bergen
|
a5e7b9795e
Add basic logging for Broker connection events.
|
11 rokov pred |
 Antoine Grondin
|
893044d278
Fix Golint errors, except for all the missing comments.
|
11 rokov pred |
 Evan Huus
|
0f7b431bdf
Remove Broker.Equals()
|
11 rokov pred |
|
Evan Huus
|
efb24f7c1c
Add accessor for broker's address
|
11 rokov pred |
|
Evan Huus
|
dae9785f7e
Replace broker's host/port with just addr
|
11 rokov pred |
|
Evan Huus
|
cb8190ccd7
tweak broker example
|
11 rokov pred |
|
Evan Huus
|
934c5688a1
Match the golang database pattern
|
11 rokov pred |
|
Evan Huus
|
4969d24fa1
kafka->sarama
|
11 rokov pred |
|
Evan Huus
|
be4d7628e5
wip remove namespacing
|
11 rokov pred |
