 Robin
|
b3f149d4d2
add create partitions
|
6 éve |
 Vlad Hanciuta
|
b7f694ebc8
Determine the records type based on the magic number not API version
|
6 éve |
|
Vlad Hanciuta
|
5a79f9f5ac
Add support for nullable strings.
|
6 éve |
|
Vlad Hanciuta
|
ff1f79c54b
Add dynamicPushDecoder interface
|
6 éve |
|
Vlad Hanciuta
|
ba10b7b08d
Add support for varint encoding and decoding
|
6 éve |
 Willem van Bergen
|
1badb8e8c4
Add JoinGroup request and response pair.
|
8 éve |
 Evan Huus
|
4969d24fa1
kafka->sarama
|
11 éve |
|
Evan Huus
|
07a8b70445
wip remove namespacing
|
11 éve |
|
Evan Huus
|
9047579808
Split into two packages, one low-level, one high
|
11 éve |
|
Evan Huus
|
d53fb36f6a
Offset request/response
|
11 éve |
 Evan Huus
|
0c69a97459
Slices can already be nil
|
11 éve |
|
Evan Huus
|
1862bd8823
Decode remaining parts of fetch responses
|
11 éve |
|
Evan Huus
|
fe73334510
Factor out common array encoding/decoding
|
11 éve |
|
Evan Huus
|
ca7a207750
finish basic message encoding/decoding
|
11 éve |
|
Evan Huus
|
2deb91d926
checkpoint wip message encoding/decoding
|
11 éve |
|
Evan Huus
|
91b0ddffd1
go files use snake_case
|
11 éve |
