 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 |
