openstack/deb-python-kafka
Code Issues Proposed changes

Lower logging level on replica not available and commit

Browse Source
This commit is contained in:
Enrico Canzonieri
2015-06-19 10:17:49 -07:00
parent 915a9ce0d1
commit f74d712adf
2 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
kafka/client.py
View File

@@ -409,7 +409,7 @@ class KafkaClient(object):
# this error code is provided for admin purposes only # this error code is provided for admin purposes only
# we never talk to replicas, only the leader # we never talk to replicas, only the leader
except ReplicaNotAvailableError: except ReplicaNotAvailableError:
log.warning('Some (non-leader) replicas not available for topic %s partition %d', topic, partition) log.debug('Some (non-leader) replicas not available for topic %s partition %d', topic, partition)
# If Known Broker, topic_partition -> BrokerMetadata # If Known Broker, topic_partition -> BrokerMetadata
if leader in self.brokers: if leader in self.brokers:

2
kafka/consumer/base.py
View File

@@ -138,7 +138,7 @@ class Consumer(object):
if partitions is None: # commit all partitions if partitions is None: # commit all partitions
partitions = list(self.offsets.keys()) partitions = list(self.offsets.keys())
log.info('Committing new offsets for %s, partitions %s', log.debug('Committing new offsets for %s, partitions %s',
self.topic, partitions) self.topic, partitions)
for partition in partitions: for partition in partitions:
offset = self.offsets[partition] offset = self.offsets[partition]