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 /test/test_consumer_group.py | |
| parent | 1eaad6fcbef499c522f45361972e7ee9e8a78909 (diff) | |
| download | kafka-python-8ae2a3073134ff58f1314bf64165456a8e627b0a.tar.gz | |
Log generation and member_id in threaded consumer group test
Diffstat (limited to 'test/test_consumer_group.py')
| -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" |