Create a gist now

Instantly share code, notes, and snippets.

@mumrah /gist:bf134906f6559b0f54ad Secret
Created Jan 30, 2013

What would you like to do?
Download ZIP
Raw
gistfile1.txt
# 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