openstack/deb-python-kafka
Code Issues Proposed changes

Adding a debug statement

Browse Source
This commit is contained in:
David Arthur
2013-04-12 14:18:29 -04:00
parent 904157ba2c
commit bf8fc04a9f
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
kafka/conn.py
View File

@@ -71,7 +71,7 @@ class KafkaConnection(object):
def send(self, requestId, payload): def send(self, requestId, payload):
"Send a request to Kafka" "Send a request to Kafka"
log.debug("About to send %d bytes to Kafka" % len(payload)) log.debug("About to send %d bytes to Kafka, request %d" % (len(payload), requestId))
sent = self._sock.sendall(payload) sent = self._sock.sendall(payload)
if sent != None: if sent != None:
raise RuntimeError("Kafka went away") raise RuntimeError("Kafka went away")
@@ -79,6 +79,7 @@ class KafkaConnection(object):
def recv(self, requestId): def recv(self, requestId):
"Get a response from Kafka" "Get a response from Kafka"
log.debug("Reading response %d from Kafka" % requestId)
return self.data return self.data
def close(self): def close(self):