Skip to content

Instantly share code, notes, and snippets.

@dtheodor

dtheodor/README.md

Last active May 23, 2018 14:02
Show Gist options
  • Save dtheodor/26821f951502aab2e325f860b459cbfc to your computer and use it in GitHub Desktop.
Save dtheodor/26821f951502aab2e325f860b459cbfc to your computer and use it in GitHub Desktop.
Download ZIP
confluent-kafka-go Consumer.Close() hangs when having multiple consumers in the same process
Raw
README.md

confluent-kafka-go Consumer.Close() hangs

Consumer.Close() blocks indefinately when having multiple consumers in the same process that are consuming from the same topic and belong to the same consumer group

The go source code contains a minimal test case to reproduce

This is run with

  • Debian GNU/Linux 9.4 (stretch)
  • go version go1.10.1 linux/amd64
  • confluent-kafka-go release v0.11.4
  • librdkafka version 722175 0.11.4
  • kafka version 0.11.0.2
  • a kafka cluster of 2 nodes
  • topic created with --partitions 2 --replication-factor 2

Calling Consumer.Unassign() right before the Close() allows close to return correctly

Raw
debug_logs
%7|1527078926.572|MEMBERID|rdkafka#consumer-1| [thrd:app]: Group "testkafkagroup5": updating member id "(not-set)" -> ""
%7|1527078926.573|BRKREASSIGN|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5" management reassigned from broker (none) to :0/internal
%7|1527078926.573|CGRPSTATE|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5" changed state init -> wait-broker (v1, join-state init)
%7|1527078926.573|BRKASSIGN|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5" management assigned to broker :0/internal
%7|1527078926.573|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5" received op SUBSCRIBE (v0) in state wait-broker (join state init, v1 vs 0)
%7|1527078926.573|SUBSCRIBE|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": subscribe to new subscription of 1 topics (join state init)
%7|1527078926.573|UNSUBSCRIBE|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": unsubscribe from current unset subscription of 0 topics (leave group=no, join state init, v1)
%7|1527078926.573|GRPLEADER|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": resetting group leader info: unsubscribe
%7|1527078926.573|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5" changed join state init -> wait-unassign (v1, state wait-broker)
%7|1527078926.573|UNASSIGN|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": unassign done in state wait-broker (join state wait-unassign): without new assignment: unassign (no previous assignment)
%7|1527078926.573|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5" changed join state wait-unassign -> init (v1, state wait-broker)
rdkafka#consumer-1 reading a message...
%7|1527078926.573|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": no broker available for coordinator query: intervaled in state wait-broker
%7|1527078926.574|SUBSCRIPTION|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": no topics in metadata matched subscription
%7|1527078926.574|BRKREASSIGN|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5" management reassigned from broker :0/internal to kc1.docker:9092/1
%7|1527078926.574|BRKUNASSIGN|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5" management unassigned from broker handle :0/internal
%7|1527078926.574|BRKASSIGN|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5" management assigned to broker kc1.docker:9092/1
%7|1527078926.574|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: kc1.docker:9092/1: Group "testkafkagroup5": querying for coordinator: intervaled in state wait-broker
%7|1527078926.575|CGRPCOORD|rdkafka#consumer-1| [thrd:main]: kc1.docker:9092/1: Group "testkafkagroup5" coordinator is kc2.docker:9092 id 2
%7|1527078926.575|CGRPCOORD|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5" changing coordinator -1 -> 2
%7|1527078926.575|BRKREASSIGN|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5" management reassigned from broker kc1.docker:9092/1 to kc2.docker:9092/2
%7|1527078926.575|BRKUNASSIGN|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5" management unassigned from broker handle kc1.docker:9092/1
%7|1527078926.575|BRKASSIGN|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5" management assigned to broker kc2.docker:9092/2
%7|1527078926.575|CGRPSTATE|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5" changed state wait-broker -> wait-broker-transport (v1, join-state init)
%7|1527078926.575|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: kc1.docker:9092/1: Group "testkafkagroup5": querying for coordinator: intervaled in state wait-broker-transport
%7|1527078926.575|CGRPCOORD|rdkafka#consumer-1| [thrd:main]: kc1.docker:9092/1: Group "testkafkagroup5" coordinator is kc2.docker:9092 id 2
%7|1527078926.575|SUBSCRIPTION|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": no topics in metadata matched subscription
%7|1527078926.575|CGRPSTATE|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5" changed state wait-broker-transport -> up (v1, join-state init)
%7|1527078926.575|JOIN|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": join with 0 (1) subscribed topic(s)
%7|1527078926.575|CGRPMETADATA|rdkafka#consumer-1| [thrd:main]: consumer join: metadata for subscription only available for 0/1 topics (-1ms old)
%7|1527078926.576|JOIN|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": postponing join until up-to-date metadata is available
%7|1527078926.576|SUBSCRIPTION|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": effective subscription list changed from 0 to 1 topic(s):
%7|1527078926.576|SUBSCRIPTION|rdkafka#consumer-1| [thrd:main]: Topic testkafka3 with 2 partition(s)
%7|1527078926.576|REJOIN|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": subscription updated from metadata change: rejoining group
%7|1527078926.576|GRPLEADER|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": resetting group leader info: Group rejoin
%7|1527078926.576|REJOIN|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5" rejoining in join-state init without an assignment
%7|1527078926.576|JOIN|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": join with 1 (1) subscribed topic(s)
%7|1527078926.576|CGRPMETADATA|rdkafka#consumer-1| [thrd:main]: consumer join: metadata for subscription is up to date (0ms old)
%7|1527078926.576|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5" changed join state init -> wait-join (v1, state up)
%7|1527078926.577|JOINGROUP|rdkafka#consumer-1| [thrd:main]: JoinGroup response: GenerationId 14, Protocol range, LeaderId rdkafka-e6fbe016-ac98-48b9-a5e0-de44b0c21ac8 (me), my MemberId rdkafka-e6fbe016-ac98-48b9-a5e0-de44b0c21ac8, 1 members in group: (no error)
%7|1527078926.577|MEMBERID|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": updating member id "" -> "rdkafka-e6fbe016-ac98-48b9-a5e0-de44b0c21ac8"
%7|1527078926.577|JOINGROUP|rdkafka#consumer-1| [thrd:main]: Elected leader for group "testkafkagroup5" with 1 member(s)
%7|1527078926.577|GRPLEADER|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": resetting group leader info: JoinGroup response clean-up
%7|1527078926.577|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5" changed join state wait-join -> wait-metadata (v1, state up)
%7|1527078926.578|ASSIGN|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5" running range assignment for 1 member(s):
%7|1527078926.578|ASSIGN|rdkafka#consumer-1| [thrd:main]: Member "rdkafka-e6fbe016-ac98-48b9-a5e0-de44b0c21ac8" (me) with 1 subscription(s):
%7|1527078926.579|ASSIGN|rdkafka#consumer-1| [thrd:main]: testkafka3 [-1]
%7|1527078926.579|ASSIGN|rdkafka#consumer-1| [thrd:main]: range: Topic testkafka3 with 2 partition(s) and 1 subscribing member(s)
%7|1527078926.579|ASSIGN|rdkafka#consumer-1| [thrd:main]: range: Member "rdkafka-e6fbe016-ac98-48b9-a5e0-de44b0c21ac8": assigned topic testkafka3 partitions 0..1
%7|1527078926.579|ASSIGN|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5" range assignment for 1 member(s) finished in 0.480ms:
%7|1527078926.579|ASSIGN|rdkafka#consumer-1| [thrd:main]: Member "rdkafka-e6fbe016-ac98-48b9-a5e0-de44b0c21ac8" (me) assigned 2 partition(s):
%7|1527078926.579|ASSIGN|rdkafka#consumer-1| [thrd:main]: testkafka3 [0]
%7|1527078926.579|ASSIGN|rdkafka#consumer-1| [thrd:main]: testkafka3 [1]
%7|1527078926.579|ASSIGNOR|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": "range" assignor run for 1 member(s)
%7|1527078926.579|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5" changed join state wait-metadata -> wait-sync (v1, state up)
%7|1527078926.579|SYNCGROUP|rdkafka#consumer-1| [thrd:main]: SyncGroup response: Success (34 bytes of MemberState data)
%7|1527078926.580|ASSIGN|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": delegating assign of 2 partition(s) to application rebalance callback on queue rd_kafka_cgrp_new: new assignment
%7|1527078926.580|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5" changed join state wait-sync -> wait-assign-rebalance_cb (v1, state up)
%7|1527078926.580|HEARTBEAT|rdkafka#consumer-1| [thrd:main]: kc2.docker:9092/2: Heartbeat for group "testkafkagroup5" generation id 14
%7|1527078926.580|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5" received op ASSIGN (v0) in state up (join state wait-assign-rebalance_cb, v1 vs 0)
%7|1527078926.580|ASSIGN|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": new assignment of 2 partition(s) in join state wait-assign-rebalance_cb
%7|1527078926.580|BARRIER|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": rd_kafka_cgrp_assign:2299: new version barrier v2
%7|1527078926.580|ASSIGN|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": assigning 2 partition(s) in join state wait-assign-rebalance_cb
%7|1527078926.580|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5" changed join state wait-assign-rebalance_cb -> assigned (v2, state up)
%7|1527078926.580|BARRIER|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": rd_kafka_cgrp_partitions_fetch_start0:1640: new version barrier v3
%7|1527078926.580|FETCHSTART|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": starting fetchers for 2 assigned partition(s) in join-state assigned (usable_offsets=no, v3, line 2344)
%7|1527078926.580|FETCHSTART|rdkafka#consumer-1| [thrd:main]: List with 2 partition(s):
%7|1527078926.580|FETCHSTART|rdkafka#consumer-1| [thrd:main]: testkafka3 [0] offset INVALID
%7|1527078926.580|FETCHSTART|rdkafka#consumer-1| [thrd:main]: testkafka3 [1] offset INVALID
%7|1527078926.580|OFFSET|rdkafka#consumer-1| [thrd:main]: kc2.docker:9092/2: Fetch committed offsets for 2/2 partition(s)
%7|1527078926.580|OFFSETFETCH|rdkafka#consumer-1| [thrd:main]: List with 2 partition(s):
%7|1527078926.580|OFFSETFETCH|rdkafka#consumer-1| [thrd:main]: testkafka3 [0] offset INVALID
%7|1527078926.580|OFFSETFETCH|rdkafka#consumer-1| [thrd:main]: testkafka3 [1] offset INVALID
%7|1527078926.580|OFFSET|rdkafka#consumer-1| [thrd:main]: Topic testkafka3 [0]: setting default offset INVALID
%7|1527078926.580|OFFSET|rdkafka#consumer-1| [thrd:main]: Topic testkafka3 [1]: setting default offset INVALID
%7|1527078926.580|BARRIER|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": rd_kafka_cgrp_partitions_fetch_start0:1640: new version barrier v4
%7|1527078926.580|FETCHSTART|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": starting fetchers for 2 assigned partition(s) in join-state assigned (usable_offsets=yes, v4, line 1572)
%7|1527078926.580|FETCHSTART|rdkafka#consumer-1| [thrd:main]: List with 2 partition(s):
%7|1527078926.580|FETCHSTART|rdkafka#consumer-1| [thrd:main]: testkafka3 [0] offset INVALID
%7|1527078926.580|FETCHSTART|rdkafka#consumer-1| [thrd:main]: testkafka3 [1] offset 10
%7|1527078926.580|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5" changed join state assigned -> started (v4, state up)
%7|1527078926.581|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5" received op PARTITION_JOIN in state up (join state started, v4) for testkafka3 [0]
%7|1527078926.581|PARTADD|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": add testkafka3 [0]
%7|1527078926.581|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5" received op PARTITION_JOIN in state up (join state started, v4) for testkafka3 [1]
%7|1527078926.581|PARTADD|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": add testkafka3 [1]
%7|1527078926.582|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5" received op OFFSET_COMMIT (v0) in state up (join state started, v4 vs 0)
%7|1527078926.582|OFFSET|rdkafka#consumer-1| [thrd:main]: Topic testkafka3 [0]: stored offset 1, committed offset -1001
%7|1527078926.582|OFFSET|rdkafka#consumer-1| [thrd:main]: Topic testkafka3 [0]: setting stored offset 1 for commit
%7|1527078926.582|OFFSET|rdkafka#consumer-1| [thrd:main]: Topic testkafka3 [1]: stored offset -1001, committed offset 10
%7|1527078926.582|OFFSET|rdkafka#consumer-1| [thrd:main]: Topic testkafka3 [1]: setting offset INVALID for commit
%7|1527078926.685|COMMIT|rdkafka#consumer-1| [thrd:main]: kc2.docker:9092/2: OffsetCommit for 2 partition(s): manual: returned: Success
%7|1527078926.685|COMMIT|rdkafka#consumer-1| [thrd:main]: All commited, call fetch_start.
%7|1527078926.685|MEMBERID|rdkafka#consumer-2| [thrd:app]: Group "testkafkagroup5": updating member id "(not-set)" -> ""
%7|1527078926.686|BRKREASSIGN|rdkafka#consumer-2| [thrd:main]: Group "testkafkagroup5" management reassigned from broker (none) to :0/internal
%7|1527078926.686|CGRPSTATE|rdkafka#consumer-2| [thrd:main]: Group "testkafkagroup5" changed state init -> wait-broker (v1, join-state init)
%7|1527078926.686|BRKASSIGN|rdkafka#consumer-2| [thrd:main]: Group "testkafkagroup5" management assigned to broker :0/internal
%7|1527078926.686|CGRPOP|rdkafka#consumer-2| [thrd:main]: Group "testkafkagroup5" received op SUBSCRIBE (v0) in state wait-broker (join state init, v1 vs 0)
%7|1527078926.686|SUBSCRIBE|rdkafka#consumer-2| [thrd:main]: Group "testkafkagroup5": subscribe to new subscription of 1 topics (join state init)
%7|1527078926.686|UNSUBSCRIBE|rdkafka#consumer-2| [thrd:main]: Group "testkafkagroup5": unsubscribe from current unset subscription of 0 topics (leave group=no, join state init, v1)
%7|1527078926.686|GRPLEADER|rdkafka#consumer-2| [thrd:main]: Group "testkafkagroup5": resetting group leader info: unsubscribe
%7|1527078926.686|CGRPJOINSTATE|rdkafka#consumer-2| [thrd:main]: Group "testkafkagroup5" changed join state init -> wait-unassign (v1, state wait-broker)
%7|1527078926.686|UNASSIGN|rdkafka#consumer-2| [thrd:main]: Group "testkafkagroup5": unassign done in state wait-broker (join state wait-unassign): without new assignment: unassign (no previous assignment)
%7|1527078926.686|CGRPJOINSTATE|rdkafka#consumer-2| [thrd:main]: Group "testkafkagroup5" changed join state wait-unassign -> init (v1, state wait-broker)
rdkafka#consumer-2 reading a message...
%7|1527078926.686|CGRPQUERY|rdkafka#consumer-2| [thrd:main]: Group "testkafkagroup5": no broker available for coordinator query: intervaled in state wait-broker
%7|1527078926.691|SUBSCRIPTION|rdkafka#consumer-2| [thrd:main]: Group "testkafkagroup5": no topics in metadata matched subscription
%7|1527078926.691|BRKREASSIGN|rdkafka#consumer-2| [thrd:main]: Group "testkafkagroup5" management reassigned from broker :0/internal to kc1.docker:9092/1
%7|1527078926.691|BRKUNASSIGN|rdkafka#consumer-2| [thrd:main]: Group "testkafkagroup5" management unassigned from broker handle :0/internal
%7|1527078926.691|BRKASSIGN|rdkafka#consumer-2| [thrd:main]: Group "testkafkagroup5" management assigned to broker kc1.docker:9092/1
%7|1527078926.691|CGRPQUERY|rdkafka#consumer-2| [thrd:main]: kc1.docker:9092/1: Group "testkafkagroup5": querying for coordinator: intervaled in state wait-broker
%7|1527078926.693|CGRPCOORD|rdkafka#consumer-2| [thrd:main]: kc1.docker:9092/1: Group "testkafkagroup5" coordinator is kc2.docker:9092 id 2
%7|1527078926.693|CGRPCOORD|rdkafka#consumer-2| [thrd:main]: Group "testkafkagroup5" changing coordinator -1 -> 2
%7|1527078926.693|BRKREASSIGN|rdkafka#consumer-2| [thrd:main]: Group "testkafkagroup5" management reassigned from broker kc1.docker:9092/1 to kc2.docker:9092/2
%7|1527078926.693|BRKUNASSIGN|rdkafka#consumer-2| [thrd:main]: Group "testkafkagroup5" management unassigned from broker handle kc1.docker:9092/1
%7|1527078926.693|BRKASSIGN|rdkafka#consumer-2| [thrd:main]: Group "testkafkagroup5" management assigned to broker kc2.docker:9092/2
%7|1527078926.693|CGRPSTATE|rdkafka#consumer-2| [thrd:main]: Group "testkafkagroup5" changed state wait-broker -> wait-broker-transport (v1, join-state init)
%7|1527078926.693|CGRPQUERY|rdkafka#consumer-2| [thrd:main]: kc1.docker:9092/1: Group "testkafkagroup5": querying for coordinator: intervaled in state wait-broker-transport
%7|1527078926.694|CGRPCOORD|rdkafka#consumer-2| [thrd:main]: kc1.docker:9092/1: Group "testkafkagroup5" coordinator is kc2.docker:9092 id 2
%7|1527078926.694|CGRPSTATE|rdkafka#consumer-2| [thrd:main]: Group "testkafkagroup5" changed state wait-broker-transport -> up (v1, join-state init)
%7|1527078926.694|JOIN|rdkafka#consumer-2| [thrd:main]: Group "testkafkagroup5": join with 0 (1) subscribed topic(s)
%7|1527078926.694|CGRPMETADATA|rdkafka#consumer-2| [thrd:main]: consumer join: metadata for subscription only available for 0/1 topics (-1ms old)
%7|1527078926.694|JOIN|rdkafka#consumer-2| [thrd:main]: Group "testkafkagroup5": postponing join until up-to-date metadata is available
%7|1527078926.695|SUBSCRIPTION|rdkafka#consumer-2| [thrd:main]: Group "testkafkagroup5": no topics in metadata matched subscription
%7|1527078926.695|SUBSCRIPTION|rdkafka#consumer-2| [thrd:main]: Group "testkafkagroup5": effective subscription list changed from 0 to 1 topic(s):
%7|1527078926.695|SUBSCRIPTION|rdkafka#consumer-2| [thrd:main]: Topic testkafka3 with 2 partition(s)
%7|1527078926.695|REJOIN|rdkafka#consumer-2| [thrd:main]: Group "testkafkagroup5": subscription updated from metadata change: rejoining group
%7|1527078926.695|GRPLEADER|rdkafka#consumer-2| [thrd:main]: Group "testkafkagroup5": resetting group leader info: Group rejoin
%7|1527078926.695|REJOIN|rdkafka#consumer-2| [thrd:main]: Group "testkafkagroup5" rejoining in join-state init without an assignment
%7|1527078926.695|JOIN|rdkafka#consumer-2| [thrd:main]: Group "testkafkagroup5": join with 1 (1) subscribed topic(s)
%7|1527078926.695|CGRPMETADATA|rdkafka#consumer-2| [thrd:main]: consumer join: metadata for subscription is up to date (0ms old)
%7|1527078926.695|CGRPJOINSTATE|rdkafka#consumer-2| [thrd:main]: Group "testkafkagroup5" changed join state init -> wait-join (v1, state up)
%7|1527078928.572|HEARTBEAT|rdkafka#consumer-1| [thrd:main]: kc2.docker:9092/2: Heartbeat for group "testkafkagroup5" generation id 14
%7|1527078928.628|HEARTBEAT|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5" heartbeat error response in state up (join state started, 2 partition(s) assigned): Broker: Group rebalance in progress
%7|1527078928.628|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5" changed join state started -> init (v4, state up)
%7|1527078928.628|ASSIGN|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": delegating revoke of 2 partition(s) to application rebalance callback on queue rd_kafka_cgrp_new: Broker: Group rebalance in progress
%7|1527078928.628|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5" changed join state init -> wait-revoke-rebalance_cb (v4, state up)
%7|1527078956.698|JOINGROUP|rdkafka#consumer-2| [thrd:main]: JoinGroup response: GenerationId 15, Protocol range, LeaderId rdkafka-fa37330f-0ca1-49d2-b08f-045d6bd14988 (me), my MemberId rdkafka-fa37330f-0ca1-49d2-b08f-045d6bd14988, 1 members in group: (no error)
%7|1527078956.698|MEMBERID|rdkafka#consumer-2| [thrd:main]: Group "testkafkagroup5": updating member id "" -> "rdkafka-fa37330f-0ca1-49d2-b08f-045d6bd14988"
%7|1527078956.698|JOINGROUP|rdkafka#consumer-2| [thrd:main]: Elected leader for group "testkafkagroup5" with 1 member(s)
%7|1527078956.698|GRPLEADER|rdkafka#consumer-2| [thrd:main]: Group "testkafkagroup5": resetting group leader info: JoinGroup response clean-up
%7|1527078956.698|CGRPJOINSTATE|rdkafka#consumer-2| [thrd:main]: Group "testkafkagroup5" changed join state wait-join -> wait-metadata (v1, state up)
%7|1527078956.698|ASSIGN|rdkafka#consumer-2| [thrd:main]: Group "testkafkagroup5" running range assignment for 1 member(s):
%7|1527078956.698|ASSIGN|rdkafka#consumer-2| [thrd:main]: Member "rdkafka-fa37330f-0ca1-49d2-b08f-045d6bd14988" (me) with 1 subscription(s):
%7|1527078956.698|ASSIGN|rdkafka#consumer-2| [thrd:main]: testkafka3 [-1]
%7|1527078956.698|ASSIGN|rdkafka#consumer-2| [thrd:main]: range: Topic testkafka3 with 2 partition(s) and 1 subscribing member(s)
%7|1527078956.698|ASSIGN|rdkafka#consumer-2| [thrd:main]: range: Member "rdkafka-fa37330f-0ca1-49d2-b08f-045d6bd14988": assigned topic testkafka3 partitions 0..1
%7|1527078956.698|ASSIGN|rdkafka#consumer-2| [thrd:main]: Group "testkafkagroup5" range assignment for 1 member(s) finished in 0.018ms:
%7|1527078956.698|ASSIGN|rdkafka#consumer-2| [thrd:main]: Member "rdkafka-fa37330f-0ca1-49d2-b08f-045d6bd14988" (me) assigned 2 partition(s):
%7|1527078956.698|ASSIGN|rdkafka#consumer-2| [thrd:main]: testkafka3 [0]
%7|1527078956.698|ASSIGN|rdkafka#consumer-2| [thrd:main]: testkafka3 [1]
%7|1527078956.698|ASSIGNOR|rdkafka#consumer-2| [thrd:main]: Group "testkafkagroup5": "range" assignor run for 1 member(s)
%7|1527078956.698|CGRPJOINSTATE|rdkafka#consumer-2| [thrd:main]: Group "testkafkagroup5" changed join state wait-metadata -> wait-sync (v1, state up)
%7|1527078956.701|SYNCGROUP|rdkafka#consumer-2| [thrd:main]: SyncGroup response: Success (34 bytes of MemberState data)
%7|1527078956.701|ASSIGN|rdkafka#consumer-2| [thrd:main]: Group "testkafkagroup5": delegating assign of 2 partition(s) to application rebalance callback on queue rd_kafka_cgrp_new: new assignment
%7|1527078956.701|CGRPJOINSTATE|rdkafka#consumer-2| [thrd:main]: Group "testkafkagroup5" changed join state wait-sync -> wait-assign-rebalance_cb (v1, state up)
%7|1527078956.701|HEARTBEAT|rdkafka#consumer-2| [thrd:main]: kc2.docker:9092/2: Heartbeat for group "testkafkagroup5" generation id 15
%7|1527078956.701|CGRPOP|rdkafka#consumer-2| [thrd:main]: Group "testkafkagroup5" received op ASSIGN (v0) in state up (join state wait-assign-rebalance_cb, v1 vs 0)
%7|1527078956.701|ASSIGN|rdkafka#consumer-2| [thrd:main]: Group "testkafkagroup5": new assignment of 2 partition(s) in join state wait-assign-rebalance_cb
%7|1527078956.701|BARRIER|rdkafka#consumer-2| [thrd:main]: Group "testkafkagroup5": rd_kafka_cgrp_assign:2299: new version barrier v2
%7|1527078956.701|ASSIGN|rdkafka#consumer-2| [thrd:main]: Group "testkafkagroup5": assigning 2 partition(s) in join state wait-assign-rebalance_cb
%7|1527078956.701|CGRPJOINSTATE|rdkafka#consumer-2| [thrd:main]: Group "testkafkagroup5" changed join state wait-assign-rebalance_cb -> assigned (v2, state up)
%7|1527078956.701|BARRIER|rdkafka#consumer-2| [thrd:main]: Group "testkafkagroup5": rd_kafka_cgrp_partitions_fetch_start0:1640: new version barrier v3
%7|1527078956.701|FETCHSTART|rdkafka#consumer-2| [thrd:main]: Group "testkafkagroup5": starting fetchers for 2 assigned partition(s) in join-state assigned (usable_offsets=no, v3, line 2344)
%7|1527078956.701|FETCHSTART|rdkafka#consumer-2| [thrd:main]: List with 2 partition(s):
%7|1527078956.701|FETCHSTART|rdkafka#consumer-2| [thrd:main]: testkafka3 [0] offset INVALID
%7|1527078956.701|FETCHSTART|rdkafka#consumer-2| [thrd:main]: testkafka3 [1] offset INVALID
%7|1527078956.701|OFFSET|rdkafka#consumer-2| [thrd:main]: kc2.docker:9092/2: Fetch committed offsets for 2/2 partition(s)
%7|1527078956.703|OFFSETFETCH|rdkafka#consumer-2| [thrd:main]: List with 2 partition(s):
%7|1527078956.703|OFFSETFETCH|rdkafka#consumer-2| [thrd:main]: testkafka3 [0] offset INVALID
%7|1527078956.703|OFFSETFETCH|rdkafka#consumer-2| [thrd:main]: testkafka3 [1] offset INVALID
%7|1527078956.703|OFFSET|rdkafka#consumer-2| [thrd:main]: Topic testkafka3 [0]: setting default offset INVALID
%7|1527078956.703|OFFSET|rdkafka#consumer-2| [thrd:main]: Topic testkafka3 [1]: setting default offset INVALID
%7|1527078956.703|BARRIER|rdkafka#consumer-2| [thrd:main]: Group "testkafkagroup5": rd_kafka_cgrp_partitions_fetch_start0:1640: new version barrier v4
%7|1527078956.703|FETCHSTART|rdkafka#consumer-2| [thrd:main]: Group "testkafkagroup5": starting fetchers for 2 assigned partition(s) in join-state assigned (usable_offsets=yes, v4, line 1572)
%7|1527078956.703|FETCHSTART|rdkafka#consumer-2| [thrd:main]: List with 2 partition(s):
%7|1527078956.703|FETCHSTART|rdkafka#consumer-2| [thrd:main]: testkafka3 [0] offset 1
%7|1527078956.703|FETCHSTART|rdkafka#consumer-2| [thrd:main]: testkafka3 [1] offset 10
%7|1527078956.703|CGRPJOINSTATE|rdkafka#consumer-2| [thrd:main]: Group "testkafkagroup5" changed join state assigned -> started (v4, state up)
%7|1527078956.703|CGRPOP|rdkafka#consumer-2| [thrd:main]: Group "testkafkagroup5" received op PARTITION_JOIN in state up (join state started, v4) for testkafka3 [0]
%7|1527078956.703|PARTADD|rdkafka#consumer-2| [thrd:main]: Group "testkafkagroup5": add testkafka3 [0]
%7|1527078956.703|CGRPOP|rdkafka#consumer-2| [thrd:main]: Group "testkafkagroup5" received op PARTITION_JOIN in state up (join state started, v4) for testkafka3 [1]
%7|1527078956.703|PARTADD|rdkafka#consumer-2| [thrd:main]: Group "testkafkagroup5": add testkafka3 [1]
%7|1527078956.704|CGRPOP|rdkafka#consumer-2| [thrd:main]: Group "testkafkagroup5" received op OFFSET_COMMIT (v0) in state up (join state started, v4 vs 0)
%7|1527078956.704|OFFSET|rdkafka#consumer-2| [thrd:main]: Topic testkafka3 [0]: stored offset -1001, committed offset 1
%7|1527078956.704|OFFSET|rdkafka#consumer-2| [thrd:main]: Topic testkafka3 [0]: setting offset INVALID for commit
%7|1527078956.704|OFFSET|rdkafka#consumer-2| [thrd:main]: Topic testkafka3 [1]: stored offset 11, committed offset 10
%7|1527078956.704|OFFSET|rdkafka#consumer-2| [thrd:main]: Topic testkafka3 [1]: setting stored offset 11 for commit
%7|1527078956.807|COMMIT|rdkafka#consumer-2| [thrd:main]: kc2.docker:9092/2: OffsetCommit for 2 partition(s): manual: returned: Success
%7|1527078956.807|COMMIT|rdkafka#consumer-2| [thrd:main]: All commited, call fetch_start.
rdkafka#consumer-1 closing now...
%7|1527078956.807|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5" received op TERMINATE (v0) in state up (join state wait-revoke-rebalance_cb, v4 vs 0)
%7|1527078956.807|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Terminating group "testkafkagroup5" in state up with 2 partition(s)
%7|1527078956.807|UNSUBSCRIBE|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": unsubscribe from current subscription of 1 topics (leave group=yes, join state wait-revoke-rebalance_cb, v4)
%7|1527078956.807|SUBSCRIPTION|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": clearing subscribed topics list (1)
%7|1527078956.807|SUBSCRIPTION|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": effective subscription list changed from 1 to 0 topic(s):
%7|1527078956.807|GRPLEADER|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": resetting group leader info: unsubscribe
%7|1527078956.807|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078956.807|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078957.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078958.686|HEARTBEAT|rdkafka#consumer-2| [thrd:main]: kc2.docker:9092/2: Heartbeat for group "testkafkagroup5" generation id 15
%7|1527078958.705|HEARTBEAT|rdkafka#consumer-2| [thrd:main]: Group "testkafkagroup5" heartbeat error response in state up (join state started, 2 partition(s) assigned): Broker: Group rebalance in progress
%7|1527078958.705|CGRPJOINSTATE|rdkafka#consumer-2| [thrd:main]: Group "testkafkagroup5" changed join state started -> init (v4, state up)
%7|1527078958.705|ASSIGN|rdkafka#consumer-2| [thrd:main]: Group "testkafkagroup5": delegating revoke of 2 partition(s) to application rebalance callback on queue rd_kafka_cgrp_new: Broker: Group rebalance in progress
%7|1527078958.705|CGRPJOINSTATE|rdkafka#consumer-2| [thrd:main]: Group "testkafkagroup5" changed join state init -> wait-revoke-rebalance_cb (v4, state up)
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.574|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
%7|1527078959.575|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "testkafkagroup5": waiting for rebalance_cb, 2 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
Raw
main.go
package main
import (
"fmt"
"github.com/confluentinc/confluent-kafka-go/kafka"
)
const (
server = "kc1.docker"
topic = "testkafka3"
consumerGroup = "testkafkagroup5"
)
func panicIfErr(err error) {
if err != nil {
panic(err)
}
}
func main() {
cfg1 := kafka.ConfigMap{
"bootstrap.servers": server,
"group.id": consumerGroup,
"auto.offset.reset": "earliest",
"enable.auto.commit": false,
// "debug": "cgrp",
}
cfg2 := cfg1
c1, err := kafka.NewConsumer(&cfg1)
panicIfErr(err)
err = c1.Subscribe(topic, nil)
panicIfErr(err)
fmt.Println(c1, "reading a message...")
_, err = c1.ReadMessage(-1)
panicIfErr(err)
_, err = c1.Commit()
panicIfErr(err)
c2, err := kafka.NewConsumer(&cfg2)
panicIfErr(err)
err = c2.Subscribe(topic, nil)
panicIfErr(err)
fmt.Println(c2, "reading a message...")
_, err = c2.ReadMessage(-1)
panicIfErr(err)
_, err = c2.Commit()
panicIfErr(err)
fmt.Println(c1, "closing now...")
err = c1.Close()
// HANGS HERE
panicIfErr(err)
fmt.Println(c1, "this will never run")
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment