# ProduceRequest | |
\x00\x00\x00|\x00\x00\x00\x00\x00\x00\x00\x03\x00\x0ckafka-python\x00\x01\x00\x00\x03\xe8\x00\x00\x00\x01\x00\x04foo2\x00\x00\x00\x01\x00\x00\x00\x00\x00\x00\x00J\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00>t\xd1\x91<\x02\x01\x00\x00\x00\x03foo\x00\x00\x00-\x1f\x8b\x08\x00\x0c3\tQ\x02\xffc`\x80\x03\x89P\xf7\xef\xccL \x16sZ~>\x90bw\x8f\xf2\x0c\x08HM\x01\x00\xc5\x93\xd3<$\x00\x00\x00 | |
\x00\x00\x00| # Size 124 | |
\x00\x00 # ApiKey 0 | |
\x00\x00 # ApiVersion 0 | |
\x00\x00\x00\x03 # CorrelationId 3 | |
\x00\x0ckafka-python # ClientId "kafka-python" | |
\x00\x01 # RequiredAcks 1 | |
\x00\x00\x03\xe8 # Timeout 1000 | |
\x00\x00\x00\x01 # NumTopics 1 | |
\x00\x04foo2 # TopicName "foo2" | |
\x00\x00\x00\x01 # NumPartitions 1 | |
\x00\x00\x00\x00 # Partition 0 | |
\x00\x00\x00J # MessageSetSize 74 | |
\x00\x00\x00\x00\x00\x00\x00\x00 # Offset 0 | |
\x00\x00\x00> # MessageSize 62 | |
t\xd1\x91< # Crc 1959891260 | |
\x02 # MagicByte 2 | |
\x01 # Attributes 1 | |
\x00\x00\x00\x03foo # Key "foo" | |
\x00\x00\x00-\x1f\x8b\x08\x00\x0c3\tQ\x02\xffc`\x80\x03\x89P\xf7\xef\xccL \x16sZ~>\x90bw\x8f\xf2\x0c\x08HM\x01\x00\xc5\x93\xd3<$\x00\x00\x00 # Value | |
# ProduceResponse | |
\x00\x00\x00\x03\x00\x00\x00\x01\x00\x04foo2\x00\x00\x00\x01\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00 | |
\x00\x00\x00\x03 # CorrelationId 3 | |
\x00\x00\x00\x01 # NumTopics 1 | |
\x00\x04foo2 # TopicName "foo2" | |
\x00\x00\x00\x01 # NumPartitions 1 | |
\x00\x00\x00\x00 # Partition 0 | |
\x00\x00 # ErrorCode 0 | |
\x00\x00\x00\x00\x00\x00\x00\x00 # Offset 0 | |
# FetchRequest | |
\x00\x00\x00@\x00\x01\x00\x00\x00\x00\x00\x04\x00\x0ckafka-python\xff\xff\xff\xff\x00\x00\x00d\x00\x00\x04\x00\x00\x00\x00\x01\x00\x04foo2\x00\x00\x00\x01\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x04\x00 | |
\x00\x00\x00@ # Size 64 | |
\x00\x01 # ApiKey 1 | |
\x00\x00 # ApiVersion 0 | |
\x00\x00\x00\x04 # CorrelationId 4 | |
\x00\x0ckafka-python # ClientId "kafka-python" | |
\xff\xff\xff\xff # ReplicaId -1 | |
\x00\x00\x00d # MaxWaitTime 100 | |
\x00\x00\x04\x00 # MinBytes 1024 | |
\x00\x00\x00\x01 # NumTopics 1 | |
\x00\x04foo2 # TopicName "foo2" | |
\x00\x00\x00\x01 # NumPartitions 1 | |
\x00\x00\x00\x00 # Partition 0 | |
\x00\x00\x00\x00\x00\x00\x00\x00 # FetchOffset 0 | |
\x00\x00\x04\x00 # MaxBytes 1024 | |
# FetchResponse | |
\x00\x00\x00\x04\x00\x00\x00\x01\x00\x04foo2\x00\x00\x00\x01\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x01\x00\x00\x00G\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00;\xf5#\xc2N\x00\x01\xff\xff\xff\xff\x00\x00\x00-\x1f\x8b\x08\x00\x00\x00\x00\x00\x00\x00c`\x80\x03\x89P\xf7\xef\xccL \x16sZ~>\x90bw\x8f\xf2\x0c\x08HM\x01\x00\xc5\x93\xd3<$\x00\x00\x00 | |
\x00\x00\x00\x04 # CorrelationId 4 | |
\x00\x00\x00\x01 # NumTopics 1 | |
\x00\x04foo2 # TopicName "foo2" | |
\x00\x00\x00\x01 # NumPartitions 1 | |
\x00\x00\x00\x00 # Partition 0 | |
\x00\x00 # ErrorCode 0 | |
\x00\x00\x00\x00\x00\x00\x00\x01 # HighwaterMarkOffset 1 | |
\x00\x00\x00G # MessageSetSize 71 | |
\x00\x00\x00\x00\x00\x00\x00\x00 # Offset 0 | |
\x00\x00\x00; # MessageSize 59 | |
\xf5#\xc2N # Crc -182205874 | |
\x00 # MagicByte 0 | |
\x01 # Attributes 1 | |
\xff\xff\xff\xff # ??? | |
\x00\x00\x00-\x1f\x8b\x08\x00\x00\x00\x00\x00\x00\x00c`\x80\x03\x89P\xf7\xef\xccL \x16sZ~>\x90bw\x8f\xf2\x0c\x08HM\x01\x00\xc5\x93\xd3<$\x00\x00\x00 # Value | |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment