 Vlad Hanciuta
|
b7f694ebc8
Determine the records type based on the magic number not API version
|
8 years ago |
 Christofer Bäcklin
|
a709f2d5ca
String functions for KafkaVersion (#989)
|
8 years ago |
 Evan Huus
|
135422b71d
Bump the go version in dev
|
8 years ago |
|
Evan Huus
|
0f6b831794
Merge pull request #982 from Shopify/consumer/fix-last-stable-offset
|
8 years ago |
|
Evan Huus
|
9ea1af8cf1
Merge pull request #984 from buyology/kafka-1.0.0
|
8 years ago |
 Robin
|
d9a51ed3de
update readme, bump 0.11, remove 0.9
|
8 years ago |
|
Robin
|
1408a8cdca
add kafka 1.0.0 to travis and as kafka version constant
|
8 years ago |
|
Evan Huus
|
10f33bec2a
consumer: don't check LastStableOffset
|
8 years ago |
|
Evan Huus
|
240fd146ce
update changelog
|
8 years ago |
|
Evan Huus
|
34068369ff
Merge pull request #975 from Shopify/return-partial-replicas
|
8 years ago |
|
Evan Huus
|
b305748200
Merge pull request #976 from wladh/producer
|
8 years ago |
|
Evan Huus
|
f12be49deb
Merge pull request #978 from mkevac/master
|
8 years ago |
 Marko Kevac
|
0e776fb397
add format of an GetOffset argument to documentation
|
8 years ago |
|
Vlad Hanciuta
|
5fd60c2be0
Add producer support for Kafka 0.11 Records
|
8 years ago |
|
Vlad Hanciuta
|
5a79f9f5ac
Add support for nullable strings.
|
8 years ago |
|
Evan Huus
|
606f9ba821
Merge pull request #974 from wladh/consumer
|
8 years ago |
|
Vlad Hanciuta
|
ed80c61d79
Make timestamp fields of type time.Time and time.Duration
|
8 years ago |
|
Vlad Hanciuta
|
5959a18af1
Make isolation level a type
|
8 years ago |
|
Evan Huus
|
84d87a3a41
client: return partial replicas
|
8 years ago |
|
Vlad Hanciuta
|
953231c528
Add support for Kafka 0.11 in consumer
|
8 years ago |
|
Vlad Hanciuta
|
cfb0c1d0ba
Add 0.11.0.0 in KafkaVersions
|
8 years ago |
|
Evan Huus
|
eca6c1cfdb
Merge pull request #973 from wladh/records
|
8 years ago |
|
Vlad Hanciuta
|
ff1f79c54b
Add dynamicPushDecoder interface
|
8 years ago |
|
Vlad Hanciuta
|
808ea149d8
Check records encoding error
|
8 years ago |
|
Vlad Hanciuta
|
033fed9b92
varintLengthField.reserveLen() should return 0 during decode
|
8 years ago |
|
Vlad Hanciuta
|
bd304f1b40
Refactor record batch encoding
|
8 years ago |
|
Vlad Hanciuta
|
c302872c8f
Fix typo
|
8 years ago |
|
Vlad Hanciuta
|
4a9a2bcc47
Get rid of size and adjusted fields in varintLengthField
|
8 years ago |
|
Vlad Hanciuta
|
5ffc7bf531
Simplify uncompressed records length computation
|
8 years ago |
|
Vlad Hanciuta
|
b51e2317f4
Make an encoder/decoder for records array
|
8 years ago |
