This repository has been archived by the owner on Apr 9, 2022. It is now read-only.

Version 1.4.0#47

Merged

ychuzevi merged 15 commits intocriteo:masterfrom verdie-g:criteo/syncFebruary2020

Feb 26, 2020

+1,149-494

Commits on Feb 26, 2020

[Kafka] Introduce partition selector with message key

Jules Bovet
authored and
verdie-g
committed
Open more RawKafkaMessage so that clients can test with it

Stanislas POCTHIER
authored and
verdie-g
committed
Change format of Info log message

Stanislas POCTHIER
authored and
verdie-g
committed
Move GetApiVersion to Basics
verdie-g
committed
Fix record batch serialization
verdie-g
committed
Rename WriteSizeInBytes -> WriteWithSize
verdie-g
committed
Rename VarIntConvert.Read{Int64, Int32, ...} to ReadAs{Int64, Int32, ...}
verdie-g
committed
Make RecordBatch.Deserialize static
verdie-g
committed
Remove useless temporary variable
verdie-g
committed
Declare RecordBatch.Serialize variables as locally as possible
verdie-g
committed
Handle brokers sending partial messages in FetchResponse

Jules Bovet
authored and
verdie-g
committed
Introduce retry delay when fetching partitions in HandleStart fails

Jules Bovet
authored and
verdie-g
committed
Improve dead node logic

Jules Bovet
authored and
verdie-g
committed
Format partition correctly when logging
verdie-g
committed
Remove LoggerManager
verdie-g
committed