TPL
DEBUG:rdkafka::client: librdkafka: CGRPOP [thrd:main]: Group "GROUP1" received op GET_ASSIGNMENT (v0) in state up (join state started, v4 vs 0)
DEBUG:rdkafka::client: librdkafka: HEARTBEAT [thrd:main]: fede-linux:9092/0: Heartbeat for group "GROUP1" generation id 1
DEBUG:rdkafka::client: librdkafka: OFFSET [thrd:app]: fede-linux:9092/0: OffsetRequest (v1, opv 0) for 1 topic(s) and 3 partition(s)
TPL DONE
DEBUG:rdkafka::client: librdkafka: CGRPOP [thrd:main]: Group "GROUP1" received op TERMINATE (v0) in state up (join state started, v4 vs 0)
DEBUG:rdkafka::client: librdkafka: CGRPTERM [thrd:main]: Terminating group "GROUP1" in state up with 3 partition(s)
DEBUG:rdkafka::client: librdkafka: UNSUBSCRIBE [thrd:main]: Group "GROUP1": unsubscribe from current subscription of 1 topics (leave group=yes, join state started, v4)
DEBUG:rdkafka::client: librdkafka: SUBSCRIPTION [thrd:main]: Group "GROUP1": clearing subscribed topics list (1)
DEBUG:rdkafka::client: librdkafka: SUBSCRIPTION [thrd:main]: Group "GROUP1": effective subscription list changed from 1 to 0 topic(s):
DEBUG:rdkafka::client: librdkafka: PAUSE [thrd:main]: Library pausing 3 partition(s)
DEBUG:rdkafka::client: librdkafka: BARRIER [thrd:main]: TOPIC [0]: rd_kafka_toppar_op_pause_resume:2139: new version barrier v3
DEBUG:rdkafka::client: librdkafka: PAUSE [thrd:main]: Pause TOPIC [0] (v3)
DEBUG:rdkafka::client: librdkafka: BARRIER [thrd:main]: TOPIC [1]: rd_kafka_toppar_op_pause_resume:2139: new version barrier v3
DEBUG:rdkafka::client: librdkafka: PAUSE [thrd:main]: Pause TOPIC [1] (v3)
DEBUG:rdkafka::client: librdkafka: BARRIER [thrd:main]: TOPIC [2]: rd_kafka_toppar_op_pause_resume:2139: new version barrier v3
DEBUG:rdkafka::client: librdkafka: PAUSE [thrd:main]: Pause TOPIC [2] (v3)
DEBUG:rdkafka::client: librdkafka: ASSIGN [thrd:main]: Group "GROUP1": delegating revoke of 3 partition(s) to application rebalance callback on queue rd_kafka_consumer_close: unsubscribe
DEBUG:rdkafka::client: librdkafka: CGRPJOINSTATE [thrd:main]: Group "GROUP1" changed join state started -> wait-revoke-rebalance_cb (v4, state up)
DEBUG:rdkafka::client: librdkafka: CGRPTERM [thrd:main]: Group "GROUP1": waiting for rebalance_cb, 3 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
DEBUG:rdkafka::client: librdkafka: CGRPTERM [thrd:main]: Group "GROUP1": waiting for rebalance_cb, 3 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
DEBUG:rdkafka::client: librdkafka: OP [thrd:main]: TOPIC [0] received op PAUSE (v3) in fetch-state active (opv2)
DEBUG:rdkafka::client: librdkafka: PAUSE [thrd:main]: Pause TOPIC [0]: at offset 3 (state active, v3)
DEBUG:rdkafka::client: librdkafka: OP [thrd:main]: TOPIC [1] received op PAUSE (v3) in fetch-state active (opv2)
DEBUG:rdkafka::client: librdkafka: PAUSE [thrd:main]: Pause TOPIC [1]: at offset INVALID (state active, v3)
DEBUG:rdkafka::client: librdkafka: OP [thrd:main]: TOPIC [2] received op PAUSE (v3) in fetch-state active (opv2)
DEBUG:rdkafka::client: librdkafka: PAUSE [thrd:main]: Pause TOPIC [2]: at offset INVALID (state active, v3)
DEBUG:rdkafka::client: librdkafka: CGRPTERM [thrd:main]: Group "GROUP1": waiting for rebalance_cb, 3 toppar(s), 0 unassignment(s), 0 commit(s), wait-unassign flag, (state up, join-state wait-revoke-rebalance_cb) before terminating
DEBUG:rdkafka::client: librdkafka: CGRPOP [thrd:main]: Group "GROUP1" received op ASSIGN (v0) in state up (join state wait-revoke-rebalance_cb, v4 vs 0)
DEBUG:rdkafka::client: librdkafka: CGRPJOINSTATE [thrd:main]: Group "GROUP1" changed join state wait-revoke-rebalance_cb -> wait-unassign (v4, state up)
DEBUG:rdkafka::client: librdkafka: BARRIER [thrd:main]: Group "GROUP1": rd_kafka_cgrp_unassign:2152: new version barrier v5
DEBUG:rdkafka::client: librdkafka: UNASSIGN [thrd:main]: Group "GROUP1": unassigning 3 partition(s) (v5)
DEBUG:rdkafka::client: librdkafka: BARRIER [thrd:main]: TOPIC [0]: rd_kafka_toppar_op_fetch_stop:2081: new version barrier v4
DEBUG:rdkafka::client: librdkafka: CONSUMER [thrd:main]: Stop consuming TOPIC [0] (v4)
DEBUG:rdkafka::client: librdkafka: DESP [thrd:main]: Removing (un)desired topic TOPIC [0]
DEBUG:rdkafka::client: librdkafka: BARRIER [thrd:main]: TOPIC [1]: rd_kafka_toppar_op_fetch_stop:2081: new version barrier v4
DEBUG:rdkafka::client: librdkafka: CONSUMER [thrd:main]: Stop consuming TOPIC [1] (v4)
DEBUG:rdkafka::client: librdkafka: DESP [thrd:main]: Removing (un)desired topic TOPIC [1]
DEBUG:rdkafka::client: librdkafka: BARRIER [thrd:main]: TOPIC [2]: rd_kafka_toppar_op_fetch_stop:2081: new version barrier v4
DEBUG:rdkafka::client: librdkafka: CONSUMER [thrd:main]: Stop consuming TOPIC [2] (v4)
DEBUG:rdkafka::client: librdkafka: DESP [thrd:main]: Removing (un)desired topic TOPIC [2]
DEBUG:rdkafka::client: librdkafka: RESUME [thrd:main]: Library resuming 3 partition(s)
DEBUG:rdkafka::client: librdkafka: BARRIER [thrd:main]: TOPIC [0]: rd_kafka_toppar_op_pause_resume:2139: new version barrier v5
DEBUG:rdkafka::client: librdkafka: RESUME [thrd:main]: Resume TOPIC [0] (v5)
DEBUG:rdkafka::client: librdkafka: BARRIER [thrd:main]: TOPIC [1]: rd_kafka_toppar_op_pause_resume:2139: new version barrier v5
DEBUG:rdkafka::client: librdkafka: RESUME [thrd:main]: Resume TOPIC [1] (v5)
DEBUG:rdkafka::client: librdkafka: BARRIER [thrd:main]: TOPIC [2]: rd_kafka_toppar_op_pause_resume:2139: new version barrier v5
DEBUG:rdkafka::client: librdkafka: RESUME [thrd:main]: Resume TOPIC [2] (v5)
DEBUG:rdkafka::client: librdkafka: UNASSIGN [thrd:main]: Unassign not done yet (3 wait_unassign, 3 assigned, 0 wait commit): unassign
DEBUG:rdkafka::client: librdkafka: CGRPTERM [thrd:main]: Group "GROUP1": waiting for 3 toppar(s), 3 unassignment(s), 0 commit(s) (state up, join-state wait-unassign) before terminating
DEBUG:rdkafka::client: librdkafka: OP [thrd:main]: TOPIC [0] received op FETCH_STOP (v4) in fetch-state active (opv3)
DEBUG:rdkafka::client: librdkafka: FETCH [thrd:main]: Stopping fetch for TOPIC [0] in state active (v4)
DEBUG:rdkafka::client: librdkafka: PARTSTATE [thrd:main]: Partition TOPIC [0] changed fetch state active -> stopping
DEBUG:rdkafka::client: librdkafka: STORETERM [thrd:main]: TOPIC [0]: offset store terminating
DEBUG:rdkafka::client: librdkafka: PARTSTATE [thrd:main]: Partition TOPIC [0] changed fetch state stopping -> stopped
DEBUG:rdkafka::client: librdkafka: OP [thrd:main]: TOPIC [1] received op FETCH_STOP (v4) in fetch-state active (opv3)
DEBUG:rdkafka::client: librdkafka: FETCH [thrd:main]: Stopping fetch for TOPIC [1] in state active (v4)
DEBUG:rdkafka::client: librdkafka: PARTSTATE [thrd:main]: Partition TOPIC [1] changed fetch state active -> stopping
DEBUG:rdkafka::client: librdkafka: STORETERM [thrd:main]: TOPIC [1]: offset store terminating
DEBUG:rdkafka::client: librdkafka: PARTSTATE [thrd:main]: Partition TOPIC [1] changed fetch state stopping -> stopped
DEBUG:rdkafka::client: librdkafka: OP [thrd:main]: TOPIC [2] received op FETCH_STOP (v4) in fetch-state active (opv3)
DEBUG:rdkafka::client: librdkafka: FETCH [thrd:main]: Stopping fetch for TOPIC [2] in state active (v4)
DEBUG:rdkafka::client: librdkafka: PARTSTATE [thrd:main]: Partition TOPIC [2] changed fetch state active -> stopping
DEBUG:rdkafka::client: librdkafka: STORETERM [thrd:main]: TOPIC [2]: offset store terminating
DEBUG:rdkafka::client: librdkafka: PARTSTATE [thrd:main]: Partition TOPIC [2] changed fetch state stopping -> stopped
DEBUG:rdkafka::client: librdkafka: OP [thrd:main]: TOPIC [0] received op PAUSE (v5) in fetch-state stopped (opv4)
DEBUG:rdkafka::client: librdkafka: RESUME [thrd:main]: Not resuming stopped TOPIC [0]: at offset 3 (state stopped, v5)
DEBUG:rdkafka::client: librdkafka: OP [thrd:main]: TOPIC [1] received op PAUSE (v5) in fetch-state stopped (opv4)
DEBUG:rdkafka::client: librdkafka: RESUME [thrd:main]: Not resuming stopped TOPIC [1]: at offset INVALID (state stopped, v5)
DEBUG:rdkafka::client: librdkafka: OP [thrd:main]: TOPIC [2] received op PAUSE (v5) in fetch-state stopped (opv4)
DEBUG:rdkafka::client: librdkafka: RESUME [thrd:main]: Not resuming stopped TOPIC [2]: at offset INVALID (state stopped, v5)
DEBUG:rdkafka::client: librdkafka: CGRPTERM [thrd:main]: Group "GROUP1": waiting for 3 toppar(s), 3 unassignment(s), 0 commit(s) (state up, join-state wait-unassign) before terminating
DEBUG:rdkafka::client: librdkafka: CGRPOP [thrd:main]: Group "GROUP1" received op PARTITION_LEAVE in state up (join state wait-unassign, v5) for TOPIC [0]
DEBUG:rdkafka::client: librdkafka: PARTDEL [thrd:main]: Group "GROUP1": delete TOPIC [0]
DEBUG:rdkafka::client: librdkafka: CGRPTERM [thrd:main]: Group "GROUP1": waiting for 2 toppar(s), 3 unassignment(s), 0 commit(s) (state up, join-state wait-unassign) before terminating
DEBUG:rdkafka::client: librdkafka: CGRPOP [thrd:main]: Group "GROUP1" received op REPLY:FETCH_STOP in state up (join state wait-unassign, v5) for TOPIC [0]
DEBUG:rdkafka::client: librdkafka: UNASSIGN [thrd:main]: Unassign not done yet (2 wait_unassign, 2 assigned, 0 wait commit): FETCH_STOP done
DEBUG:rdkafka::client: librdkafka: CGRPOP [thrd:main]: Group "GROUP1" received op PARTITION_LEAVE in state up (join state wait-unassign, v5) for TOPIC [1]
DEBUG:rdkafka::client: librdkafka: PARTDEL [thrd:main]: Group "GROUP1": delete TOPIC [1]
DEBUG:rdkafka::client: librdkafka: CGRPTERM [thrd:main]: Group "GROUP1": waiting for 1 toppar(s), 2 unassignment(s), 0 commit(s) (state up, join-state wait-unassign) before terminating
DEBUG:rdkafka::client: librdkafka: CGRPOP [thrd:main]: Group "GROUP1" received op REPLY:FETCH_STOP in state up (join state wait-unassign, v5) for TOPIC [1]
DEBUG:rdkafka::client: librdkafka: UNASSIGN [thrd:main]: Unassign not done yet (1 wait_unassign, 1 assigned, 0 wait commit): FETCH_STOP done
DEBUG:rdkafka::client: librdkafka: CGRPOP [thrd:main]: Group "GROUP1" received op PARTITION_LEAVE in state up (join state wait-unassign, v5) for TOPIC [2]
DEBUG:rdkafka::client: librdkafka: PARTDEL [thrd:main]: Group "GROUP1": delete TOPIC [2]
DEBUG:rdkafka::client: librdkafka: CGRPTERM [thrd:main]: Group "GROUP1": waiting for 0 toppar(s), 1 unassignment(s), 0 commit(s) (state up, join-state wait-unassign) before terminating
DEBUG:rdkafka::client: librdkafka: CGRPOP [thrd:main]: Group "GROUP1" received op REPLY:FETCH_STOP in state up (join state wait-unassign, v5) for TOPIC [2]
DEBUG:rdkafka::client: librdkafka: UNASSIGN [thrd:main]: Group "GROUP1": unassign done in state up (join state wait-unassign): without new assignment: FETCH_STOP done
DEBUG:rdkafka::client: librdkafka: LEAVE [thrd:main]: Group "GROUP1": leave
DEBUG:rdkafka::client: librdkafka: CGRPJOINSTATE [thrd:main]: Group "GROUP1" changed join state wait-unassign -> init (v5, state up)
DEBUG:rdkafka::client: librdkafka: CGRPSTATE [thrd:main]: Group "GROUP1" changed state up -> term (v5, join-state init)
DEBUG:rdkafka::client: librdkafka: FETCHADD [thrd:fede-linux:9092/0]: fede-linux:9092/0: Removed TOPIC [1] from fetch list (1 entries, opv 2)
DEBUG:rdkafka::client: librdkafka: BRKUNASSIGN [thrd:main]: Group "GROUP1" management unassigned from broker handle fede-linux:9092/0
DEBUG:rdkafka::client: librdkafka: FETCHADD [thrd:fede-linux:9092/0]: fede-linux:9092/0: Removed TOPIC [2] from fetch list (0 entries, opv 2)
DEBUG:rdkafka::client: librdkafka: DESTROY [thrd:app]: Terminating instance
DEBUG:rdkafka::client: librdkafka: DESTROY [thrd:main]: Destroy internal
DEBUG:rdkafka::client: librdkafka: DESTROY [thrd:main]: Removing all topics
DEBUG:rdkafka::client: librdkafka: PARTCNT [thrd:main]: Topic TOPIC partition count changed from 3 to 0
DEBUG:rdkafka::client: librdkafka: REMOVE [thrd:main]: TOPIC [0] no longer reported in metadata
DEBUG:rdkafka::client: librdkafka: BRKMIGR [thrd:main]: TOPIC [0] 0x7f45040027e0 sending final LEAVE for removal by fede-linux:9092/0
DEBUG:rdkafka::client: librdkafka: REMOVE [thrd:main]: TOPIC [1] no longer reported in metadata
DEBUG:rdkafka::client: librdkafka: TOPBRK [thrd:fede-linux:9092/0]: fede-linux:9092/0: Topic TOPIC [0]: leaving broker (0 messages in xmitq, next leader (none), rktp 0x7f45040027e0)
DEBUG:rdkafka::client: librdkafka: BRKMIGR [thrd:main]: TOPIC [1] 0x7f4504002bc0 sending final LEAVE for removal by fede-linux:9092/0
DEBUG:rdkafka::client: librdkafka: TOPBRK [thrd:fede-linux:9092/0]: fede-linux:9092/0: Topic TOPIC [0]: no next leader, failing 0 message(s) in partition queue
DEBUG:rdkafka::client: librdkafka: REMOVE [thrd:main]: TOPIC [2] no longer reported in metadata
DEBUG:rdkafka::client: librdkafka: TOPPARREMOVE [thrd:fede-linux:9092/0]: Removing toppar TOPIC [0] 0x7f45040027e0
DEBUG:rdkafka::client: librdkafka: BRKMIGR [thrd:main]: TOPIC [2] 0x7f45040041f0 sending final LEAVE for removal by fede-linux:9092/0
DEBUG:rdkafka::client: librdkafka: DESTROY [thrd:fede-linux:9092/0]: TOPIC [0]: 0x7f45040027e0 DESTROY_FINAL
DEBUG:rdkafka::client: librdkafka: TOPPARREMOVE [thrd:main]: Removing toppar TOPIC [-1] 0x7f4504002340
DEBUG:rdkafka::client: librdkafka: TOPBRK [thrd:fede-linux:9092/0]: fede-linux:9092/0: Topic TOPIC [1]: leaving broker (0 messages in xmitq, next leader (none), rktp 0x7f4504002bc0)
DEBUG:rdkafka::client: librdkafka: DESTROY [thrd:main]: TOPIC [-1]: 0x7f4504002340 DESTROY_FINAL
DEBUG:rdkafka::client: librdkafka: TOPBRK [thrd:fede-linux:9092/0]: fede-linux:9092/0: Topic TOPIC [1]: no next leader, failing 0 message(s) in partition queue
DEBUG:rdkafka::client: librdkafka: TOPBRK [thrd:fede-linux:9092/0]: fede-linux:9092/0: Topic TOPIC [2]: leaving broker (0 messages in xmitq, next leader (none), rktp 0x7f45040041f0)
DEBUG:rdkafka::client: librdkafka: TOPBRK [thrd:fede-linux:9092/0]: fede-linux:9092/0: Topic TOPIC [2]: no next leader, failing 0 message(s) in partition queue
DEBUG:rdkafka::client: librdkafka: UNKTOPIC [thrd:fede-linux:9092/0]: fede-linux:9092/0: Received Fetch response (error 0) for unknown topic TOPIC [2]: ignoring
DEBUG:rdkafka::client: librdkafka: UNKTOPIC [thrd:fede-linux:9092/0]: fede-linux:9092/0: Received Fetch response (error 0) for unknown topic TOPIC [1]: ignoring
DEBUG:rdkafka::client: librdkafka: TOPPARREMOVE [thrd:fede-linux:9092/0]: Removing toppar TOPIC [1] 0x7f4504002bc0
DEBUG:rdkafka::client: librdkafka: DESTROY [thrd:fede-linux:9092/0]: TOPIC [1]: 0x7f4504002bc0 DESTROY_FINAL
DEBUG:rdkafka::client: librdkafka: TOPPARREMOVE [thrd:fede-linux:9092/0]: Removing toppar TOPIC [2] 0x7f45040041f0
DEBUG:rdkafka::client: librdkafka: DESTROY [thrd:fede-linux:9092/0]: TOPIC [2]: 0x7f45040041f0 DESTROY_FINAL
