 Evan Huus
|
b2e844a45f
Merge pull request #124 from Shopify/fix-producer-deadlocks
|
11 lat temu |
|
Evan Huus
|
a76afec10e
Merge pull request #125 from Shopify/getoffset-better-error
|
11 lat temu |
|
Evan Huus
|
65629827b8
Return better error when server returns no offsets
|
11 lat temu |
|
Evan Huus
|
d4ba4ed0bf
Make sure we always call errorCb in flushRequest
|
11 lat temu |
|
Evan Huus
|
cfae4c6314
Merge pull request #120 from Shopify/leave-broker-connected
|
11 lat temu |
|
Evan Huus
|
3221de0278
Merge pull request #119 from Shopify/validate-offset
|
11 lat temu |
|
Evan Huus
|
58d966f25f
Only disconnect the broker on error conditions
|
11 lat temu |
|
Evan Huus
|
affb0b04e0
Only update the stored offset on successful events
|
11 lat temu |
|
Evan Huus
|
e33b57b271
Validate the offset received from kafka when consuming
|
11 lat temu |
 Willem van Bergen
|
648613d411
Merge pull request #118 from Shopify/mockbroker-tweak
|
11 lat temu |
|
Evan Huus
|
53701a953d
Make mockbroker's ID an int32 to avoid a boatload of casts
|
11 lat temu |
|
Willem van Bergen
|
7a259fb770
Merge pull request #117 from Shopify/rsrsps
|
11 lat temu |
 Willem van Bergen
|
c5df84256b
Code review fix
|
11 lat temu |
 Rob Rodgers
|
15782aa08d
Address Evan's comments on the previous version. Add checks for Closed() to a few other locations including consumer.go.
|
12 lat temu |
|
Rob Rodgers
|
26beb2e678
Add a check to make debugging easier when the client has been closed previously (e.g., an misplaced defer() closed it).
|
12 lat temu |
|
Willem van Bergen
|
70f3ca2135
Merge pull request #115 from Shopify/fixes
|
11 lat temu |
|
Willem van Bergen
|
2bae192c12
Use time.Duration values consistently in *Config types.
|
11 lat temu |
|
Evan Huus
|
b3d9702dd2
Merge pull request #113 from Shopify/func-test-tweak
|
11 lat temu |
|
Evan Huus
|
414f7d26e6
Close the producer inline instead of deferring it.
|
11 lat temu |
|
Evan Huus
|
726fa7099e
Add travis and godoc badges to README
|
11 lat temu |
|
Evan Huus
|
737f836006
remove stale comment
|
11 lat temu |
|
Evan Huus
|
5cbd22983e
doc tweaks suggested by golint
|
11 lat temu |
 Nick Evans
|
01497948eb
Merge pull request #109 from Shopify/add_GetCurrentOffset_to_client
|
11 lat temu |
|
Evan Huus
|
a321303f68
use Fatalf not Fatal when using format arguments (caught by vet)
|
11 lat temu |
|
Nick Evans
|
6352c9917d
add GetCurrentOffset to client
|
11 lat temu |
|
Evan Huus
|
b29a1814cb
Merge pull request #112 from Shopify/better-consumer-config
|
11 lat temu |
|
Evan Huus
|
d99b33ee72
Improve documentation and defaults for consumer configuration
|
11 lat temu |
 Burke Libbey
|
afe5c7e71e
Merge pull request #100 from dolzenko/fix-race
|
11 lat temu |
|
Willem van Bergen
|
3137586442
Merge pull request #110 from Shopify/make_functional_tests_optional
|
11 lat temu |
|
Willem van Bergen
|
3dc39f7c7c
Code review fixes
|
11 lat temu |
