diff options
| -rw-r--r-- | kafka/consumer/fetcher.py | 2 | ||||
| -rw-r--r-- | test/test_consumer_group.py | 5 |
2 files changed, 5 insertions, 2 deletions
diff --git a/kafka/consumer/fetcher.py b/kafka/consumer/fetcher.py index dfbb0d6..eb85060 100644 --- a/kafka/consumer/fetcher.py +++ b/kafka/consumer/fetcher.py @@ -496,7 +496,7 @@ class Fetcher(six.Iterator): self.config['max_partition_fetch_bytes'] ) fetchable[node_id][partition.topic].append(partition_info) - log.debug("Adding fetch request for partition %d at offset %d", + log.debug("Adding fetch request for partition %s at offset %d", partition, position) requests = {} diff --git a/test/test_consumer_group.py b/test/test_consumer_group.py index 6160372..035d65a 100644 --- a/test/test_consumer_group.py +++ b/test/test_consumer_group.py @@ -116,7 +116,10 @@ def test_group(kafka_broker, topic): break else: for c in range(num_consumers): - logging.info("%s: %s", c, consumers[c].assignment()) + logging.info("[%s] %s %s: %s", c, + consumers[c]._coordinator.generation, + consumers[c]._coordinator.member_id, + consumers[c].assignment()) break assert time.time() < timeout, "timeout waiting for assignments" |