-
-
Save mumrah/bf134906f6559b0f54ad to your computer and use it in GitHub Desktop.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
# 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