 Maxim Vladimirskiy
|
780ea152be
Fix gzip compression encode/decode test
|
преди 6 години |
 Phil Kedy
|
3805d7a205
Forgot to update 1 test
|
преди 6 години |
|
Phil Kedy
|
d40eb2c596
Tweak to LastOffsetDelta calculation based on C implementation (which uses length of records - 1)
|
преди 6 години |
 Ivan Babrou
|
939043e02e
Correctly encode RecordBatch.LastOffsetDelta
|
преди 6 години |
 Vlad Hanciuta
|
5fd60c2be0
Add producer support for Kafka 0.11 Records
|
преди 7 години |
|
Vlad Hanciuta
|
ed80c61d79
Make timestamp fields of type time.Time and time.Duration
|
преди 7 години |
|
Vlad Hanciuta
|
b37b1580be
Introduce dynamicPushEncoders
|
преди 7 години |
|
Vlad Hanciuta
|
61fb33edde
Rename Header to RecordHeader
|
преди 7 години |
|
Vlad Hanciuta
|
7630f80a01
Add support for Kafka 0.11 RecordBatch
|
преди 7 години |
