 Evan Huus
|
96fa1c8378
Allow resetting manager to the same offset
|
%!s(int64=7) %!d(string=hai) anos |
 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
|
0d77a1d392
Offset Manager: report unknown topic errors
|
%!s(int64=8) %!d(string=hai) anos |
|
Evan Huus
|
53285c9f5e
Fix race condition on OffsetManager shutdown
|
%!s(int64=8) %!d(string=hai) anos |
|
Evan Huus
|
2048ccdb23
Don't try to send partition timestamps in v2 OCRs
|
%!s(int64=8) %!d(string=hai) anos |
|
Evan Huus
|
bed560f780
Add additional error handling based on spec
|
%!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
|
48e29ec594
Publish GroupGenerationUndefined constant
|
%!s(int64=9) %!d(string=hai) anos |
|
Maxim Vladimirsky
|
1e5cc31d7c
Fix offset_manager for Kafka 0.9.0.0
|
%!s(int64=9) %!d(string=hai) anos |
|
Evan Huus
|
12d29331cf
A few minor suggestions from golint
|
%!s(int64=9) %!d(string=hai) anos |
|
Evan Huus
|
6facece8ef
Wrap godoc to 80 chars, round 2
|
%!s(int64=9) %!d(string=hai) anos |
|
Evan Huus
|
93c1f7437d
Wrap all godoc at 80 characters
|
%!s(int64=9) %!d(string=hai) anos |
|
Evan Huus
|
e4cf5d402c
Fix offset-manager expiry timestamps to 'now'
|
%!s(int64=9) %!d(string=hai) anos |
|
Evan Huus
|
46fa225867
A few minor offset-manager tweaks
|
%!s(int64=9) %!d(string=hai) anos |
 Willem van Bergen
|
0ae0505b85
Deregister a partition offset manager in the OffsetManager when it is done, so we can register a new one later.
|
%!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 |
|
Willem van Bergen
|
1e19f5c7c7
Improve godoc of PartitionOffsetManager interface
|
%!s(int64=9) %!d(string=hai) anos |
|
Evan Huus
|
84abfe4a4c
Skip clean subscriptions when parsing responses
|
%!s(int64=9) %!d(string=hai) anos |
 Aaron Kavlie
|
e98389a071
Fix some error return codes
|
%!s(int64=9) %!d(string=hai) anos |
|
Evan Huus
|
9d4ca029b1
Fix abort()
|
%!s(int64=9) %!d(string=hai) anos |
|
Evan Huus
|
b4fb5b7b3b
Only add dirty subscriptions to the request
|
%!s(int64=9) %!d(string=hai) anos |
|
Evan Huus
|
9e2380c33a
Don't start setting until the initial get succeeds
|
%!s(int64=9) %!d(string=hai) anos |
|
Evan Huus
|
e7d8e17d23
Don't shutdown until the latest offset was successfully committed
|
%!s(int64=9) %!d(string=hai) anos |
|
Evan Huus
|
90ba479262
Track dirty flag in partition-offset-manager
|
%!s(int64=9) %!d(string=hai) anos |
|
Evan Huus
|
e0c0da8880
First draft implementation of an offset manager
|
%!s(int64=9) %!d(string=hai) anos |
