From 8ae2a3073134ff58f1314bf64165456a8e627b0a Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Sun, 10 Jan 2016 16:14:30 -0800 Subject: Log generation and member_id in threaded consumer group test --- test/test_consumer_group.py | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) 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" -- cgit v1.2.1