 Leonid Koftun
|
2d2326efcf
feat: Add alter and list partition reassignments
|
4 vuotta sitten |
 Diego Alvarez
|
88b0e98974
removes unused fields/methods
|
4 vuotta sitten |
 Sean Hanson
|
dec71e97e5
Remove use of magic number
|
5 vuotta sitten |
|
Sean Hanson
|
1d23237375
Remove useless tmp var
|
5 vuotta sitten |
|
Sean Hanson
|
4ed1ab2ab8
Provide peekInt8 to reduce allocations
|
5 vuotta sitten |
 Robin
|
7957e72eca
factor out getStringLength, use putArrayLength
|
7 vuotta sitten |
|
Robin
|
b3f149d4d2
add create partitions
|
7 vuotta sitten |
 Vlad Hanciuta
|
b7f694ebc8
Determine the records type based on the magic number not API version
|
7 vuotta sitten |
|
Vlad Hanciuta
|
5a79f9f5ac
Add support for nullable strings.
|
7 vuotta sitten |
|
Vlad Hanciuta
|
ff1f79c54b
Add dynamicPushDecoder interface
|
7 vuotta sitten |
|
Vlad Hanciuta
|
82babd01e5
Allow negative values for getArrayLength()
|
7 vuotta sitten |
|
Vlad Hanciuta
|
ba10b7b08d
Add support for varint encoding and decoding
|
7 vuotta sitten |
 DiSiqueira
|
fdebee00c4
Following Golint tips for if blocks who ends with a return
|
7 vuotta sitten |
 Dieter Plaetinck
|
70f640ef06
move to real_decoder and privatize.
|
8 vuotta sitten |
|
Dieter Plaetinck
|
edca54dc23
pre-allocate decoding errors
|
8 vuotta sitten |
 Willem van Bergen
|
1badb8e8c4
Add JoinGroup request and response pair.
|
9 vuotta sitten |
 Evan Huus
|
12d29331cf
A few minor suggestions from golint
|
9 vuotta sitten |
|
Evan Huus
|
900e4f4595
Centralize and unify getSubset error checking
|
9 vuotta sitten |
|
Evan Huus
|
66411d8222
Cleanup a bunch more error formats
|
9 vuotta sitten |
|
Evan Huus
|
37fcac52fd
Hardcode integer sizes
|
9 vuotta sitten |
|
Willem van Bergen
|
566627d2ad
Make PacketEncodingError and PacketDecodingError more similar to each other.
|
9 vuotta sitten |
|
Willem van Bergen
|
2018fd405e
Prefix error variables with Err
|
9 vuotta sitten |
 Burke Libbey
|
34956b2be3
More informative logging around DecodingError, and bumped max msg size
|
11 vuotta sitten |
 Evan Huus
|
0f5cff6a9a
Return a decoding error for negative array lengths
|
11 vuotta sitten |
 Antoine Grondin
|
07ce59b43f
Revert `go vet` incompatible changes (go1.0). More magic numbers.
|
11 vuotta sitten |
|
Antoine Grondin
|
893044d278
Fix Golint errors, except for all the missing comments.
|
11 vuotta sitten |
|
Evan Huus
|
e4ff187a56
go 1.0 compatibility; all we lose is ipv6 zones
|
11 vuotta sitten |
|
Evan Huus
|
4969d24fa1
kafka->sarama
|
11 vuotta sitten |
|
Evan Huus
|
07a8b70445
wip remove namespacing
|
11 vuotta sitten |
|
Evan Huus
|
9047579808
Split into two packages, one low-level, one high
|
11 vuotta sitten |
