Packages
kafka_protocol
1.0.0
4.3.4
4.3.3
4.3.2
4.3.1
4.3.0
4.2.9
4.2.8
4.2.7
4.2.6
4.2.5
4.2.4
4.2.3
4.2.2
4.2.1
4.2.0
4.1.10
4.1.9
4.1.8
4.1.7
4.1.6
4.1.5
4.1.4
4.1.3
4.1.2
4.1.1
4.1.0
4.0.3
4.0.2
4.0.1
3.0.1
3.0.0
2.4.1
2.3.6
2.3.5
2.3.4
2.3.3
2.3.2
2.3.1
2.3.0
2.2.9
2.2.8
2.2.7
2.2.6
2.2.5
2.2.4
2.2.3
2.2.2
2.2.1
2.2.0
2.1.2
2.1.1
2.1.0
2.0.1
2.0.0
1.1.3
1.1.2
1.1.1
1.1.0
1.0.0
0.9.2
0.9.1
0.9.0
0.8.0
0.7.8
0.7.7
0.7.6
0.7.5
0.7.4
0.7.3
0.7.2
0.7.1
0.7.0
0.6.0
0.4.0
0.3.2
0.3.1
0.2.3
Kafka protocol library for Erlang/Elixir
Current section
Files
Jump to
Current section
Files
priv/kafka_prelude.bnf
Packet => size payload
size => INT32
payload => Request | Response
Message => offset size crc magic_byte attributes key value
offset => INT64
size => INT32
crc => INT32
magic_byte => INT8
attributes => INT8
key => BYTES
value => BYTES
# embedded in 'BYTES' content of
# JoinGroupRequestV0.group_protocol.protocol_metadata
# JoinGroupResponseV0.members.protocol_metadata
ConsumerGroupProtocolMetadata => version [topics] user_data
version => INT16
topics => STRING
user_data => BYTES
## embedded in 'BYTES' content of
## SyncGroupRequestV0.group_assignment.member_assignment
ConsumerGroupMemberAssignment => version [partition_assignments] user_data
version => INT16
partition_assignments => topic [partitions]
topic => STRING
partitions => INT32
user_data => BYTES