diff options
author | Dana Powers <dana.powers@rd.io> | 2016-01-10 16:14:30 -0800 |
---|---|---|
committer | Dana Powers <dana.powers@rd.io> | 2016-01-10 16:34:08 -0800 |
commit | 8ae2a3073134ff58f1314bf64165456a8e627b0a (patch) | |
tree | 3fb7ec198e3c4eb3b05daed9a1c7dc69fc6b04e7 | |
parent | 1eaad6fcbef499c522f45361972e7ee9e8a78909 (diff) | |
download | kafka-python-8ae2a3073134ff58f1314bf64165456a8e627b0a.tar.gz |
Log generation and member_id in threaded consumer group test
-rw-r--r-- | test/test_consumer_group.py | 5 |
1 files changed, 4 insertions, 1 deletions
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" |