 Willem van Bergen
|
68e40800ed
Fix travis config
|
%!s(int64=11) %!d(string=hai) anos |
 Willem van Bergen
|
2e9e85aa81
Merge pull request #64 from dim/master
|
%!s(int64=11) %!d(string=hai) anos |
 Dimitrij Denissenko
|
3233da72fa
Mockbroker should not import testing - https://github.com/Shopify/sarama/issues/66
|
%!s(int64=11) %!d(string=hai) anos |
 Ev Dolzhenko
|
4a85940400
Revert "Rename mockbroker.go to mockbroker_test.go"
|
%!s(int64=11) %!d(string=hai) anos |
|
Ev Dolzhenko
|
849ea1ab8e
Rename mockbroker.go to mockbroker_test.go
|
%!s(int64=11) %!d(string=hai) anos |
|
Dimitrij Denissenko
|
9675a91962
Added Gzip test. Simplified a little.
|
%!s(int64=11) %!d(string=hai) anos |
|
Dimitrij Denissenko
|
c087d7fc53
Allow Gzip bulk consumption
|
%!s(int64=11) %!d(string=hai) anos |
|
Dimitrij Denissenko
|
b1a73257c4
Allow to decode snappy streams
|
%!s(int64=11) %!d(string=hai) anos |
|
Dimitrij Denissenko
|
7664076559
Added support for snappy stream decoding
|
%!s(int64=11) %!d(string=hai) anos |
 Burke Libbey
|
ac41aba73c
Merge pull request #63 from Shopify/verbose_decoding_error
|
%!s(int64=11) %!d(string=hai) anos |
|
Burke Libbey
|
00a4811e0d
DecodingError.Packet wasn't very useful
|
%!s(int64=11) %!d(string=hai) anos |
|
Burke Libbey
|
34956b2be3
More informative logging around DecodingError, and bumped max msg size
|
%!s(int64=11) %!d(string=hai) anos |
|
Burke Libbey
|
00c7285dc2
Merge pull request #62 from Shopify/more_logging
|
%!s(int64=11) %!d(string=hai) anos |
|
Burke Libbey
|
13d276c488
Log the other two sites where disconnectBroker is called
|
%!s(int64=11) %!d(string=hai) anos |
|
Willem van Bergen
|
dacfb4bced
Merge pull request #61 from Shopify/metadata_request_logging
|
%!s(int64=11) %!d(string=hai) anos |
|
Willem van Bergen
|
8a309047ec
Small tweaks
|
%!s(int64=11) %!d(string=hai) anos |
|
Willem van Bergen
|
59d8bbd31d
Add logging to metadata refreshes
|
%!s(int64=11) %!d(string=hai) anos |
|
Burke Libbey
|
e780b70223
Fixed tests
|
%!s(int64=11) %!d(string=hai) anos |
|
Burke Libbey
|
12297f18bd
Fixed tests
|
%!s(int64=11) %!d(string=hai) anos |
|
Burke Libbey
|
a3737f568e
More verbose logging on failure
|
%!s(int64=11) %!d(string=hai) anos |
|
Burke Libbey
|
5c4debd9dd
Add a bit more logging to client creation/closing
|
%!s(int64=11) %!d(string=hai) anos |
|
Burke Libbey
|
732652bf64
Yell about un-thought-about config values.
|
%!s(int64=11) %!d(string=hai) anos |
|
Burke Libbey
|
87b7e454d0
When OutOfBrokers, retry with previously-disconnected brokers.
|
%!s(int64=11) %!d(string=hai) anos |
|
Burke Libbey
|
e9d9675a5b
Copy iteration var into block-local to prevent clobbering spawned Gs.
|
%!s(int64=11) %!d(string=hai) anos |
|
Burke Libbey
|
1103e8c970
Fix consumer tests
|
%!s(int64=11) %!d(string=hai) anos |
|
Burke Libbey
|
8c2c1f53d4
Don't let the caller pass in MaxWaitTime=0.
|
%!s(int64=11) %!d(string=hai) anos |
|
Burke Libbey
|
290b698c74
ReplicaNotAvailable is returned from FetchRequests.
|
%!s(int64=11) %!d(string=hai) anos |
|
Burke Libbey
|
0d48767f72
Force callers to configure MaxBufferedBytes and MaxBufferTime.
|
%!s(int64=11) %!d(string=hai) anos |
|
Burke Libbey
|
32a25f144c
Fixed a logic bug whereby a producer hung after leader election
|
%!s(int64=11) %!d(string=hai) anos |
|
Burke Libbey
|
d26a0090a4
Merge pull request #59 from Shopify/more_error_reporting
|
%!s(int64=11) %!d(string=hai) anos |
