openstack/deb-python-kafka
Code Issues Proposed changes

Warn on 0.8.2 GroupCoordinator no-topic-quirk, dont raise exception

Browse Source
This commit is contained in:
Dana Powers
2016-01-23 23:27:17 -08:00
parent b52f17e18d
commit 80c3a76aa6
1 changed files with 5 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
kafka/conn.py
View File

@@ -305,9 +305,12 @@ class BrokerConnection(object):
# 0.8.2 quirk # 0.8.2 quirk
if (self.config['api_version'] == (0, 8, 2) and if (self.config['api_version'] == (0, 8, 2) and
ifr.response_type is GroupCoordinatorResponse and ifr.response_type is GroupCoordinatorResponse and
ifr.correlation_id != 0 and
recv_correlation_id == 0): recv_correlation_id == 0):
raise Errors.KafkaError( log.warning('Kafka 0.8.2 quirk -- GroupCoordinatorResponse'
'Kafka 0.8.2 quirk -- try creating a topic first') ' coorelation id does not match request. This'
' should go away once at least one topic has been'
' initialized on the broker')
elif ifr.correlation_id != recv_correlation_id: elif ifr.correlation_id != recv_correlation_id: