blob: e4454554ca93faef6859310da0a3df7ef2c29819 (
plain)
1
2
3
4
5
6
7
8
|
Module structured mostly based on
kafka/clients/src/main/java/org/apache/kafka/common/record/ module of Java
Client.
See abc.py for abstract declarations. `ABCRecords` is used as a facade to hide
version differences. `ABCRecordBatch` subclasses will implement actual parsers
for different versions (v0/v1 as LegacyBatch and v2 as DefaultBatch. Names
taken from Java).
|
