openstack/deb-python-kafka
Code Issues Proposed changes

change comments in order to trigger a travis build

Browse Source
This commit is contained in:
Lars Jørgen Solberg
2016-07-25 09:06:35 +00:00
committed by Dana Powers
parent 2925c33799
commit 2ebf9133ef
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
kafka/conn.py
View File

@@ -294,7 +294,7 @@ class BrokerConnection(object):
if self.config['security_protocol'] == 'SASL_PLAINTEXT':
log.warning('%s: Sending username and password in the clear', str(self))
# build a SaslHandShakeRequest message
# Build a SaslHandShakeRequest message
correlation_id = self._next_correlation_id()
request = SaslHandShakeRequest[0](self.config['sasl_mechanism'])
header = RequestHeader(request,
@@ -304,7 +304,7 @@ class BrokerConnection(object):
message = b''.join([header.encode(), request.encode()])
size = Int32.encode(len(message))
# attempt to send it over our socket
# Attempt to send it over our socket
try:
self._sock.setblocking(True)
self._sock.sendall(size + message)
@@ -323,7 +323,7 @@ class BrokerConnection(object):
timestamp=time.time())
self.in_flight_requests.append(ifr)
# listen for a reply and check that the server supports the PLAIN mechanism
# Listen for a reply and check that the server supports the PLAIN mechanism
response = None
while not response:
response = self.recv()
@@ -340,7 +340,7 @@ class BrokerConnection(object):
data = b''
try:
self._sock.setblocking(True)
# send our credentials
# Send our credentials
msg = bytes('\0'.join([self.config['sasl_username'],
self.config['sasl_username'],
self.config['sasl_password']]).encode('utf-8'))