 Felix Geller
|
b966238f31
adds ResetOffset to reset to earlier offset values. #554
|
%!s(int64=7) %!d(string=hai) anos |
 Evan Huus
|
ccab789d44
OffsetManager: match upstream mark/next behaviour
|
%!s(int64=8) %!d(string=hai) anos |
|
Evan Huus
|
90a4cc632e
Fix race in broker version check
|
%!s(int64=8) %!d(string=hai) anos |
|
Evan Huus
|
7f63fa323d
Merge pull request #570 from mailgun/maxim/publish
|
%!s(int64=8) %!d(string=hai) anos |
 Matvey Arye
|
262eef8ff4
Add support for custom offset retention durations to offset manager
|
%!s(int64=8) %!d(string=hai) anos |
 Maxim Vladimirsky
|
201ab73cb4
Make mock brokers and protocol packets available for outsider
|
%!s(int64=9) %!d(string=hai) anos |
 Willem van Bergen
|
5109f975f5
OffsetManager: make initial offset configurable
|
%!s(int64=9) %!d(string=hai) anos |
|
Willem van Bergen
|
1e8c4f2b83
Add Close() error to OffsetManager interface
|
%!s(int64=9) %!d(string=hai) anos |
 Aaron Kavlie
|
33f2f9fdb4
Misc. small changes to address PR feedback
|
%!s(int64=9) %!d(string=hai) anos |
|
Aaron Kavlie
|
2ad9fa7801
Complete coverage of flushToBroker()
|
%!s(int64=9) %!d(string=hai) anos |
|
Aaron Kavlie
|
50afd11d79
Close open connections; refine and clean up code.
|
%!s(int64=9) %!d(string=hai) anos |
|
Aaron Kavlie
|
147e2fe87e
Test to covert abort process.
|
%!s(int64=9) %!d(string=hai) anos |
|
Aaron Kavlie
|
132f5820c3
Tests of error responses in fetchInitialOffset
|
%!s(int64=9) %!d(string=hai) anos |
|
Aaron Kavlie
|
67f88f7ce0
Break out repeated code to separate init function
|
%!s(int64=9) %!d(string=hai) anos |
|
Aaron Kavlie
|
71aee6656f
Test of one fetchInitialOffset error
|
%!s(int64=9) %!d(string=hai) anos |
|
Aaron Kavlie
|
5f0a997bd4
Test handling of commit errors when an offset is set
|
%!s(int64=9) %!d(string=hai) anos |
|
Aaron Kavlie
|
1d965338c7
Start offset manager tests
|
%!s(int64=9) %!d(string=hai) anos |
