Skip to content
This repository has been archived by the owner on Mar 24, 2021. It is now read-only.

Commit

Permalink
non-code style nitpicks in message.py
Browse files Browse the repository at this point in the history
  • Loading branch information
emmettbutler committed Jul 30, 2018
1 parent 7535c63 commit 056ba50
Showing 1 changed file with 4 additions and 3 deletions.
7 changes: 4 additions & 3 deletions pykafka/protocol/message.py
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,8 @@
class Message(Message, Serializable):
"""Representation of a Kafka Message
NOTE: Compression is handled in the protocol because of the way Kafka embeds compressed MessageSets within Messages
NOTE: Compression is handled in the protocol because of the way Kafka embeds
compressed MessageSets within Messages
Specification::
Expand Down Expand Up @@ -176,7 +177,8 @@ class MessageSet(Serializable):
This isn't useful outside of direct communications with Kafka, so we
keep it hidden away here.
N.B.: MessageSets are not preceded by an int32 like other array elements in the protocol.
N.B.: MessageSets are not preceded by an int32 like other array elements in the
protocol.
Specification::
Expand Down Expand Up @@ -268,7 +270,6 @@ def decode(cls, buff, partition_id=-1):
message = Message.decode(buff[offset:offset + size],
msg_offset,
partition_id=partition_id)
# print '[%d] (%s) %s' % (message.offset, message.partition_key, message.value)
messages.append(message)
offset += size
if len(messages) == 0 and attempted:
Expand Down

0 comments on commit 056ba50

Please sign in to comment.