 Vlad Hanciuta
|
5fd60c2be0
Add producer support for Kafka 0.11 Records
|
%!s(int64=6) %!d(string=hai) anos |
|
Vlad Hanciuta
|
ed80c61d79
Make timestamp fields of type time.Time and time.Duration
|
%!s(int64=6) %!d(string=hai) anos |
|
Vlad Hanciuta
|
ff1f79c54b
Add dynamicPushDecoder interface
|
%!s(int64=6) %!d(string=hai) anos |
|
Vlad Hanciuta
|
5ffc7bf531
Simplify uncompressed records length computation
|
%!s(int64=6) %!d(string=hai) anos |
|
Vlad Hanciuta
|
135aca9ac6
Don't cache the length
|
%!s(int64=6) %!d(string=hai) anos |
|
Vlad Hanciuta
|
b37b1580be
Introduce dynamicPushEncoders
|
%!s(int64=6) %!d(string=hai) anos |
|
Vlad Hanciuta
|
61fb33edde
Rename Header to RecordHeader
|
%!s(int64=6) %!d(string=hai) anos |
|
Vlad Hanciuta
|
f554f211f2
Add support for Kafka 0.11 Record format.
|
%!s(int64=6) %!d(string=hai) anos |
