librdkafka Multiple subscribers subscribing to single non-existing topic triggers multiple rebalance cbs

Coming from here

When consumers C1, C2 subscribing to non-existing topi, T (only one partition). Once the topic gets created, the metadata refresh happens in C1 first, rebalance cb is called and T is assigned to C1. Later the metadata refresh happens in C2, rebalance cb is called again and is assigned to C2.

To confirm that metadata refresh is not happening during rebalance, I started C1 subscribing to T with metadata refresh time as 12 seconds and C2 subscribing to same non existing topic with metadatarefresh as 2 minutes. After the topic creation, in < 12 seconds the rebalance cb was called and the topic for assigned to C1. Only after 1.5 minutes, the metadata refresh happened in C2 causing a rebalance cb again in both consumers causing the topic to be assigned to C2.

Assignment is based on the assignment strategy but still this can happen.

Jul 09 '20 11:07 dshivashankar1994

What librdkafka version are you on? The behaviour for non-existent topics changed in v1.5.0

Aug 17 '20 13:08 edenhill

I tried with v1.5.0 and the behavior is same. Also, as per link, you have mentioned that you will be taking up as part of 1.6.

Aug 20 '20 04:08 dshivashankar1994

Please let us know if this can be fixed with V1.6

Aug 26 '20 07:08 dshivashankar1994

Any updates here ?

Aug 31 '20 06:08 dshivashankar1994

Ping

Sep 02 '20 07:09 dshivashankar1994

If a consumer only subscribes to non-existent topics it will not join the group (since there would be nothing to assign to it) and it will thus not detect that another consumer picks up the new topic and triggers a rebalance. Then later when the topic.metadata.refresh.interval.ms kicks in and the new topic is discovered the consumer will join the group and cause the second rebalance.

I guess the consumer could join the group even if none of its topics exists to be able to detect these rebalances, but it doesn't seem like too common of a case for that functionality.

Sep 02 '20 14:09 edenhill

This happens in case when a consumer subscribes to existing + non-existing topics too. Take the below case

Let C1 and C2 be the consumers connecting with same consumer group id.

C1 starts first with topics A, B (A exists and B not existing).
C2 is started with topic C, B (C exists and B not existing).
Now topic B is created.
Topic metadata refresh happens in C2 first.
This triggers a rebalance cb and the topic B is assigned to C2.
Now the topic metadata refresh happens in C1.
This triggers the rebalance cb again and the topic is now assigned to C1 (as C1 is started first).

So i believe this is an issue to be fixed and not a rare case failure

Sep 04 '20 09:09 dshivashankar1994

This I believe has to be reopened as the problem is not specific to consumers having only non-existing topics

Sep 07 '20 03:09 dshivashankar1994

Ping for above

Sep 16 '20 16:09 dshivashankar1994

Ping

Sep 21 '20 04:09 dshivashankar1994

Ping

Feb 04 '21 07:02 dshivashankar1994

Could you try to reproduce this on v1.6.0/master, we've done quite a bit of consumer work second half of 2020.

Feb 05 '21 15:02 edenhill

yes, am able to reproduce this with v1.6.0 as well

Feb 10 '21 12:02 dshivashankar1994

Can you provide reproduction logs (with debug=cgrp) from v1.6.0?

Feb 10 '21 12:02 edenhill

Consumer 1:

/codemill/dhamodha/projects/librdkafka-1.6.0/examples/rdkafka_complex_consumer_example_cpp -b u-kafkatst-kafkadev-1.sd.firm.com:9092,u-kafkatst-kafkadev-2.sd.firm.com:9092,u-kafkatst-kafkadev-3.sd.firm.com:9092,u-kafkatst-kafkadev-4.sd.firm.com:9092,u-kafkatst-kafkadev-5.sd.firm.com:9092 -g new_cons_gp -X security.protocol=SASL_PLAINTEXT -X sasl.kerberos.service.name=kafka -X sasl.mechanism=GSSAPI -X sasl.kerberos.kinit.cmd='skinit --force' -X client.id=cppcona -X topic.metadata.refresh.interval.ms=100000 fps.dhamodha.test_hello_8 -d cgrp
dhamodha acquired ticket: client dhamodha/[email protected], server krbtgt/[email protected]
2021-02-10 08:49:34.484: LOG-7-MEMBERID: [thrd:app]: Group "new_cons_gp": updating member id "(not-set)" -> ""
2021-02-10 08:49:34.485: 2021-02-10 08:49:34.485: LOG-7-INIT: [thrd:app]: librdkafka v1.6.0 (0x10600ff) cppcona#consumer-1 initialized (builtin.features gzip,snappy,ssl,sasl,regex,lz4,sasl_gssapi,sasl_plain,sasl_scram,plugins,zstd,sasl_oauthbearer, GCC GXX PKGCONFIG INSTALL GNULD LDS LIBDL PLUGINS ZLIB SSL SASL_CYRUS ZSTD HDRHISTOGRAM LZ4_EXT SYSLOG SNAPPY SOCKEM SASL_SCRAM SASL_OAUTHBEARER CRC32C_HW, debug 0x100)
LOG-7-CGRPSTATE: [thrd:main]: Group "new_cons_gp" changed state init -> query-coord (join-state init)
% Created consumer cppcona#consumer-1
2021-02-10 08:49:34.485: LOG-7-CGRPQUERY: [thrd:main]: Group "new_cons_gp": no broker available for coordinator query: intervaled in state query-coord
2021-02-10 08:49:34.485: LOG-7-CGRPOP: [thrd:main]: Group "new_cons_gp" received op SUBSCRIBE in state query-coord (join-state init)
2021-02-10 08:49:34.485: LOG-7-SUBSCRIBE: [thrd:main]: Group "new_cons_gp": subscribe to new subscription of 1 topics (join-state init)
2021-02-10 08:49:34.485: LOG-7-CGRPQUERY: [thrd:main]: Group "new_cons_gp": no broker available for coordinator query: intervaled in state query-coord
2021-02-10 08:49:34.508: LOG-7-CGRPQUERY: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-2.sd.firm.com:9092/bootstrap: Group "new_cons_gp": querying for coordinator: intervaled in state query-coord
2021-02-10 08:49:34.508: LOG-7-CGRPSTATE: [thrd:main]: Group "new_cons_gp" changed state query-coord -> wait-coord (join-state init)
2021-02-10 08:49:34.508: LOG-7-CGRPCOORD: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-2.sd.firm.com:9092/2: Group "new_cons_gp" coordinator is u-kafkatst-kafkadev-5.sd.firm.com:9092 id 5
2021-02-10 08:49:34.508: LOG-7-CGRPCOORD: [thrd:main]: Group "new_cons_gp" changing coordinator -1 -> 5
2021-02-10 08:49:34.508: LOG-7-COORDSET: [thrd:main]: Group "new_cons_gp" coordinator set to broker sasl_plaintext://u-kafkatst-kafkadev-5.sd.firm.com:9092/5
2021-02-10 08:49:34.508: LOG-7-CGRPSTATE: [thrd:main]: Group "new_cons_gp" changed state wait-coord -> wait-broker-transport (join-state init)
2021-02-10 08:49:34.508: LOG-7-CGRPQUERY: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-2.sd.firm.com:9092/2: Group "new_cons_gp": querying for coordinator: intervaled in state wait-broker-transport
2021-02-10 08:49:34.508: LOG-7-CGRPCOORD: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-2.sd.firm.com:9092/2: Group "new_cons_gp" coordinator is u-kafkatst-kafkadev-5.sd.firm.com:9092 id 5
2021-02-10 08:49:34.544: LOG-7-CGRPSTATE: [thrd:main]: Group "new_cons_gp" changed state wait-broker-transport -> up (join-state init)
2021-02-10 08:49:34.544: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": join with 0 subscribed topic(s)
2021-02-10 08:49:34.544: LOG-7-CGRPMETADATA: [thrd:main]: consumer join: metadata for subscription only available for 0/1 topics (-1ms old)
2021-02-10 08:49:34.544: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": postponing join until up-to-date metadata is available
2021-02-10 08:49:34.544: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state init -> wait-metadata (state up)
2021-02-10 08:49:34.544: LOG-7-DUMP: [thrd:main]: Assignment dump (started_cnt=0, wait_stop_cnt=0)
2021-02-10 08:49:34.544: LOG-7-DUMP_ALL: [thrd:main]: List with 0 partition(s):
2021-02-10 08:49:34.544: LOG-7-DUMP_PND: [thrd:main]: List with 0 partition(s):
2021-02-10 08:49:34.544: LOG-7-DUMP_QRY: [thrd:main]: List with 0 partition(s):
2021-02-10 08:49:34.544: LOG-7-DUMP_REM: [thrd:main]: List with 0 partition(s):
2021-02-10 08:49:34.544: LOG-7-ASSIGNDONE: [thrd:main]: Group "new_cons_gp": assignment operations done in join-state wait-metadata (rebalance rejoin=false)
2021-02-10 08:49:34.545: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:49:34.545: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp": subscription updated from metadata change: rejoining group
2021-02-10 08:49:34.545: LOG-7-GRPLEADER: [thrd:main]: Group "new_cons_gp": resetting group leader info: group (re)join
2021-02-10 08:49:34.545: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp" (re)joining in join-state wait-metadata with 0 assigned partition(s): Metadata for subscribed topic(s) has changed
2021-02-10 08:49:34.545: LOG-7-REBALANCE: [thrd:main]: Group "new_cons_gp" initiating rebalance (NONE) in state up (join-state wait-metadata) with 0 assigned partition(s): Metadata for subscribed topic(s) has changed
2021-02-10 08:49:34.545: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp": Rejoining group without an assignment: Metadata for subscribed topic(s) has changed
2021-02-10 08:49:34.545: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state wait-metadata -> init (state up)
2021-02-10 08:49:34.545: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": join with 0 subscribed topic(s)
2021-02-10 08:49:34.545: LOG-7-CGRPMETADATA: [thrd:main]: consumer join: metadata for subscription is up to date (0ms old)
2021-02-10 08:49:34.545: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:49:34.545: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": no matching topics based on 0ms old metadata: next metadata refresh in 100000ms
2021-02-10 08:49:34.545: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:49:36.484: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": join with 0 subscribed topic(s)
2021-02-10 08:49:36.484: LOG-7-CGRPMETADATA: [thrd:main]: consumer join: metadata for subscription only available for 0/1 topics (-1ms old)
2021-02-10 08:49:36.484: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": postponing join until up-to-date metadata is available
2021-02-10 08:49:36.484: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state init -> wait-metadata (state up)
2021-02-10 08:49:36.484: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:49:36.484: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp": subscription updated from metadata change: rejoining group
2021-02-10 08:49:36.484: LOG-7-GRPLEADER: [thrd:main]: Group "new_cons_gp": resetting group leader info: group (re)join
2021-02-10 08:49:36.484: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp" (re)joining in join-state wait-metadata with 0 assigned partition(s): Metadata for subscribed topic(s) has changed
2021-02-10 08:49:36.484: LOG-7-REBALANCE: [thrd:main]: Group "new_cons_gp" initiating rebalance (NONE) in state up (join-state wait-metadata) with 0 assigned partition(s): Metadata for subscribed topic(s) has changed
2021-02-10 08:49:36.484: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp": Rejoining group without an assignment: Metadata for subscribed topic(s) has changed
2021-02-10 08:49:36.484: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state wait-metadata -> init (state up)
2021-02-10 08:49:36.484: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": join with 0 subscribed topic(s)
2021-02-10 08:49:36.484: LOG-7-CGRPMETADATA: [thrd:main]: consumer join: metadata for subscription is up to date (0ms old)
2021-02-10 08:49:36.484: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:49:36.484: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": no matching topics based on 0ms old metadata: next metadata refresh in 100000ms
2021-02-10 08:49:36.484: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:49:37.484: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": join with 0 subscribed topic(s)
2021-02-10 08:49:37.484: LOG-7-CGRPMETADATA: [thrd:main]: consumer join: metadata for subscription only available for 0/1 topics (-1ms old)
2021-02-10 08:49:37.484: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": postponing join until up-to-date metadata is available
2021-02-10 08:49:37.484: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state init -> wait-metadata (state up)
2021-02-10 08:49:37.485: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:49:37.485: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp": subscription updated from metadata change: rejoining group
2021-02-10 08:49:37.485: LOG-7-GRPLEADER: [thrd:main]: Group "new_cons_gp": resetting group leader info: group (re)join
2021-02-10 08:49:37.485: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp" (re)joining in join-state wait-metadata with 0 assigned partition(s): Metadata for subscribed topic(s) has changed
2021-02-10 08:49:37.485: LOG-7-REBALANCE: [thrd:main]: Group "new_cons_gp" initiating rebalance (NONE) in state up (join-state wait-metadata) with 0 assigned partition(s): Metadata for subscribed topic(s) has changed
2021-02-10 08:49:37.485: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp": Rejoining group without an assignment: Metadata for subscribed topic(s) has changed
2021-02-10 08:49:37.485: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state wait-metadata -> init (state up)
2021-02-10 08:49:37.485: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": join with 0 subscribed topic(s)
2021-02-10 08:49:37.485: LOG-7-CGRPMETADATA: [thrd:main]: consumer join: metadata for subscription is up to date (0ms old)
2021-02-10 08:49:37.485: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:49:37.485: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": no matching topics based on 0ms old metadata: next metadata refresh in 100000ms
2021-02-10 08:49:37.485: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:49:39.484: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": join with 0 subscribed topic(s)
2021-02-10 08:49:39.484: LOG-7-CGRPMETADATA: [thrd:main]: consumer join: metadata for subscription only available for 0/1 topics (-1ms old)
2021-02-10 08:49:39.484: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": postponing join until up-to-date metadata is available
2021-02-10 08:49:39.484: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state init -> wait-metadata (state up)
2021-02-10 08:49:39.484: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:49:39.484: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp": subscription updated from metadata change: rejoining group
2021-02-10 08:49:39.484: LOG-7-GRPLEADER: [thrd:main]: Group "new_cons_gp": resetting group leader info: group (re)join
2021-02-10 08:49:39.484: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp" (re)joining in join-state wait-metadata with 0 assigned partition(s): Metadata for subscribed topic(s) has changed
2021-02-10 08:49:39.484: LOG-7-REBALANCE: [thrd:main]: Group "new_cons_gp" initiating rebalance (NONE) in state up (join-state wait-metadata) with 0 assigned partition(s): Metadata for subscribed topic(s) has changed
2021-02-10 08:49:39.484: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp": Rejoining group without an assignment: Metadata for subscribed topic(s) has changed
2021-02-10 08:49:39.484: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state wait-metadata -> init (state up)
2021-02-10 08:49:39.484: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": join with 0 subscribed topic(s)
2021-02-10 08:49:39.484: LOG-7-CGRPMETADATA: [thrd:main]: consumer join: metadata for subscription is up to date (0ms old)
2021-02-10 08:49:39.484: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:49:39.484: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": no matching topics based on 0ms old metadata: next metadata refresh in 100000ms
2021-02-10 08:49:39.484: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:49:39.484: LOG-7-DUMP: [thrd:main]: Assignment dump (started_cnt=0, wait_stop_cnt=0)
2021-02-10 08:49:39.484: LOG-7-DUMP_ALL: [thrd:main]: List with 0 partition(s):
2021-02-10 08:49:39.484: LOG-7-DUMP_PND: [thrd:main]: List with 0 partition(s):
2021-02-10 08:49:39.484: LOG-7-DUMP_QRY: [thrd:main]: List with 0 partition(s):
2021-02-10 08:49:39.484: LOG-7-DUMP_REM: [thrd:main]: List with 0 partition(s):
2021-02-10 08:49:39.484: LOG-7-ASSIGNDONE: [thrd:main]: Group "new_cons_gp": assignment operations done in join-state init (rebalance rejoin=false)
2021-02-10 08:49:40.484: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": join with 0 subscribed topic(s)
2021-02-10 08:49:40.484: LOG-7-CGRPMETADATA: [thrd:main]: consumer join: metadata for subscription only available for 0/1 topics (-1ms old)
2021-02-10 08:49:40.484: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": postponing join until up-to-date metadata is available
2021-02-10 08:49:40.484: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state init -> wait-metadata (state up)
2021-02-10 08:49:40.485: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:49:40.485: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp": subscription updated from metadata change: rejoining group
2021-02-10 08:49:40.485: LOG-7-GRPLEADER: [thrd:main]: Group "new_cons_gp": resetting group leader info: group (re)join
2021-02-10 08:49:40.485: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp" (re)joining in join-state wait-metadata with 0 assigned partition(s): Metadata for subscribed topic(s) has changed
2021-02-10 08:49:40.485: LOG-7-REBALANCE: [thrd:main]: Group "new_cons_gp" initiating rebalance (NONE) in state up (join-state wait-metadata) with 0 assigned partition(s): Metadata for subscribed topic(s) has changed
2021-02-10 08:49:40.485: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp": Rejoining group without an assignment: Metadata for subscribed topic(s) has changed
2021-02-10 08:49:40.485: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state wait-metadata -> init (state up)
2021-02-10 08:49:40.485: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": join with 0 subscribed topic(s)
2021-02-10 08:49:40.485: LOG-7-CGRPMETADATA: [thrd:main]: consumer join: metadata for subscription is up to date (0ms old)
2021-02-10 08:49:40.485: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:49:40.485: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": no matching topics based on 0ms old metadata: next metadata refresh in 100000ms
2021-02-10 08:49:40.485: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:49:42.484: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": join with 0 subscribed topic(s)
2021-02-10 08:49:42.484: LOG-7-CGRPMETADATA: [thrd:main]: consumer join: metadata for subscription only available for 0/1 topics (-1ms old)
2021-02-10 08:49:42.484: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": postponing join until up-to-date metadata is available
2021-02-10 08:49:42.484: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state init -> wait-metadata (state up)
2021-02-10 08:49:42.484: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:49:42.484: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp": subscription updated from metadata change: rejoining group
2021-02-10 08:49:42.484: LOG-7-GRPLEADER: [thrd:main]: Group "new_cons_gp": resetting group leader info: group (re)join
2021-02-10 08:49:42.484: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp" (re)joining in join-state wait-metadata with 0 assigned partition(s): Metadata for subscribed topic(s) has changed
2021-02-10 08:49:42.484: LOG-7-REBALANCE: [thrd:main]: Group "new_cons_gp" initiating rebalance (NONE) in state up (join-state wait-metadata) with 0 assigned partition(s): Metadata for subscribed topic(s) has changed
2021-02-10 08:49:42.484: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp": Rejoining group without an assignment: Metadata for subscribed topic(s) has changed
2021-02-10 08:49:42.484: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state wait-metadata -> init (state up)
2021-02-10 08:49:42.484: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": join with 0 subscribed topic(s)
2021-02-10 08:49:42.484: LOG-7-CGRPMETADATA: [thrd:main]: consumer join: metadata for subscription is up to date (0ms old)
2021-02-10 08:49:42.484: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:49:42.484: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": no matching topics based on 0ms old metadata: next metadata refresh in 100000ms
2021-02-10 08:49:42.484: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:49:43.484: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": join with 0 subscribed topic(s)
2021-02-10 08:49:43.484: LOG-7-CGRPMETADATA: [thrd:main]: consumer join: metadata for subscription only available for 0/1 topics (-1ms old)
2021-02-10 08:49:43.484: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": postponing join until up-to-date metadata is available
2021-02-10 08:49:43.484: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state init -> wait-metadata (state up)
2021-02-10 08:49:43.485: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:49:43.485: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp": subscription updated from metadata change: rejoining group
2021-02-10 08:49:43.485: LOG-7-GRPLEADER: [thrd:main]: Group "new_cons_gp": resetting group leader info: group (re)join
2021-02-10 08:49:43.485: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp" (re)joining in join-state wait-metadata with 0 assigned partition(s): Metadata for subscribed topic(s) has changed
2021-02-10 08:49:43.485: LOG-7-REBALANCE: [thrd:main]: Group "new_cons_gp" initiating rebalance (NONE) in state up (join-state wait-metadata) with 0 assigned partition(s): Metadata for subscribed topic(s) has changed
2021-02-10 08:49:43.485: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp": Rejoining group without an assignment: Metadata for subscribed topic(s) has changed
2021-02-10 08:49:43.485: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state wait-metadata -> init (state up)
2021-02-10 08:49:43.485: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": join with 0 subscribed topic(s)
2021-02-10 08:49:43.485: LOG-7-CGRPMETADATA: [thrd:main]: consumer join: metadata for subscription is up to date (0ms old)
2021-02-10 08:49:43.485: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:49:43.485: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": no matching topics based on 0ms old metadata: next metadata refresh in 100000ms
2021-02-10 08:49:43.485: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:49:44.484: LOG-7-DUMP: [thrd:main]: Assignment dump (started_cnt=0, wait_stop_cnt=0)
2021-02-10 08:49:44.485: LOG-7-DUMP_ALL: [thrd:main]: List with 0 partition(s):
2021-02-10 08:49:44.485: LOG-7-DUMP_PND: [thrd:main]: List with 0 partition(s):
2021-02-10 08:49:44.485: LOG-7-DUMP_QRY: [thrd:main]: List with 0 partition(s):
2021-02-10 08:49:44.485: LOG-7-DUMP_REM: [thrd:main]: List with 0 partition(s):
2021-02-10 08:49:44.485: LOG-7-ASSIGNDONE: [thrd:main]: Group "new_cons_gp": assignment operations done in join-state init (rebalance rejoin=false)
2021-02-10 08:49:45.484: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": join with 0 subscribed topic(s)
2021-02-10 08:49:45.484: LOG-7-CGRPMETADATA: [thrd:main]: consumer join: metadata for subscription only available for 0/1 topics (-1ms old)
2021-02-10 08:49:45.484: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": postponing join until up-to-date metadata is available
2021-02-10 08:49:45.484: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state init -> wait-metadata (state up)
2021-02-10 08:49:45.484: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:49:45.484: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp": subscription updated from metadata change: rejoining group
2021-02-10 08:49:45.484: LOG-7-GRPLEADER: [thrd:main]: Group "new_cons_gp": resetting group leader info: group (re)join
2021-02-10 08:49:45.484: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp" (re)joining in join-state wait-metadata with 0 assigned partition(s): Metadata for subscribed topic(s) has changed
2021-02-10 08:49:45.484: LOG-7-REBALANCE: [thrd:main]: Group "new_cons_gp" initiating rebalance (NONE) in state up (join-state wait-metadata) with 0 assigned partition(s): Metadata for subscribed topic(s) has changed
2021-02-10 08:49:45.484: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp": Rejoining group without an assignment: Metadata for subscribed topic(s) has changed
2021-02-10 08:49:45.484: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state wait-metadata -> init (state up)
2021-02-10 08:49:45.484: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": join with 0 subscribed topic(s)
2021-02-10 08:49:45.484: LOG-7-CGRPMETADATA: [thrd:main]: consumer join: metadata for subscription is up to date (0ms old)
2021-02-10 08:49:45.484: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:49:45.484: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": no matching topics based on 0ms old metadata: next metadata refresh in 100000ms
2021-02-10 08:49:45.484: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:49:46.484: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": join with 0 subscribed topic(s)
2021-02-10 08:49:46.484: LOG-7-CGRPMETADATA: [thrd:main]: consumer join: metadata for subscription only available for 0/1 topics (-1ms old)
2021-02-10 08:49:46.484: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": postponing join until up-to-date metadata is available
2021-02-10 08:49:46.484: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state init -> wait-metadata (state up)
2021-02-10 08:49:46.485: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:49:46.485: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp": subscription updated from metadata change: rejoining group
2021-02-10 08:49:46.485: LOG-7-GRPLEADER: [thrd:main]: Group "new_cons_gp": resetting group leader info: group (re)join
2021-02-10 08:49:46.485: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp" (re)joining in join-state wait-metadata with 0 assigned partition(s): Metadata for subscribed topic(s) has changed
2021-02-10 08:49:46.485: LOG-7-REBALANCE: [thrd:main]: Group "new_cons_gp" initiating rebalance (NONE) in state up (join-state wait-metadata) with 0 assigned partition(s): Metadata for subscribed topic(s) has changed
2021-02-10 08:49:46.485: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp": Rejoining group without an assignment: Metadata for subscribed topic(s) has changed
2021-02-10 08:49:46.485: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state wait-metadata -> init (state up)
2021-02-10 08:49:46.485: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": join with 0 subscribed topic(s)
2021-02-10 08:49:46.485: LOG-7-CGRPMETADATA: [thrd:main]: consumer join: metadata for subscription is up to date (0ms old)
2021-02-10 08:49:46.485: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:49:46.485: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": no matching topics based on 0ms old metadata: next metadata refresh in 100000ms
2021-02-10 08:49:46.485: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:49:47.485: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": join with 0 subscribed topic(s)
2021-02-10 08:49:47.485: LOG-7-CGRPMETADATA: [thrd:main]: consumer join: metadata for subscription only available for 0/1 topics (-1ms old)
2021-02-10 08:49:47.485: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": postponing join until up-to-date metadata is available
2021-02-10 08:49:47.485: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state init -> wait-metadata (state up)
2021-02-10 08:49:47.485: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:49:47.485: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp": subscription updated from metadata change: rejoining group
2021-02-10 08:49:47.485: LOG-7-GRPLEADER: [thrd:main]: Group "new_cons_gp": resetting group leader info: group (re)join
2021-02-10 08:49:47.485: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp" (re)joining in join-state wait-metadata with 0 assigned partition(s): Metadata for subscribed topic(s) has changed
2021-02-10 08:49:47.485: LOG-7-REBALANCE: [thrd:main]: Group "new_cons_gp" initiating rebalance (NONE) in state up (join-state wait-metadata) with 0 assigned partition(s): Metadata for subscribed topic(s) has changed
2021-02-10 08:49:47.485: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp": Rejoining group without an assignment: Metadata for subscribed topic(s) has changed
2021-02-10 08:49:47.485: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state wait-metadata -> init (state up)
2021-02-10 08:49:47.485: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": join with 0 subscribed topic(s)
2021-02-10 08:49:47.485: LOG-7-CGRPMETADATA: [thrd:main]: consumer join: metadata for subscription is up to date (0ms old)
2021-02-10 08:49:47.485: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:49:47.485: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": no matching topics based on 0ms old metadata: next metadata refresh in 100000ms
2021-02-10 08:49:47.485: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:49:49.484: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": join with 0 subscribed topic(s)
2021-02-10 08:49:49.484: LOG-7-CGRPMETADATA: [thrd:main]: consumer join: metadata for subscription only available for 0/1 topics (-1ms old)
2021-02-10 08:49:49.484: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": postponing join until up-to-date metadata is available
2021-02-10 08:49:49.484: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state init -> wait-metadata (state up)
2021-02-10 08:49:49.484: LOG-7-DUMP: [thrd:main]: Assignment dump (started_cnt=0, wait_stop_cnt=0)
2021-02-10 08:49:49.484: LOG-7-DUMP_ALL: [thrd:main]: List with 0 partition(s):
2021-02-10 08:49:49.484: LOG-7-DUMP_PND: [thrd:main]: List with 0 partition(s):
2021-02-10 08:49:49.484: LOG-7-DUMP_QRY: [thrd:main]: List with 0 partition(s):
2021-02-10 08:49:49.484: LOG-7-DUMP_REM: [thrd:main]: List with 0 partition(s):
2021-02-10 08:49:49.484: LOG-7-ASSIGNDONE: [thrd:main]: Group "new_cons_gp": assignment operations done in join-state wait-metadata (rebalance rejoin=false)
2021-02-10 08:49:49.485: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": effective subscription list changed from 0 to 1 topic(s):
2021-02-10 08:49:49.485: LOG-7-SUBSCRIPTION: [thrd:main]:  Topic fps.dhamodha.test_hello_8 with 1 partition(s)
2021-02-10 08:49:49.485: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp": subscription updated from metadata change: rejoining group
2021-02-10 08:49:49.485: LOG-7-GRPLEADER: [thrd:main]: Group "new_cons_gp": resetting group leader info: group (re)join
2021-02-10 08:49:49.485: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp" (re)joining in join-state wait-metadata with 0 assigned partition(s): Metadata for subscribed topic(s) has changed
2021-02-10 08:49:49.485: LOG-7-REBALANCE: [thrd:main]: Group "new_cons_gp" initiating rebalance (NONE) in state up (join-state wait-metadata) with 0 assigned partition(s): Metadata for subscribed topic(s) has changed
2021-02-10 08:49:49.485: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp": Rejoining group without an assignment: Metadata for subscribed topic(s) has changed
2021-02-10 08:49:49.485: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state wait-metadata -> init (state up)
2021-02-10 08:49:49.485: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": join with 1 subscribed topic(s)
2021-02-10 08:49:49.485: LOG-7-CGRPMETADATA: [thrd:main]: consumer join: metadata for subscription is up to date (0ms old)
2021-02-10 08:49:49.485: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state init -> wait-join (state up)
2021-02-10 08:49:49.485: LOG-7-JOINGROUP: [thrd:main]: JoinGroup response: GenerationId -1, Protocol , LeaderId , my MemberId cppcona-80711f7e-d278-4857-8297-8c6bb9acb426, member metadata count 0: Broker: Group member needs a valid member ID
2021-02-10 08:49:49.485: LOG-7-MEMBERID: [thrd:main]: Group "new_cons_gp": updating member id "" -> "cppcona-80711f7e-d278-4857-8297-8c6bb9acb426"
2021-02-10 08:49:49.485: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp": Rejoining group without an assignment: JoinGroup error: Broker: Group member needs a valid member ID
2021-02-10 08:49:49.485: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state wait-join -> init (state up)
2021-02-10 08:49:49.485: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": join with 1 subscribed topic(s)
2021-02-10 08:49:49.485: LOG-7-CGRPMETADATA: [thrd:main]: consumer join: metadata for subscription is up to date (0ms old)
2021-02-10 08:49:49.485: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state init -> wait-join (state up)
2021-02-10 08:49:50.865: LOG-7-JOINGROUP: [thrd:main]: JoinGroup response: GenerationId 36, Protocol range, LeaderId cppconz-1d2e0ff1-4927-4c96-bdc1-9a0441302eff, my MemberId cppcona-80711f7e-d278-4857-8297-8c6bb9acb426, member metadata count 0: (no error)
2021-02-10 08:49:50.865: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state wait-join -> wait-sync (state up)
2021-02-10 08:49:50.866: LOG-7-SYNCGROUP: [thrd:main]: SyncGroup response: Success (45 bytes of MemberState data)
2021-02-10 08:49:50.866: LOG-7-ASSIGNMENT: [thrd:main]: List with 1 partition(s):
2021-02-10 08:49:50.866: LOG-7-ASSIGNMENT: [thrd:main]:  fps.dhamodha.test_hello_8 [0] offset INVALID
2021-02-10 08:49:50.866: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state wait-sync -> wait-assign-call (state up)
2021-02-10 08:49:50.866: LOG-7-ASSIGN: [thrd:main]: Group "new_cons_gp": delegating assign of 1 partition(s) to application on queue rd_kafka_cgrp_new: new assignment
2021-02-10 08:49:50.866: LOG-7-ASSIGNMENT: [thrd:main]: Group "new_cons_gp": setting group assignment to 1 partition(s)
2021-02-10 08:49:50.866: LOG-7-GRPASSIGNMENT: [thrd:main]: List with 1 partition(s):
2021-02-10 08:49:50.866: LOG-7-GRPASSIGNMENT: [thrd:main]:  fps.dhamodha.test_hello_8 [0] offset INVALID
2021-02-10 08:49:50.866: LOG-7-HEARTBEAT: [thrd:main]: GroupCoordinator/5: Heartbeat for group "new_cons_gp" generation id 36
RebalanceCb: Local: Assign partitions: fps.dhamodha.test_hello_8[0], 
2021-02-10 08:49:50.866: LOG-7-CGRPOP: [thrd:main]: Group "new_cons_gp" received op GET_REBALANCE_PROTOCOL in state up (join-state wait-assign-call)
2021-02-10 08:49:50.866: LOG-7-CGRPOP: [thrd:main]: Group "new_cons_gp" received op ASSIGN in state up (join-state wait-assign-call)
2021-02-10 08:49:50.866: LOG-7-ASSIGN: [thrd:main]: Group "new_cons_gp": new assignment of 1 partition(s) in join-state wait-assign-call
2021-02-10 08:49:50.866: LOG-7-CLEARASSIGN: [thrd:main]: No current assignment to clear
2021-02-10 08:49:50.866: LOG-7-ASSIGNMENT: [thrd:main]: Added 1 partition(s) to assignment which now consists of 1 partition(s) where of 1 are in pending state and 0 are being queried
2021-02-10 08:49:50.866: LOG-7-PAUSE: [thrd:main]: Resuming fetchers for 1 assigned partition(s): assign called
2021-02-10 08:49:50.866: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state wait-assign-call -> steady (state up)
2021-02-10 08:49:50.866: LOG-7-DUMP: [thrd:main]: Assignment dump (started_cnt=0, wait_stop_cnt=0)
2021-02-10 08:49:50.866: LOG-7-DUMP_ALL: [thrd:main]: List with 1 partition(s):
2021-02-10 08:49:50.866: LOG-7-DUMP_ALL: [thrd:main]:  fps.dhamodha.test_hello_8 [0] offset STORED
2021-02-10 08:49:50.866: LOG-7-DUMP_PND: [thrd:main]: List with 1 partition(s):
2021-02-10 08:49:50.866: LOG-7-DUMP_PND: [thrd:main]:  fps.dhamodha.test_hello_8 [0] offset STORED
2021-02-10 08:49:50.866: LOG-7-DUMP_QRY: [thrd:main]: List with 0 partition(s):
2021-02-10 08:49:50.866: LOG-7-DUMP_REM: [thrd:main]: List with 0 partition(s):
2021-02-10 08:49:50.866: LOG-7-SRVPEND: [thrd:main]: Querying committed offset for pending assigned partition fps.dhamodha.test_hello_8 [0]
2021-02-10 08:49:50.866: LOG-7-OFFSETFETCH: [thrd:main]: Fetching committed offsets for 1 pending partition(s) in assignment
2021-02-10 08:49:50.866: LOG-7-OFFSET: [thrd:main]: GroupCoordinator/5: Fetch committed offsets for 1/1 partition(s)
2021-02-10 08:49:50.866: LOG-7-ASSIGNMENT: [thrd:main]: Current assignment of 1 partition(s) with 1 pending adds, 1 offset queries, 0 partitions awaiting stop and 0 offset commits in progress
2021-02-10 08:49:50.866: LOG-7-OFFSETFETCH: [thrd:main]: Adding fps.dhamodha.test_hello_8 [0] back to pending list with offset 1
2021-02-10 08:49:50.866: LOG-7-DUMP: [thrd:main]: Assignment dump (started_cnt=0, wait_stop_cnt=0)
2021-02-10 08:49:50.866: LOG-7-DUMP_ALL: [thrd:main]: List with 1 partition(s):
2021-02-10 08:49:50.866: LOG-7-DUMP_ALL: [thrd:main]:  fps.dhamodha.test_hello_8 [0] offset STORED
2021-02-10 08:49:50.866: LOG-7-DUMP_PND: [thrd:main]: List with 1 partition(s):
2021-02-10 08:49:50.866: LOG-7-DUMP_PND: [thrd:main]:  fps.dhamodha.test_hello_8 [0] offset 1
2021-02-10 08:49:50.866: LOG-7-DUMP_QRY: [thrd:main]: List with 0 partition(s):
2021-02-10 08:49:50.866: LOG-7-DUMP_REM: [thrd:main]: List with 0 partition(s):
2021-02-10 08:49:50.866: LOG-7-SRVPEND: [thrd:main]: Starting pending assigned partition fps.dhamodha.test_hello_8 [0] at offset 1
2021-02-10 08:49:50.866: LOG-7-ASSIGNDONE: [thrd:main]: Group "new_cons_gp": assignment operations done in join-state steady (rebalance rejoin=false)
2021-02-10 08:49:50.866: LOG-7-CGRPOP: [thrd:main]: Group "new_cons_gp" received op PARTITION_JOIN in state up (join-state steady) for fps.dhamodha.test_hello_8 [0]
2021-02-10 08:49:50.866: LOG-7-PARTADD: [thrd:main]: Group "new_cons_gp": add fps.dhamodha.test_hello_8 [0]
2021-02-10 08:49:53.866: LOG-7-HEARTBEAT: [thrd:main]: GroupCoordinator/5: Heartbeat for group "new_cons_gp" generation id 36
2021-02-10 08:49:54.484: LOG-7-OFFSET: [thrd:main]: Topic fps.dhamodha.test_hello_8 [0]: stored offset -1001, committed offset 1: not including in commit
2021-02-10 08:49:54.485: LOG-7-DUMP: [thrd:main]: Assignment dump (started_cnt=1, wait_stop_cnt=0)
2021-02-10 08:49:54.485: LOG-7-DUMP_ALL: [thrd:main]: List with 1 partition(s):
2021-02-10 08:49:54.485: LOG-7-DUMP_ALL: [thrd:main]:  fps.dhamodha.test_hello_8 [0] offset STORED
2021-02-10 08:49:54.485: LOG-7-DUMP_PND: [thrd:main]: List with 0 partition(s):
2021-02-10 08:49:54.485: LOG-7-DUMP_QRY: [thrd:main]: List with 0 partition(s):
2021-02-10 08:49:54.485: LOG-7-DUMP_REM: [thrd:main]: List with 0 partition(s):
2021-02-10 08:49:54.485: LOG-7-ASSIGNDONE: [thrd:main]: Group "new_cons_gp": assignment operations done in join-state steady (rebalance rejoin=false)
2021-02-10 08:49:56.866: LOG-7-HEARTBEAT: [thrd:main]: GroupCoordinator/5: Heartbeat for group "new_cons_gp" generation id 36
2021-02-10 08:49:59.485: LOG-7-OFFSET: [thrd:main]: Topic fps.dhamodha.test_hello_8 [0]: stored offset -1001, committed offset 1: not including in commit
2021-02-10 08:49:59.485: LOG-7-DUMP: [thrd:main]: Assignment dump (started_cnt=1, wait_stop_cnt=0)
2021-02-10 08:49:59.485: LOG-7-DUMP_ALL: [thrd:main]: List with 1 partition(s):
2021-02-10 08:49:59.485: LOG-7-DUMP_ALL: [thrd:main]:  fps.dhamodha.test_hello_8 [0] offset STORED
2021-02-10 08:49:59.485: LOG-7-DUMP_PND: [thrd:main]: List with 0 partition(s):
2021-02-10 08:49:59.485: LOG-7-DUMP_QRY: [thrd:main]: List with 0 partition(s):
2021-02-10 08:49:59.485: LOG-7-DUMP_REM: [thrd:main]: List with 0 partition(s):
2021-02-10 08:49:59.485: LOG-7-ASSIGNDONE: [thrd:main]: Group "new_cons_gp": assignment operations done in join-state steady (rebalance rejoin=false)
2021-02-10 08:49:59.866: LOG-7-HEARTBEAT: [thrd:main]: GroupCoordinator/5: Heartbeat for group "new_cons_gp" generation id 36
2021-02-10 08:50:02.866: LOG-7-HEARTBEAT: [thrd:main]: GroupCoordinator/5: Heartbeat for group "new_cons_gp" generation id 36
2021-02-10 08:50:04.485: LOG-7-OFFSET: [thrd:main]: Topic fps.dhamodha.test_hello_8 [0]: stored offset -1001, committed offset 1: not including in commit
2021-02-10 08:50:04.485: LOG-7-DUMP: [thrd:main]: Assignment dump (started_cnt=1, wait_stop_cnt=0)
2021-02-10 08:50:04.485: LOG-7-DUMP_ALL: [thrd:main]: List with 1 partition(s):
2021-02-10 08:50:04.485: LOG-7-DUMP_ALL: [thrd:main]:  fps.dhamodha.test_hello_8 [0] offset STORED
2021-02-10 08:50:04.485: LOG-7-DUMP_PND: [thrd:main]: List with 0 partition(s):
2021-02-10 08:50:04.485: LOG-7-DUMP_QRY: [thrd:main]: List with 0 partition(s):
2021-02-10 08:50:04.485: LOG-7-DUMP_REM: [thrd:main]: List with 0 partition(s):
2021-02-10 08:50:04.485: LOG-7-ASSIGNDONE: [thrd:main]: Group "new_cons_gp": assignment operations done in join-state steady (rebalance rejoin=false)
2021-02-10 08:50:05.866: LOG-7-HEARTBEAT: [thrd:main]: GroupCoordinator/5: Heartbeat for group "new_cons_gp" generation id 36
2021-02-10 08:50:08.866: LOG-7-HEARTBEAT: [thrd:main]: GroupCoordinator/5: Heartbeat for group "new_cons_gp" generation id 36
2021-02-10 08:50:09.485: LOG-7-OFFSET: [thrd:main]: Topic fps.dhamodha.test_hello_8 [0]: stored offset -1001, committed offset 1: not including in commit
2021-02-10 08:50:09.485: LOG-7-DUMP: [thrd:main]: Assignment dump (started_cnt=1, wait_stop_cnt=0)
2021-02-10 08:50:09.485: LOG-7-DUMP_ALL: [thrd:main]: List with 1 partition(s):
2021-02-10 08:50:09.485: LOG-7-DUMP_ALL: [thrd:main]:  fps.dhamodha.test_hello_8 [0] offset STORED
2021-02-10 08:50:09.485: LOG-7-DUMP_PND: [thrd:main]: List with 0 partition(s):
2021-02-10 08:50:09.485: LOG-7-DUMP_QRY: [thrd:main]: List with 0 partition(s):
2021-02-10 08:50:09.485: LOG-7-DUMP_REM: [thrd:main]: List with 0 partition(s):
2021-02-10 08:50:09.485: LOG-7-ASSIGNDONE: [thrd:main]: Group "new_cons_gp": assignment operations done in join-state steady (rebalance rejoin=false)
2021-02-10 08:50:11.866: LOG-7-HEARTBEAT: [thrd:main]: GroupCoordinator/5: Heartbeat for group "new_cons_gp" generation id 36
2021-02-10 08:50:13.385: LOG-7-CGRPOP: [thrd:main]: Group "new_cons_gp" received op TERMINATE in state up (join-state steady)
2021-02-10 08:50:13.385: LOG-7-CGRPTERM: [thrd:main]: Terminating group "new_cons_gp" in state up with 1 partition(s)
2021-02-10 08:50:13.385: LOG-7-UNSUBSCRIBE: [thrd:main]: Group "new_cons_gp": unsubscribe from current subscription of size 1 (leave group=true, has joined=true, cppcona-80711f7e-d278-4857-8297-8c6bb9acb426, join-state steady)
2021-02-10 08:50:13.385: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": clearing subscribed topics list (1)
2021-02-10 08:50:13.385: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": effective subscription list changed from 1 to 0 topic(s):
2021-02-10 08:50:13.385: LOG-7-GRPLEADER: [thrd:main]: Group "new_cons_gp": resetting group leader info: unsubscribe
2021-02-10 08:50:13.385: LOG-7-REBALANCE: [thrd:main]: Group "new_cons_gp" initiating rebalance (EAGER) in state up (join-state steady) with 1 assigned partition(s): unsubscribe
2021-02-10 08:50:13.385: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state steady -> wait-unassign-call (state up)
2021-02-10 08:50:13.385: LOG-7-ASSIGN: [thrd:main]: Group "new_cons_gp": delegating revoke of 1 partition(s) to application on queue rd_kafka_consumer_close: unsubscribe
2021-02-10 08:50:13.385: LOG-7-PAUSE: [thrd:main]: Pausing fetchers for 1 assigned partition(s): rebalance
2021-02-10 08:50:13.385: LOG-7-ASSIGNMENT: [thrd:main]: Group "new_cons_gp": clearing group assignment
2021-02-10 08:50:13.385: LOG-7-DUMP: [thrd:main]: Assignment dump (started_cnt=1, wait_stop_cnt=0)
2021-02-10 08:50:13.385: LOG-7-DUMP_ALL: [thrd:main]: List with 1 partition(s):
2021-02-10 08:50:13.385: RebalanceCb: Local: Revoke partitions: fps.dhamodha.test_hello_8[0], 
LOG-7-DUMP_ALL: [thrd:main]:  fps.dhamodha.test_hello_8 [0] offset STORED
2021-02-10 08:50:13.385: LOG-7-DUMP_PND: [thrd:main]: List with 0 partition(s):
2021-02-10 08:50:13.385: LOG-7-DUMP_QRY: [thrd:main]: List with 0 partition(s):
2021-02-10 08:50:13.385: LOG-7-DUMP_REM: [thrd:main]: List with 0 partition(s):
2021-02-10 08:50:13.385: LOG-7-ASSIGNDONE: [thrd:main]: Group "new_cons_gp": assignment operations done in join-state wait-unassign-call (rebalance rejoin=false)
2021-02-10 08:50:13.385: LOG-7-CGRPTERM: [thrd:main]: Group "new_cons_gp": waiting for assign call, 1 toppar(s), 0 commit(s) (state up, join-state wait-unassign-call) before terminating
2021-02-10 08:50:13.385: LOG-7-CGRPTERM: [thrd:main]: Group "new_cons_gp": waiting for assign call, 1 toppar(s), 0 commit(s) (state up, join-state wait-unassign-call) before terminating
2021-02-10 08:50:13.385: LOG-7-CGRPOP: [thrd:main]: Group "new_cons_gp" received op GET_REBALANCE_PROTOCOL in state up (join-state wait-unassign-call)
2021-02-10 08:50:13.385: LOG-7-CGRPTERM: [thrd:main]: Group "new_cons_gp": waiting for assign call, 1 toppar(s), 0 commit(s) (state up, join-state wait-unassign-call) before terminating
2021-02-10 08:50:13.385: LOG-7-CGRPOP: [thrd:main]: Group "new_cons_gp" received op ASSIGN in state up (join-state wait-unassign-call)
2021-02-10 08:50:13.385: LOG-7-ASSIGN: [thrd:main]: Group "new_cons_gp": Consumer is terminating: treating assign as unassign
2021-02-10 08:50:13.385: LOG-7-CLEARASSIGN: [thrd:main]: Clearing current assignment of 1 partition(s)
2021-02-10 08:50:13.385: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state wait-unassign-call -> wait-unassign-to-complete (state up)
2021-02-10 08:50:13.385: LOG-7-DUMP: [thrd:main]: Assignment dump (started_cnt=1, wait_stop_cnt=0)
2021-02-10 08:50:13.385: LOG-7-DUMP_ALL: [thrd:main]: List with 0 partition(s):
2021-02-10 08:50:13.385: LOG-7-DUMP_PND: [thrd:main]: List with 0 partition(s):
2021-02-10 08:50:13.385: LOG-7-DUMP_QRY: [thrd:main]: List with 0 partition(s):
2021-02-10 08:50:13.385: LOG-7-DUMP_REM: [thrd:main]: List with 1 partition(s):
2021-02-10 08:50:13.385: LOG-7-DUMP_REM: [thrd:main]:  fps.dhamodha.test_hello_8 [0] offset STORED
2021-02-10 08:50:13.385: LOG-7-REMOVE: [thrd:main]: Removing fps.dhamodha.test_hello_8 [0] from assignment (started=true, pending=false, queried=false, stored offset=INVALID)
2021-02-10 08:50:13.385: LOG-7-REMOVE: [thrd:main]: Served 1 removed partition(s), with 0 offset(s) to commit
2021-02-10 08:50:13.385: LOG-7-ASSIGNMENT: [thrd:main]: Current assignment of 0 partition(s) with 0 pending adds, 0 offset queries, 1 partitions awaiting stop and 0 offset commits in progress
2021-02-10 08:50:13.385: LOG-7-CGRPTERM: [thrd:main]: Group "new_cons_gp": waiting for 1 toppar(s), assignment in progress, 0 commit(s) (state up, join-state wait-unassign-to-complete) before terminating
2021-02-10 08:50:13.385: LOG-7-CGRPTERM: [thrd:main]: Group "new_cons_gp": waiting for 1 toppar(s), assignment in progress, 0 commit(s) (state up, join-state wait-unassign-to-complete) before terminating
2021-02-10 08:50:13.385: LOG-7-CGRPOP: [thrd:main]: Group "new_cons_gp" received op PARTITION_LEAVE in state up (join-state wait-unassign-to-complete) for fps.dhamodha.test_hello_8 [0]
2021-02-10 08:50:13.385: LOG-7-PARTDEL: [thrd:main]: Group "new_cons_gp": delete fps.dhamodha.test_hello_8 [0]
2021-02-10 08:50:13.385: LOG-7-CGRPTERM: [thrd:main]: Group "new_cons_gp": waiting for 0 toppar(s), assignment in progress, 0 commit(s) (state up, join-state wait-unassign-to-complete) before terminating
2021-02-10 08:50:13.385: LOG-7-STOPSERVE: [thrd:main]: All partitions awaiting stop are now stopped: serving assignment
2021-02-10 08:50:13.385: LOG-7-DUMP: [thrd:main]: Assignment dump (started_cnt=0, wait_stop_cnt=0)
2021-02-10 08:50:13.385: LOG-7-DUMP_ALL: [thrd:main]: List with 0 partition(s):
2021-02-10 08:50:13.385: LOG-7-DUMP_PND: [thrd:main]: List with 0 partition(s):
2021-02-10 08:50:13.385: LOG-7-DUMP_QRY: [thrd:main]: List with 0 partition(s):
2021-02-10 08:50:13.385: LOG-7-DUMP_REM: [thrd:main]: List with 0 partition(s):
2021-02-10 08:50:13.385: LOG-7-ASSIGNDONE: [thrd:main]: Group "new_cons_gp": assignment operations done in join-state wait-unassign-to-complete (rebalance rejoin=false)
2021-02-10 08:50:13.385: LOG-7-UNASSIGN: [thrd:main]: Group "new_cons_gp": unassign done in state up (join-state wait-unassign-to-complete)
2021-02-10 08:50:13.385: LOG-7-MEMBERID: [thrd:main]: Group "new_cons_gp": updating member id "cppcona-80711f7e-d278-4857-8297-8c6bb9acb426" -> ""
2021-02-10 08:50:13.385: LOG-7-LEAVE: [thrd:main]: Group "new_cons_gp": leave (in state up)
2021-02-10 08:50:13.385: LOG-7-NOREJOIN: [thrd:main]: Group "new_cons_gp": Not rejoining group without an assignment: Unassignment done: no subscribed topics
2021-02-10 08:50:13.385: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state wait-unassign-to-complete -> init (state up)
2021-02-10 08:50:13.385: LOG-7-CGRPTERM: [thrd:main]: Group "new_cons_gp": waiting for 0 toppar(s), 0 commit(s), wait-leave, (state up, join-state init) before terminating
2021-02-10 08:50:13.387: LOG-7-LEAVEGROUP: [thrd:main]: LeaveGroup response received in state up
2021-02-10 08:50:13.387: LOG-7-CGRPSTATE: [thrd:main]: Group "new_cons_gp" changed state up -> term (join-state init)
2021-02-10 08:50:13.387: LOG-7-ASSIGNMENT: [thrd:main]: Group "new_cons_gp": clearing group assignment
2021-02-10 08:50:13.387: LOG-7-COORDCLEAR: [thrd:main]: Group "new_cons_gp" broker sasl_plaintext://u-kafkatst-kafkadev-5.sd.firm.com:9092/5 is no longer coordinator
2021-02-10 08:50:13.387: LOG-7-DESTROY: [thrd:app]: Terminating instance (destroy flags NoConsumerClose (0x8))
2021-02-10 08:50:13.387: LOG-7-DESTROY: [thrd:main]: Destroy internal
2021-02-10 08:50:13.387: LOG-7-DESTROY: [thrd:main]: Removing all topics
2021-02-10 08:50:13.387: LOG-7-MEMBERID: [thrd:app]: Group "new_cons_gp": updating member id "" -> "(not-set)"
% Consumed 0 messages (0 bytes)

Feb 10 '21 13:02 dshivashankar1994

Consumer 2:

/codemill/dhamodha/projects/librdkafka-1.6.0/examples/rdkafka_complex_consumer_example_cpp -b u-kafkatst-kafkadev-1.sd.firm.com:9092,u-kafkatst-kafkadev-2.sd.firm.com:9092,u-kafkatst-kafkadev-3.sd.firm.com:9092,u-kafkatst-kafkadev-4.sd.firm.com:9092,u-kafkatst-kafkadev-5.sd.firm.com:9092 -g new_cons_gp -X security.protocol=SASL_PLAINTEXT -X sasl.kerberos.service.name=kafka -X sasl.mechanism=GSSAPI -X sasl.kerberos.kinit.cmd='skinit --force' -X client.id=cppconz  -X topic.metadata.refresh.interval.ms=300  fps.dhamodha.test_hello_8 -d cgrp
dhamodha acquired ticket: client dhamodha/[email protected], server krbtgt/[email protected]
2021-02-10 08:49:41.557: LOG-7-MEMBERID: [thrd:app]: Group "new_cons_gp": updating member id "(not-set)" -> ""
2021-02-10 08:49:41.557: LOG-7-CGRPSTATE: [thrd:main]: Group "new_cons_gp" changed state init -> query-coord (join-state init)
2021-02-10 08:49:41.557: LOG-7-CGRPQUERY: [thrd:main]: Group "new_cons_gp": no broker available for coordinator query: intervaled in state query-coord
2021-02-10 08:49:41.557: LOG-7-INIT: [thrd:app]: librdkafka v1.6.0 (0x10600ff) cppconz#consumer-1 initialized (builtin.features gzip,snappy,ssl,sasl,regex,lz4,sasl_gssapi,sasl_plain,sasl_scram,plugins,zstd,sasl_oauthbearer, GCC GXX PKGCONFIG INSTALL GNULD LDS LIBDL PLUGINS ZLIB SSL SASL_CYRUS ZSTD HDRHISTOGRAM LZ4_EXT SYSLOG SNAPPY SOCKEM SASL_SCRAM SASL_OAUTHBEARER CRC32C_HW, debug 0x100)
% Created consumer cppconz#consumer-1
2021-02-10 08:49:41.557: LOG-7-CGRPOP: [thrd:main]: Group "new_cons_gp" received op SUBSCRIBE in state query-coord (join-state init)
2021-02-10 08:49:41.557: LOG-7-SUBSCRIBE: [thrd:main]: Group "new_cons_gp": subscribe to new subscription of 1 topics (join-state init)
2021-02-10 08:49:41.557: LOG-7-CGRPQUERY: [thrd:main]: Group "new_cons_gp": no broker available for coordinator query: intervaled in state query-coord
2021-02-10 08:49:41.578: LOG-7-CGRPQUERY: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-1.sd.firm.com:9092/bootstrap: Group "new_cons_gp": querying for coordinator: intervaled in state query-coord
2021-02-10 08:49:41.578: LOG-7-CGRPSTATE: [thrd:main]: Group "new_cons_gp" changed state query-coord -> wait-coord (join-state init)
2021-02-10 08:49:41.581: LOG-7-CGRPCOORD: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-1.sd.firm.com:9092/1: Group "new_cons_gp" coordinator is u-kafkatst-kafkadev-5.sd.firm.com:9092 id 5
2021-02-10 08:49:41.581: LOG-7-CGRPCOORD: [thrd:main]: Group "new_cons_gp" changing coordinator -1 -> 5
2021-02-10 08:49:41.581: LOG-7-COORDSET: [thrd:main]: Group "new_cons_gp" coordinator set to broker sasl_plaintext://u-kafkatst-kafkadev-5.sd.firm.com:9092/5
2021-02-10 08:49:41.581: LOG-7-CGRPSTATE: [thrd:main]: Group "new_cons_gp" changed state wait-coord -> wait-broker-transport (join-state init)
2021-02-10 08:49:41.581: LOG-7-CGRPQUERY: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-1.sd.firm.com:9092/1: Group "new_cons_gp": querying for coordinator: intervaled in state wait-broker-transport
2021-02-10 08:49:41.582: LOG-7-CGRPCOORD: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-1.sd.firm.com:9092/1: Group "new_cons_gp" coordinator is u-kafkatst-kafkadev-5.sd.firm.com:9092 id 5
2021-02-10 08:49:41.592: LOG-7-CGRPSTATE: [thrd:main]: Group "new_cons_gp" changed state wait-broker-transport -> up (join-state init)
2021-02-10 08:49:41.593: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": join with 0 subscribed topic(s)
2021-02-10 08:49:41.593: LOG-7-CGRPMETADATA: [thrd:main]: consumer join: metadata for subscription only available for 0/1 topics (-1ms old)
2021-02-10 08:49:41.593: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": postponing join until up-to-date metadata is available
2021-02-10 08:49:41.593: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state init -> wait-metadata (state up)
2021-02-10 08:49:41.593: LOG-7-DUMP: [thrd:main]: Assignment dump (started_cnt=0, wait_stop_cnt=0)
2021-02-10 08:49:41.593: LOG-7-DUMP_ALL: [thrd:main]: List with 0 partition(s):
2021-02-10 08:49:41.593: LOG-7-DUMP_PND: [thrd:main]: List with 0 partition(s):
2021-02-10 08:49:41.593: LOG-7-DUMP_QRY: [thrd:main]: List with 0 partition(s):
2021-02-10 08:49:41.593: LOG-7-DUMP_REM: [thrd:main]: List with 0 partition(s):
2021-02-10 08:49:41.593: LOG-7-ASSIGNDONE: [thrd:main]: Group "new_cons_gp": assignment operations done in join-state wait-metadata (rebalance rejoin=false)
2021-02-10 08:49:41.594: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:49:41.594: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp": subscription updated from metadata change: rejoining group
2021-02-10 08:49:41.594: LOG-7-GRPLEADER: [thrd:main]: Group "new_cons_gp": resetting group leader info: group (re)join
2021-02-10 08:49:41.594: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp" (re)joining in join-state wait-metadata with 0 assigned partition(s): Metadata for subscribed topic(s) has changed
2021-02-10 08:49:41.594: LOG-7-REBALANCE: [thrd:main]: Group "new_cons_gp" initiating rebalance (NONE) in state up (join-state wait-metadata) with 0 assigned partition(s): Metadata for subscribed topic(s) has changed
2021-02-10 08:49:41.594: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp": Rejoining group without an assignment: Metadata for subscribed topic(s) has changed
2021-02-10 08:49:41.594: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state wait-metadata -> init (state up)
2021-02-10 08:49:41.594: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": join with 0 subscribed topic(s)
2021-02-10 08:49:41.594: LOG-7-CGRPMETADATA: [thrd:main]: consumer join: metadata for subscription is up to date (0ms old)
2021-02-10 08:49:41.594: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:49:41.594: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": no matching topics based on 0ms old metadata: next metadata refresh in 300ms
2021-02-10 08:49:41.594: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:49:41.858: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:49:42.158: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:49:42.458: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:49:42.756: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": join with 0 subscribed topic(s)
2021-02-10 08:49:42.756: LOG-7-CGRPMETADATA: [thrd:main]: consumer join: metadata for subscription only available for 0/1 topics (-1ms old)
2021-02-10 08:49:42.756: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": postponing join until up-to-date metadata is available
2021-02-10 08:49:42.756: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state init -> wait-metadata (state up)
2021-02-10 08:49:42.758: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:49:42.758: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp": subscription updated from metadata change: rejoining group
2021-02-10 08:49:42.758: LOG-7-GRPLEADER: [thrd:main]: Group "new_cons_gp": resetting group leader info: group (re)join
2021-02-10 08:49:42.758: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp" (re)joining in join-state wait-metadata with 0 assigned partition(s): Metadata for subscribed topic(s) has changed
2021-02-10 08:49:42.758: LOG-7-REBALANCE: [thrd:main]: Group "new_cons_gp" initiating rebalance (NONE) in state up (join-state wait-metadata) with 0 assigned partition(s): Metadata for subscribed topic(s) has changed
2021-02-10 08:49:42.758: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp": Rejoining group without an assignment: Metadata for subscribed topic(s) has changed
2021-02-10 08:49:42.758: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state wait-metadata -> init (state up)
2021-02-10 08:49:42.758: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": join with 0 subscribed topic(s)
2021-02-10 08:49:42.758: LOG-7-CGRPMETADATA: [thrd:main]: consumer join: metadata for subscription is up to date (0ms old)
2021-02-10 08:49:42.758: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:49:42.758: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": no matching topics based on 0ms old metadata: next metadata refresh in 300ms
2021-02-10 08:49:42.758: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:49:42.759: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:49:43.058: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:49:43.358: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:49:43.658: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:49:43.758: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": join with 0 subscribed topic(s)
2021-02-10 08:49:43.758: LOG-7-CGRPMETADATA: [thrd:main]: consumer join: metadata for subscription is up to date (99ms old)
2021-02-10 08:49:43.758: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:49:43.758: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": no matching topics based on 99ms old metadata: next metadata refresh in 201ms
2021-02-10 08:49:43.958: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:49:44.259: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:49:44.558: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:49:44.856: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": join with 0 subscribed topic(s)
2021-02-10 08:49:44.856: LOG-7-CGRPMETADATA: [thrd:main]: consumer join: metadata for subscription only available for 0/1 topics (-1ms old)
2021-02-10 08:49:44.856: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": postponing join until up-to-date metadata is available
2021-02-10 08:49:44.856: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state init -> wait-metadata (state up)
2021-02-10 08:49:44.858: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:49:44.858: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp": subscription updated from metadata change: rejoining group
2021-02-10 08:49:44.858: LOG-7-GRPLEADER: [thrd:main]: Group "new_cons_gp": resetting group leader info: group (re)join
2021-02-10 08:49:44.858: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp" (re)joining in join-state wait-metadata with 0 assigned partition(s): Metadata for subscribed topic(s) has changed
2021-02-10 08:49:44.858: LOG-7-REBALANCE: [thrd:main]: Group "new_cons_gp" initiating rebalance (NONE) in state up (join-state wait-metadata) with 0 assigned partition(s): Metadata for subscribed topic(s) has changed
2021-02-10 08:49:44.858: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp": Rejoining group without an assignment: Metadata for subscribed topic(s) has changed
2021-02-10 08:49:44.858: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state wait-metadata -> init (state up)
2021-02-10 08:49:44.858: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": join with 0 subscribed topic(s)
2021-02-10 08:49:44.858: LOG-7-CGRPMETADATA: [thrd:main]: consumer join: metadata for subscription is up to date (0ms old)
2021-02-10 08:49:44.858: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:49:44.858: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": no matching topics based on 0ms old metadata: next metadata refresh in 300ms
2021-02-10 08:49:44.858: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:49:44.859: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:49:45.158: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:49:45.458: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:49:45.759: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:49:45.858: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": join with 0 subscribed topic(s)
2021-02-10 08:49:45.858: LOG-7-CGRPMETADATA: [thrd:main]: consumer join: metadata for subscription is up to date (99ms old)
2021-02-10 08:49:45.858: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:49:45.858: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": no matching topics based on 99ms old metadata: next metadata refresh in 201ms
2021-02-10 08:49:46.059: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:49:46.359: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:49:46.557: LOG-7-DUMP: [thrd:main]: Assignment dump (started_cnt=0, wait_stop_cnt=0)
2021-02-10 08:49:46.557: LOG-7-DUMP_ALL: [thrd:main]: List with 0 partition(s):
2021-02-10 08:49:46.557: LOG-7-DUMP_PND: [thrd:main]: List with 0 partition(s):
2021-02-10 08:49:46.557: LOG-7-DUMP_QRY: [thrd:main]: List with 0 partition(s):
2021-02-10 08:49:46.557: LOG-7-DUMP_REM: [thrd:main]: List with 0 partition(s):
2021-02-10 08:49:46.557: LOG-7-ASSIGNDONE: [thrd:main]: Group "new_cons_gp": assignment operations done in join-state init (rebalance rejoin=false)
2021-02-10 08:49:46.659: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:49:46.957: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": join with 0 subscribed topic(s)
2021-02-10 08:49:46.957: LOG-7-CGRPMETADATA: [thrd:main]: consumer join: metadata for subscription only available for 0/1 topics (-1ms old)
2021-02-10 08:49:46.957: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": postponing join until up-to-date metadata is available
2021-02-10 08:49:46.957: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state init -> wait-metadata (state up)
2021-02-10 08:49:46.958: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:49:46.958: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp": subscription updated from metadata change: rejoining group
2021-02-10 08:49:46.958: LOG-7-GRPLEADER: [thrd:main]: Group "new_cons_gp": resetting group leader info: group (re)join
2021-02-10 08:49:46.958: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp" (re)joining in join-state wait-metadata with 0 assigned partition(s): Metadata for subscribed topic(s) has changed
2021-02-10 08:49:46.958: LOG-7-REBALANCE: [thrd:main]: Group "new_cons_gp" initiating rebalance (NONE) in state up (join-state wait-metadata) with 0 assigned partition(s): Metadata for subscribed topic(s) has changed
2021-02-10 08:49:46.958: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp": Rejoining group without an assignment: Metadata for subscribed topic(s) has changed
2021-02-10 08:49:46.958: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state wait-metadata -> init (state up)
2021-02-10 08:49:46.958: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": join with 0 subscribed topic(s)
2021-02-10 08:49:46.958: LOG-7-CGRPMETADATA: [thrd:main]: consumer join: metadata for subscription is up to date (0ms old)
2021-02-10 08:49:46.958: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:49:46.958: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": no matching topics based on 0ms old metadata: next metadata refresh in 300ms
2021-02-10 08:49:46.958: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:49:46.960: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:49:47.259: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:49:47.559: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:49:47.859: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": effective subscription list changed from 0 to 1 topic(s):
2021-02-10 08:49:47.859: LOG-7-SUBSCRIPTION: [thrd:main]:  Topic fps.dhamodha.test_hello_8 with 1 partition(s)
2021-02-10 08:49:47.859: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp": subscription updated from metadata change: rejoining group
2021-02-10 08:49:47.859: LOG-7-GRPLEADER: [thrd:main]: Group "new_cons_gp": resetting group leader info: group (re)join
2021-02-10 08:49:47.859: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp" (re)joining in join-state init with 0 assigned partition(s): Metadata for subscribed topic(s) has changed
2021-02-10 08:49:47.859: LOG-7-REBALANCE: [thrd:main]: Group "new_cons_gp" initiating rebalance (NONE) in state up (join-state init) with 0 assigned partition(s): Metadata for subscribed topic(s) has changed
2021-02-10 08:49:47.859: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp": Joining group without an assignment: Metadata for subscribed topic(s) has changed
2021-02-10 08:49:47.859: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": join with 1 subscribed topic(s)
2021-02-10 08:49:47.859: LOG-7-CGRPMETADATA: [thrd:main]: consumer join: metadata for subscription is up to date (0ms old)
2021-02-10 08:49:47.859: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state init -> wait-join (state up)
2021-02-10 08:49:47.859: LOG-7-JOINGROUP: [thrd:main]: JoinGroup response: GenerationId -1, Protocol , LeaderId , my MemberId cppconz-1d2e0ff1-4927-4c96-bdc1-9a0441302eff, member metadata count 0: Broker: Group member needs a valid member ID
2021-02-10 08:49:47.859: LOG-7-MEMBERID: [thrd:main]: Group "new_cons_gp": updating member id "" -> "cppconz-1d2e0ff1-4927-4c96-bdc1-9a0441302eff"
2021-02-10 08:49:47.859: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp": Rejoining group without an assignment: JoinGroup error: Broker: Group member needs a valid member ID
2021-02-10 08:49:47.859: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state wait-join -> init (state up)
2021-02-10 08:49:47.859: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": join with 1 subscribed topic(s)
2021-02-10 08:49:47.859: LOG-7-CGRPMETADATA: [thrd:main]: consumer join: metadata for subscription is up to date (0ms old)
2021-02-10 08:49:47.859: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state init -> wait-join (state up)
2021-02-10 08:49:47.860: LOG-7-JOINGROUP: [thrd:main]: JoinGroup response: GenerationId 35, Protocol range, LeaderId cppconz-1d2e0ff1-4927-4c96-bdc1-9a0441302eff (me), my MemberId cppconz-1d2e0ff1-4927-4c96-bdc1-9a0441302eff, member metadata count 1: (no error)
2021-02-10 08:49:47.860: LOG-7-JOINGROUP: [thrd:main]: I am elected leader for group "new_cons_gp" with 1 member(s)
2021-02-10 08:49:47.860: LOG-7-GRPLEADER: [thrd:main]: Group "new_cons_gp": resetting group leader info: JoinGroup response clean-up
2021-02-10 08:49:47.860: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state wait-join -> wait-metadata (state up)
2021-02-10 08:49:47.861: LOG-7-ASSIGN: [thrd:main]: Group "new_cons_gp" running range assignor for 1 member(s) and 1 eligible subscribed topic(s):
2021-02-10 08:49:47.861: LOG-7-ASSIGN: [thrd:main]:  Member "cppconz-1d2e0ff1-4927-4c96-bdc1-9a0441302eff" (me) with 0 assigned partition(s) and 1 subscribed topic(s):
2021-02-10 08:49:47.861: LOG-7-ASSIGN: [thrd:main]:   fps.dhamodha.test_hello_8 [-1]
2021-02-10 08:49:47.861: LOG-7-ASSIGN: [thrd:main]: range: Topic fps.dhamodha.test_hello_8 with 1 partition(s) and 1 subscribing member(s)
2021-02-10 08:49:47.861: LOG-7-ASSIGN: [thrd:main]: range: Member "cppconz-1d2e0ff1-4927-4c96-bdc1-9a0441302eff": assigned topic fps.dhamodha.test_hello_8 partitions 0..0
2021-02-10 08:49:47.861: LOG-7-ASSIGN: [thrd:main]: Group "new_cons_gp" range assignment for 1 member(s) finished in 0.034ms:
2021-02-10 08:49:47.861: LOG-7-ASSIGN: [thrd:main]:  Member "cppconz-1d2e0ff1-4927-4c96-bdc1-9a0441302eff" (me) assigned 1 partition(s):
2021-02-10 08:49:47.861: LOG-7-ASSIGN: [thrd:main]:   fps.dhamodha.test_hello_8 [0]
2021-02-10 08:49:47.861: LOG-7-ASSIGNOR: [thrd:main]: Group "new_cons_gp": "range" assignor run for 1 member(s)
2021-02-10 08:49:47.861: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state wait-metadata -> wait-sync (state up)
2021-02-10 08:49:47.861: LOG-7-SYNCGROUP: [thrd:main]: SyncGroup response: Success (45 bytes of MemberState data)
2021-02-10 08:49:47.861: LOG-7-ASSIGNMENT: [thrd:main]: List with 1 partition(s):
2021-02-10 08:49:47.861: LOG-7-ASSIGNMENT: [thrd:main]:  fps.dhamodha.test_hello_8 [0] offset INVALID
2021-02-10 08:49:47.861: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state wait-sync -> wait-assign-call (state up)
2021-02-10 08:49:47.861: LOG-7-ASSIGN: [thrd:main]: Group "new_cons_gp": delegating assign of 1 partition(s) to application on queue rd_kafka_cgrp_new: new assignment
2021-02-10 08:49:47.861: LOG-7-ASSIGNMENT: [thrd:main]: Group "new_cons_gp": setting group assignment to 1 partition(s)
2021-02-10 08:49:47.861: LOG-7-GRPASSIGNMENT: [thrd:main]: List with 1 partition(s):
2021-02-10 08:49:47.861: LOG-7-GRPASSIGNMENT: [thrd:main]:  fps.dhamodha.test_hello_8 [0] offset INVALID
2021-02-10 08:49:47.861: LOG-7-HEARTBEAT: [thrd:main]: GroupCoordinator/5: Heartbeat for group "new_cons_gp" generation id 35
**_### RebalanceCb: Local: Assign partitions: fps.dhamodha.test_hello_8[0],_** 
2021-02-10 08:49:47.862: LOG-7-CGRPOP: [thrd:main]: Group "new_cons_gp" received op GET_REBALANCE_PROTOCOL in state up (join-state wait-assign-call)
2021-02-10 08:49:47.862: LOG-7-CGRPOP: [thrd:main]: Group "new_cons_gp" received op ASSIGN in state up (join-state wait-assign-call)
2021-02-10 08:49:47.862: LOG-7-ASSIGN: [thrd:main]: Group "new_cons_gp": new assignment of 1 partition(s) in join-state wait-assign-call
2021-02-10 08:49:47.862: LOG-7-CLEARASSIGN: [thrd:main]: No current assignment to clear
2021-02-10 08:49:47.862: LOG-7-ASSIGNMENT: [thrd:main]: Added 1 partition(s) to assignment which now consists of 1 partition(s) where of 1 are in pending state and 0 are being queried
2021-02-10 08:49:47.862: LOG-7-PAUSE: [thrd:main]: Resuming fetchers for 1 assigned partition(s): assign called
2021-02-10 08:49:47.862: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state wait-assign-call -> steady (state up)
2021-02-10 08:49:47.862: LOG-7-DUMP: [thrd:main]: Assignment dump (started_cnt=0, wait_stop_cnt=0)
2021-02-10 08:49:47.862: LOG-7-DUMP_ALL: [thrd:main]: List with 1 partition(s):
2021-02-10 08:49:47.862: LOG-7-DUMP_ALL: [thrd:main]:  fps.dhamodha.test_hello_8 [0] offset STORED
2021-02-10 08:49:47.862: LOG-7-DUMP_PND: [thrd:main]: List with 1 partition(s):
2021-02-10 08:49:47.862: LOG-7-DUMP_PND: [thrd:main]:  fps.dhamodha.test_hello_8 [0] offset STORED
2021-02-10 08:49:47.862: LOG-7-DUMP_QRY: [thrd:main]: List with 0 partition(s):
2021-02-10 08:49:47.862: LOG-7-DUMP_REM: [thrd:main]: List with 0 partition(s):
2021-02-10 08:49:47.862: LOG-7-SRVPEND: [thrd:main]: Querying committed offset for pending assigned partition fps.dhamodha.test_hello_8 [0]
2021-02-10 08:49:47.862: LOG-7-OFFSETFETCH: [thrd:main]: Fetching committed offsets for 1 pending partition(s) in assignment
2021-02-10 08:49:47.862: LOG-7-OFFSET: [thrd:main]: GroupCoordinator/5: Fetch committed offsets for 1/1 partition(s)
2021-02-10 08:49:47.862: LOG-7-ASSIGNMENT: [thrd:main]: Current assignment of 1 partition(s) with 1 pending adds, 1 offset queries, 0 partitions awaiting stop and 0 offset commits in progress
2021-02-10 08:49:47.862: LOG-7-OFFSETFETCH: [thrd:main]: Adding fps.dhamodha.test_hello_8 [0] back to pending list with offset INVALID
2021-02-10 08:49:47.862: LOG-7-DUMP: [thrd:main]: Assignment dump (started_cnt=0, wait_stop_cnt=0)
2021-02-10 08:49:47.862: LOG-7-DUMP_ALL: [thrd:main]: List with 1 partition(s):
2021-02-10 08:49:47.862: LOG-7-DUMP_ALL: [thrd:main]:  fps.dhamodha.test_hello_8 [0] offset STORED
2021-02-10 08:49:47.862: LOG-7-DUMP_PND: [thrd:main]: List with 1 partition(s):
2021-02-10 08:49:47.862: LOG-7-DUMP_PND: [thrd:main]:  fps.dhamodha.test_hello_8 [0] offset INVALID
2021-02-10 08:49:47.862: LOG-7-DUMP_QRY: [thrd:main]: List with 0 partition(s):
2021-02-10 08:49:47.862: LOG-7-DUMP_REM: [thrd:main]: List with 0 partition(s):
2021-02-10 08:49:47.862: LOG-7-SRVPEND: [thrd:main]: Starting pending assigned partition fps.dhamodha.test_hello_8 [0] at offset INVALID
2021-02-10 08:49:47.862: LOG-7-ASSIGNDONE: [thrd:main]: Group "new_cons_gp": assignment operations done in join-state steady (rebalance rejoin=false)
2021-02-10 08:49:47.862: LOG-7-CGRPOP: [thrd:main]: Group "new_cons_gp" received op PARTITION_JOIN in state up (join-state steady) for fps.dhamodha.test_hello_8 [0]
2021-02-10 08:49:47.862: LOG-7-PARTADD: [thrd:main]: Group "new_cons_gp": add fps.dhamodha.test_hello_8 [0]

2021-02-10 08:49:50.861: LOG-7-HEARTBEAT: [thrd:main]: GroupCoordinator/5: Heartbeat for group "new_cons_gp" generation id 35
2021-02-10 08:49:50.862: LOG-7-HEARTBEAT: [thrd:main]: Group "new_cons_gp" heartbeat error response in state up (join-state steady, 1 partition(s) assigned): Broker: Group rebalance in progress
2021-02-10 08:49:50.862: LOG-7-REBALANCE: [thrd:main]: Group "new_cons_gp" is rebalancing (EAGER) in state up (join-state steady) with 1 assigned partition(s): rebalance in progress
2021-02-10 08:49:50.862: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state steady -> wait-unassign-call (state up)
2021-02-10 08:49:50.862: LOG-7-ASSIGN: [thrd:main]: Group "new_cons_gp": delegating revoke of 1 partition(s) to application on queue rd_kafka_cgrp_new: rebalance in progress
2021-02-10 08:49:50.862: LOG-7-PAUSE: [thrd:main]: Pausing fetchers for 1 assigned partition(s): rebalance
2021-02-10 08:49:50.862: LOG-7-ASSIGNMENT: [thrd:main]: Group "new_cons_gp": clearing group assignment
**_### RebalanceCb: Local: Revoke partitions: fps.dhamodha.test_hello_8[0],_** 
2021-02-10 08:49:50.862: LOG-7-CGRPOP: [thrd:main]: Group "new_cons_gp" received op GET_REBALANCE_PROTOCOL in state up (join-state wait-unassign-call)
2021-02-10 08:49:50.862: LOG-7-CGRPOP: [thrd:main]: Group "new_cons_gp" received op ASSIGN in state up (join-state wait-unassign-call)
2021-02-10 08:49:50.862: LOG-7-CLEARASSIGN: [thrd:main]: Clearing current assignment of 1 partition(s)
2021-02-10 08:49:50.862: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state wait-unassign-call -> wait-unassign-to-complete (state up)
2021-02-10 08:49:50.862: LOG-7-DUMP: [thrd:main]: Assignment dump (started_cnt=1, wait_stop_cnt=0)
2021-02-10 08:49:50.862: LOG-7-DUMP_ALL: [thrd:main]: List with 0 partition(s):
2021-02-10 08:49:50.862: LOG-7-DUMP_PND: [thrd:main]: List with 0 partition(s):
2021-02-10 08:49:50.862: LOG-7-DUMP_QRY: [thrd:main]: List with 0 partition(s):
2021-02-10 08:49:50.862: LOG-7-DUMP_REM: [thrd:main]: List with 1 partition(s):
2021-02-10 08:49:50.862: LOG-7-DUMP_REM: [thrd:main]:  fps.dhamodha.test_hello_8 [0] offset STORED
2021-02-10 08:49:50.862: LOG-7-REMOVE: [thrd:main]: Removing fps.dhamodha.test_hello_8 [0] from assignment (started=true, pending=false, queried=false, stored offset=1)
2021-02-10 08:49:50.862: LOG-7-REMOVE: [thrd:main]: Served 1 removed partition(s), with 1 offset(s) to commit
2021-02-10 08:49:50.862: LOG-7-ASSIGNMENT: [thrd:main]: Current assignment of 0 partition(s) with 0 pending adds, 0 offset queries, 1 partitions awaiting stop and 1 offset commits in progress
2021-02-10 08:49:50.862: LOG-7-CGRPOP: [thrd:main]: Group "new_cons_gp" received op PARTITION_LEAVE in state up (join-state wait-unassign-to-complete) for fps.dhamodha.test_hello_8 [0]
2021-02-10 08:49:50.862: LOG-7-PARTDEL: [thrd:main]: Group "new_cons_gp": delete fps.dhamodha.test_hello_8 [0]
2021-02-10 08:49:50.862: LOG-7-STOPSERVE: [thrd:main]: All partitions awaiting stop are now stopped: serving assignment
2021-02-10 08:49:50.862: LOG-7-DUMP: [thrd:main]: Assignment dump (started_cnt=0, wait_stop_cnt=0)
2021-02-10 08:49:50.862: LOG-7-DUMP_ALL: [thrd:main]: List with 0 partition(s):
2021-02-10 08:49:50.862: LOG-7-DUMP_PND: [thrd:main]: List with 0 partition(s):
2021-02-10 08:49:50.862: LOG-7-DUMP_QRY: [thrd:main]: List with 0 partition(s):
2021-02-10 08:49:50.862: LOG-7-DUMP_REM: [thrd:main]: List with 0 partition(s):
2021-02-10 08:49:50.862: LOG-7-ASSIGNMENT: [thrd:main]: Current assignment of 0 partition(s) with 0 pending adds, 0 offset queries, 0 partitions awaiting stop and 1 offset commits in progress
2021-02-10 08:49:50.862: LOG-7-COMMIT: [thrd:main]: GroupCoordinator/5: OffsetCommit for 1 partition(s) in join-state wait-unassign-to-complete: unassigned partitions: returned: Success
2021-02-10 08:49:50.862: LOG-7-DUMP: [thrd:main]: Assignment dump (started_cnt=0, wait_stop_cnt=0)
2021-02-10 08:49:50.862: LOG-7-DUMP_ALL: [thrd:main]: List with 0 partition(s):
2021-02-10 08:49:50.862: LOG-7-DUMP_PND: [thrd:main]: List with 0 partition(s):
2021-02-10 08:49:50.862: LOG-7-DUMP_QRY: [thrd:main]: List with 0 partition(s):
2021-02-10 08:49:50.862: LOG-7-DUMP_REM: [thrd:main]: List with 0 partition(s):
2021-02-10 08:49:50.862: LOG-7-ASSIGNDONE: [thrd:main]: Group "new_cons_gp": assignment operations done in join-state wait-unassign-to-complete (rebalance rejoin=false)
2021-02-10 08:49:50.862: LOG-7-UNASSIGN: [thrd:main]: Group "new_cons_gp": unassign done in state up (join-state wait-unassign-to-complete)
2021-02-10 08:49:50.862: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp": Rejoining group without an assignment: Unassignment done
2021-02-10 08:49:50.862: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state wait-unassign-to-complete -> init (state up)
2021-02-10 08:49:50.862: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": join with 1 subscribed topic(s)
2021-02-10 08:49:50.862: LOG-7-CGRPMETADATA: [thrd:main]: consumer join: metadata for subscription is up to date (203ms old)
2021-02-10 08:49:50.862: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state init -> wait-join (state up)
2021-02-10 08:49:50.864: LOG-7-JOINGROUP: [thrd:main]: JoinGroup response: GenerationId 36, Protocol range, LeaderId cppconz-1d2e0ff1-4927-4c96-bdc1-9a0441302eff (me), my MemberId cppconz-1d2e0ff1-4927-4c96-bdc1-9a0441302eff, member metadata count 2: (no error)
2021-02-10 08:49:50.864: LOG-7-JOINGROUP: [thrd:main]: I am elected leader for group "new_cons_gp" with 2 member(s)
2021-02-10 08:49:50.864: LOG-7-GRPLEADER: [thrd:main]: Group "new_cons_gp": resetting group leader info: JoinGroup response clean-up
2021-02-10 08:49:50.864: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state wait-join -> wait-metadata (state up)
2021-02-10 08:49:50.865: LOG-7-ASSIGN: [thrd:main]: Group "new_cons_gp" running range assignor for 2 member(s) and 1 eligible subscribed topic(s):
2021-02-10 08:49:50.865: LOG-7-ASSIGN: [thrd:main]:  Member "cppconz-1d2e0ff1-4927-4c96-bdc1-9a0441302eff" (me) with 0 assigned partition(s) and 1 subscribed topic(s):
2021-02-10 08:49:50.865: LOG-7-ASSIGN: [thrd:main]:   fps.dhamodha.test_hello_8 [-1]
2021-02-10 08:49:50.865: LOG-7-ASSIGN: [thrd:main]:  Member "cppcona-80711f7e-d278-4857-8297-8c6bb9acb426" with 0 assigned partition(s) and 1 subscribed topic(s):
2021-02-10 08:49:50.865: LOG-7-ASSIGN: [thrd:main]:   fps.dhamodha.test_hello_8 [-1]
2021-02-10 08:49:50.865: LOG-7-ASSIGN: [thrd:main]: range: Topic fps.dhamodha.test_hello_8 with 1 partition(s) and 2 subscribing member(s)
2021-02-10 08:49:50.865: LOG-7-ASSIGN: [thrd:main]: range: Member "cppcona-80711f7e-d278-4857-8297-8c6bb9acb426": assigned topic fps.dhamodha.test_hello_8 partitions 0..0
2021-02-10 08:49:50.865: LOG-7-ASSIGN: [thrd:main]: Group "new_cons_gp" range assignment for 2 member(s) finished in 0.045ms:
2021-02-10 08:49:50.865: LOG-7-ASSIGN: [thrd:main]:  Member "cppconz-1d2e0ff1-4927-4c96-bdc1-9a0441302eff" (me) assigned 0 partition(s):
2021-02-10 08:49:50.865: LOG-7-ASSIGN: [thrd:main]:  Member "cppcona-80711f7e-d278-4857-8297-8c6bb9acb426" assigned 1 partition(s):
2021-02-10 08:49:50.865: LOG-7-ASSIGN: [thrd:main]:   fps.dhamodha.test_hello_8 [0]
2021-02-10 08:49:50.865: LOG-7-ASSIGNOR: [thrd:main]: Group "new_cons_gp": "range" assignor run for 2 member(s)
2021-02-10 08:49:50.865: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state wait-metadata -> wait-sync (state up)
2021-02-10 08:49:50.866: LOG-7-SYNCGROUP: [thrd:main]: SyncGroup response: Success (10 bytes of MemberState data)
2021-02-10 08:49:50.866: LOG-7-ASSIGNMENT: [thrd:main]: List with 0 partition(s):
2021-02-10 08:49:50.866: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state wait-sync -> wait-assign-call (state up)
2021-02-10 08:49:50.866: LOG-7-ASSIGN: [thrd:main]: Group "new_cons_gp": delegating assign of 0 partition(s) to application on queue rd_kafka_cgrp_new: new assignment
2021-02-10 08:49:50.866: LOG-7-ASSIGNMENT: [thrd:main]: Group "new_cons_gp": setting group assignment to 0 partition(s)
2021-02-10 08:49:50.866: LOG-7-GRPASSIGNMENT: [thrd:main]: List with 0 partition(s):
**_### RebalanceCb: Local: Assign partitions:_** 
2021-02-10 08:49:50.866: LOG-7-CGRPOP: [thrd:main]: Group "new_cons_gp" received op GET_REBALANCE_PROTOCOL in state up (join-state wait-assign-call)
2021-02-10 08:49:50.866: LOG-7-CGRPOP: [thrd:main]: Group "new_cons_gp" received op ASSIGN in state up (join-state wait-assign-call)
2021-02-10 08:49:50.866: LOG-7-ASSIGN: [thrd:main]: Group "new_cons_gp": new assignment of 0 partition(s) in join-state wait-assign-call
2021-02-10 08:49:50.866: LOG-7-CLEARASSIGN: [thrd:main]: No current assignment to clear
2021-02-10 08:49:50.866: LOG-7-ASSIGNMENT: [thrd:main]: Added 0 partition(s) to assignment which now consists of 0 partition(s) where of 0 are in pending state and 0 are being queried
2021-02-10 08:49:50.866: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state wait-assign-call -> steady (state up)
2021-02-10 08:49:50.866: LOG-7-DUMP: [thrd:main]: Assignment dump (started_cnt=0, wait_stop_cnt=0)
2021-02-10 08:49:50.866: LOG-7-DUMP_ALL: [thrd:main]: List with 0 partition(s):
2021-02-10 08:49:50.866: LOG-7-DUMP_PND: [thrd:main]: List with 0 partition(s):
2021-02-10 08:49:50.866: LOG-7-DUMP_QRY: [thrd:main]: List with 0 partition(s):
2021-02-10 08:49:50.866: LOG-7-DUMP_REM: [thrd:main]: List with 0 partition(s):
2021-02-10 08:49:50.866: LOG-7-ASSIGNDONE: [thrd:main]: Group "new_cons_gp": assignment operations done in join-state steady (rebalance rejoin=false)
2021-02-10 08:49:51.557: LOG-7-DUMP: [thrd:main]: Assignment dump (started_cnt=0, wait_stop_cnt=0)
2021-02-10 08:49:51.557: LOG-7-DUMP_ALL: [thrd:main]: List with 0 partition(s):
2021-02-10 08:49:51.557: LOG-7-DUMP_PND: [thrd:main]: List with 0 partition(s):
2021-02-10 08:49:51.557: LOG-7-DUMP_QRY: [thrd:main]: List with 0 partition(s):
2021-02-10 08:49:51.557: LOG-7-DUMP_REM: [thrd:main]: List with 0 partition(s):
2021-02-10 08:49:51.557: LOG-7-ASSIGNDONE: [thrd:main]: Group "new_cons_gp": assignment operations done in join-state steady (rebalance rejoin=false)
2021-02-10 08:49:53.865: LOG-7-HEARTBEAT: [thrd:main]: GroupCoordinator/5: Heartbeat for group "new_cons_gp" generation id 36
2021-02-10 08:49:56.557: LOG-7-DUMP: [thrd:main]: Assignment dump (started_cnt=0, wait_stop_cnt=0)
2021-02-10 08:49:56.557: LOG-7-DUMP_ALL: [thrd:main]: List with 0 partition(s):
2021-02-10 08:49:56.557: LOG-7-DUMP_PND: [thrd:main]: List with 0 partition(s):
2021-02-10 08:49:56.557: LOG-7-DUMP_QRY: [thrd:main]: List with 0 partition(s):
2021-02-10 08:49:56.557: LOG-7-DUMP_REM: [thrd:main]: List with 0 partition(s):
2021-02-10 08:49:56.557: LOG-7-ASSIGNDONE: [thrd:main]: Group "new_cons_gp": assignment operations done in join-state steady (rebalance rejoin=false)
2021-02-10 08:49:56.865: LOG-7-HEARTBEAT: [thrd:main]: GroupCoordinator/5: Heartbeat for group "new_cons_gp" generation id 36
2021-02-10 08:49:59.866: LOG-7-HEARTBEAT: [thrd:main]: GroupCoordinator/5: Heartbeat for group "new_cons_gp" generation id 36
2021-02-10 08:50:01.557: LOG-7-DUMP: [thrd:main]: Assignment dump (started_cnt=0, wait_stop_cnt=0)
2021-02-10 08:50:01.557: LOG-7-DUMP_ALL: [thrd:main]: List with 0 partition(s):
2021-02-10 08:50:01.557: LOG-7-DUMP_PND: [thrd:main]: List with 0 partition(s):
2021-02-10 08:50:01.557: LOG-7-DUMP_QRY: [thrd:main]: List with 0 partition(s):
2021-02-10 08:50:01.557: LOG-7-DUMP_REM: [thrd:main]: List with 0 partition(s):
2021-02-10 08:50:01.557: LOG-7-ASSIGNDONE: [thrd:main]: Group "new_cons_gp": assignment operations done in join-state steady (rebalance rejoin=false)
2021-02-10 08:50:02.866: LOG-7-HEARTBEAT: [thrd:main]: GroupCoordinator/5: Heartbeat for group "new_cons_gp" generation id 36
2021-02-10 08:50:05.866: LOG-7-HEARTBEAT: [thrd:main]: GroupCoordinator/5: Heartbeat for group "new_cons_gp" generation id 36
2021-02-10 08:50:06.557: LOG-7-DUMP: [thrd:main]: Assignment dump (started_cnt=0, wait_stop_cnt=0)
2021-02-10 08:50:06.557: LOG-7-DUMP_ALL: [thrd:main]: List with 0 partition(s):
2021-02-10 08:50:06.557: LOG-7-DUMP_PND: [thrd:main]: List with 0 partition(s):
2021-02-10 08:50:06.557: LOG-7-DUMP_QRY: [thrd:main]: List with 0 partition(s):
2021-02-10 08:50:06.557: LOG-7-DUMP_REM: [thrd:main]: List with 0 partition(s):
2021-02-10 08:50:06.557: LOG-7-ASSIGNDONE: [thrd:main]: Group "new_cons_gp": assignment operations done in join-state steady (rebalance rejoin=false)
2021-02-10 08:50:08.866: LOG-7-HEARTBEAT: [thrd:main]: GroupCoordinator/5: Heartbeat for group "new_cons_gp" generation id 36
2021-02-10 08:50:11.557: LOG-7-DUMP: [thrd:main]: Assignment dump (started_cnt=0, wait_stop_cnt=0)
2021-02-10 08:50:11.557: LOG-7-DUMP_ALL: [thrd:main]: List with 0 partition(s):
2021-02-10 08:50:11.557: LOG-7-DUMP_PND: [thrd:main]: List with 0 partition(s):
2021-02-10 08:50:11.557: LOG-7-DUMP_QRY: [thrd:main]: List with 0 partition(s):
2021-02-10 08:50:11.557: LOG-7-DUMP_REM: [thrd:main]: List with 0 partition(s):
2021-02-10 08:50:11.557: LOG-7-ASSIGNDONE: [thrd:main]: Group "new_cons_gp": assignment operations done in join-state steady (rebalance rejoin=false)
2021-02-10 08:50:11.866: LOG-7-HEARTBEAT: [thrd:main]: GroupCoordinator/5: Heartbeat for group "new_cons_gp" generation id 36
2021-02-10 08:50:12.160: LOG-7-CGRPOP: [thrd:main]: Group "new_cons_gp" received op TERMINATE in state up (join-state steady)
2021-02-10 08:50:12.160: LOG-7-CGRPTERM: [thrd:main]: Terminating group "new_cons_gp" in state up with 0 partition(s)
2021-02-10 08:50:12.160: LOG-7-UNSUBSCRIBE: [thrd:main]: Group "new_cons_gp": unsubscribe from current subscription of size 1 (leave group=true, has joined=true, cppconz-1d2e0ff1-4927-4c96-bdc1-9a0441302eff, join-state steady)
2021-02-10 08:50:12.160: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": clearing subscribed topics list (1)
2021-02-10 08:50:12.160: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": effective subscription list changed from 1 to 0 topic(s):
2021-02-10 08:50:12.160: LOG-7-GRPLEADER: [thrd:main]: Group "new_cons_gp": resetting group leader info: unsubscribe
2021-02-10 08:50:12.160: LOG-7-REBALANCE: [thrd:main]: Group "new_cons_gp" initiating rebalance (EAGER) in state up (join-state steady) with 0 assigned partition(s): unsubscribe
2021-02-10 08:50:12.160: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state steady -> wait-unassign-call (state up)
2021-02-10 08:50:12.160: LOG-7-ASSIGN: [thrd:main]: Group "new_cons_gp": delegating revoke of 0 partition(s) to application on queue rd_kafka_consumer_close: unsubscribe
2021-02-10 08:50:12.160: LOG-7-ASSIGNMENT: [thrd:main]: Group "new_cons_gp": clearing group assignment
2021-02-10 08:50:12.160: LOG-7-DUMP: [thrd:main]: Assignment dump (started_cnt=0, wait_stop_cnt=0)
RebalanceCb: Local: Revoke partitions: 
2021-02-10 08:50:12.160: LOG-7-DUMP_ALL: [thrd:main]: List with 0 partition(s):
2021-02-10 08:50:12.160: LOG-7-DUMP_PND: [thrd:main]: List with 0 partition(s):
2021-02-10 08:50:12.160: LOG-7-DUMP_QRY: [thrd:main]: List with 0 partition(s):
2021-02-10 08:50:12.160: LOG-7-DUMP_REM: [thrd:main]: List with 0 partition(s):
2021-02-10 08:50:12.160: LOG-7-ASSIGNDONE: [thrd:main]: Group "new_cons_gp": assignment operations done in join-state wait-unassign-call (rebalance rejoin=false)
2021-02-10 08:50:12.160: LOG-7-CGRPTERM: [thrd:main]: Group "new_cons_gp": waiting for assign call, 0 toppar(s), 0 commit(s) (state up, join-state wait-unassign-call) before terminating
2021-02-10 08:50:12.160: LOG-7-CGRPTERM: [thrd:main]: Group "new_cons_gp": waiting for assign call, 0 toppar(s), 0 commit(s) (state up, join-state wait-unassign-call) before terminating
2021-02-10 08:50:12.160: LOG-7-CGRPOP: [thrd:main]: Group "new_cons_gp" received op GET_REBALANCE_PROTOCOL in state up (join-state wait-unassign-call)
2021-02-10 08:50:12.160: LOG-7-CGRPTERM: [thrd:main]: Group "new_cons_gp": waiting for assign call, 0 toppar(s), 0 commit(s) (state up, join-state wait-unassign-call) before terminating
2021-02-10 08:50:12.160: LOG-7-CGRPOP: [thrd:main]: Group "new_cons_gp" received op ASSIGN in state up (join-state wait-unassign-call)
2021-02-10 08:50:12.160: LOG-7-ASSIGN: [thrd:main]: Group "new_cons_gp": Consumer is terminating: treating assign as unassign
2021-02-10 08:50:12.160: LOG-7-CLEARASSIGN: [thrd:main]: No current assignment to clear
2021-02-10 08:50:12.160: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state wait-unassign-call -> wait-unassign-to-complete (state up)
2021-02-10 08:50:12.160: LOG-7-DUMP: [thrd:main]: Assignment dump (started_cnt=0, wait_stop_cnt=0)
2021-02-10 08:50:12.160: LOG-7-DUMP_ALL: [thrd:main]: List with 0 partition(s):
2021-02-10 08:50:12.160: LOG-7-DUMP_PND: [thrd:main]: List with 0 partition(s):
2021-02-10 08:50:12.160: LOG-7-DUMP_QRY: [thrd:main]: List with 0 partition(s):
2021-02-10 08:50:12.160: LOG-7-DUMP_REM: [thrd:main]: List with 0 partition(s):
2021-02-10 08:50:12.160: LOG-7-ASSIGNDONE: [thrd:main]: Group "new_cons_gp": assignment operations done in join-state wait-unassign-to-complete (rebalance rejoin=false)
2021-02-10 08:50:12.160: LOG-7-UNASSIGN: [thrd:main]: Group "new_cons_gp": unassign done in state up (join-state wait-unassign-to-complete)
2021-02-10 08:50:12.160: LOG-7-MEMBERID: [thrd:main]: Group "new_cons_gp": updating member id "cppconz-1d2e0ff1-4927-4c96-bdc1-9a0441302eff" -> ""
2021-02-10 08:50:12.160: LOG-7-LEAVE: [thrd:main]: Group "new_cons_gp": leave (in state up)
2021-02-10 08:50:12.160: LOG-7-NOREJOIN: [thrd:main]: Group "new_cons_gp": Not rejoining group without an assignment: Unassignment done: no subscribed topics
2021-02-10 08:50:12.160: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state wait-unassign-to-complete -> init (state up)
2021-02-10 08:50:12.160: LOG-7-CGRPTERM: [thrd:main]: Group "new_cons_gp": waiting for 0 toppar(s), 0 commit(s), wait-leave, (state up, join-state init) before terminating
2021-02-10 08:50:12.161: LOG-7-LEAVEGROUP: [thrd:main]: LeaveGroup response received in state up
2021-02-10 08:50:12.161: LOG-7-CGRPSTATE: [thrd:main]: Group "new_cons_gp" changed state up -> term (join-state init)
2021-02-10 08:50:12.161: LOG-7-ASSIGNMENT: [thrd:main]: Group "new_cons_gp": clearing group assignment
2021-02-10 08:50:12.161: LOG-7-COORDCLEAR: [thrd:main]: Group "new_cons_gp" broker sasl_plaintext://u-kafkatst-kafkadev-5.sd.firm.com:9092/5 is no longer coordinator
2021-02-10 08:50:12.161: LOG-7-DESTROY: [thrd:app]: Terminating instance (destroy flags NoConsumerClose (0x8))
2021-02-10 08:50:12.161: LOG-7-DESTROY: [thrd:main]: Destroy internal
2021-02-10 08:50:12.161: LOG-7-DESTROY: [thrd:main]: Removing all topics
2021-02-10 08:50:12.162: LOG-7-MEMBERID: [thrd:app]: Group "new_cons_gp": updating member id "" -> "(not-set)"
% Consumed 1 messages (67 bytes)

Feb 10 '21 13:02 dshivashankar1994

2021-02-10 08:49:42.758: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp" (re)joining in join-state wait-metadata with 0 assigned partition(s): Metadata for subscribed topic(s) has changed

It'd be interesting to understand why it thinks the metadata changed; will have to ask you to reproduce this with debug=cgrp,topic,metadata on v1.6.0.

Thanks

Feb 10 '21 13:02 edenhill

Consumer 1:

[email protected](nyc):/codemill/dhamodha/projects/librdkafka-1.6.0> /codemill/dhamodha/projects/librdkafka-1.6.0/examples/rdkafka_complex_consumer_example_cpp -b u-kafkatst-kafkadev-1.sd.firm.com:9092,u-kafkatst-kafkadev-2.sd.firm.com:9092,u-kafkatst-kafkadev-3.sd.firm.com:9092,u-kafkatst-kafkadev-4.sd.firm.com:9092,u-kafkatst-kafkadev-5.sd.firm.com:9092 -g new_cons_gp -X security.protocol=SASL_PLAINTEXT -X sasl.kerberos.service.name=kafka -X sasl.mechanism=GSSAPI -X sasl.kerberos.kinit.cmd='skinit --force' -X client.id=cppcona -X topic.metadata.refresh.interval.ms=100000 fps.dhamodha.test_hello_9 -d cgrp,topic,metadata
dhamodha acquired ticket: client dhamodha/[email protected], server krbtgt/[email protected]
2021-02-10 08:58:48.255: LOG-7-MEMBERID: [thrd:app]: Group "new_cons_gp": updating member id "(not-set)" -> ""
2021-02-10 08:58:48.255: LOG-7-CGRPSTATE: [thrd:main]: Group "new_cons_gp" changed state init -> query-coord (join-state init)
2021-02-10 08:58:48.255: LOG-7-CGRPQUERY: [thrd:main]: Group "new_cons_gp": no broker available for coordinator query: intervaled in state query-coord
2021-02-10 08:58:48.255: LOG-7-INIT: [thrd:app]: librdkafka v1.6.0 (0x10600ff) cppcona#consumer-1 initialized (builtin.features gzip,snappy,ssl,sasl,regex,lz4,sasl_gssapi,sasl_plain,sasl_scram,plugins,zstd,sasl_oauthbearer, GCC GXX PKGCONFIG INSTALL GNULD LDS LIBDL PLUGINS ZLIB SSL SASL_CYRUS ZSTD HDRHISTOGRAM LZ4_EXT SYSLOG SNAPPY SOCKEM SASL_SCRAM SASL_OAUTHBEARER CRC32C_HW, debug 0x10c)
% Created consumer cppcona#consumer-1
2021-02-10 08:58:48.256: LOG-7-CGRPOP: [thrd:main]: Group "new_cons_gp" received op SUBSCRIBE in state query-coord (join-state init)
2021-02-10 08:58:48.256: LOG-7-SUBSCRIBE: [thrd:main]: Group "new_cons_gp": subscribe to new subscription of 1 topics (join-state init)
2021-02-10 08:58:48.256: LOG-7-CGRPQUERY: [thrd:main]: Group "new_cons_gp": no broker available for coordinator query: intervaled in state query-coord
2021-02-10 08:58:48.267: 2021-02-10 08:58:48.267: LOG-7-CGRPQUERY: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/bootstrap: Group "new_cons_gp": querying for coordinator: intervaled in state query-coord
LOG-7-METADATA: [thrd:sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/boots]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/bootstrap: Request metadata for brokers only: connected
2021-02-10 08:58:48.267: LOG-7-CGRPSTATE: [thrd:main]: Group "new_cons_gp" changed state query-coord -> wait-coord (join-state init)
2021-02-10 08:58:48.268: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/bootstrap: ===== Received metadata: connected =====
2021-02-10 08:58:48.268: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/bootstrap: ClusterId: f2omDNr9THyyx9GLoe5bIA, ControllerId: 1
2021-02-10 08:58:48.268: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/bootstrap: 5 brokers, 0 topics
2021-02-10 08:58:48.268: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/bootstrap:   Broker #0/5: u-kafkatst-kafkadev-5.sd.firm.com:9092 NodeId 5
2021-02-10 08:58:48.268: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/bootstrap:   Broker #1/5: u-kafkatst-kafkadev-4.sd.firm.com:9092 NodeId 4
2021-02-10 08:58:48.268: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/bootstrap:   Broker #2/5: u-kafkatst-kafkadev-1.sd.firm.com:9092 NodeId 1
2021-02-10 08:58:48.268: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/bootstrap:   Broker #3/5: u-kafkatst-kafkadev-2.sd.firm.com:9092 NodeId 2
2021-02-10 08:58:48.268: LOG-7-LEADER: [thrd:sasl_plaintext://u-kafkatst-kafkadev-5.sd.firm.com:9092/boots]: sasl_plaintext://u-kafkatst-kafkadev-5.sd.firm.com:9092/5: Mapped 0 partition(s) to broker
2021-02-10 08:58:48.268: LOG-7-LEADER: [thrd:sasl_plaintext://u-kafkatst-kafkadev-4.sd.firm.com:9092/boots]: sasl_plaintext://u-kafkatst-kafkadev-4.sd.firm.com:9092/4: Mapped 0 partition(s) to broker
2021-02-10 08:58:48.268: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/bootstrap:   Broker #4/5: u-kafkatst-kafkadev-3.sd.firm.com:9092 NodeId 3
2021-02-10 08:58:48.268: LOG-7-LEADER: [thrd:sasl_plaintext://u-kafkatst-kafkadev-1.sd.firm.com:9092/boots]: sasl_plaintext://u-kafkatst-kafkadev-1.sd.firm.com:9092/1: Mapped 0 partition(s) to broker
2021-02-10 08:58:48.268: 2021-02-10 08:58:48.268: LOG-7-LEADER: [thrd:sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/boots]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3: Mapped 0 partition(s) to broker
2021-02-10 08:58:48.268: LOG-7-CGRPCOORD: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3: Group "new_cons_gp" coordinator is u-kafkatst-kafkadev-5.sd.firm.com:9092 id 5
LOG-7-LEADER: [thrd:sasl_plaintext://u-kafkatst-kafkadev-2.sd.firm.com:9092/boots]: sasl_plaintext://u-kafkatst-kafkadev-2.sd.firm.com:9092/2: Mapped 0 partition(s) to broker
2021-02-10 08:58:48.268: LOG-7-CGRPCOORD: [thrd:main]: Group "new_cons_gp" changing coordinator -1 -> 5
2021-02-10 08:58:48.268: LOG-7-COORDSET: [thrd:main]: Group "new_cons_gp" coordinator set to broker sasl_plaintext://u-kafkatst-kafkadev-5.sd.firm.com:9092/5
2021-02-10 08:58:48.268: LOG-7-CGRPSTATE: [thrd:main]: Group "new_cons_gp" changed state wait-coord -> wait-broker-transport (join-state init)
2021-02-10 08:58:48.268: LOG-7-CGRPQUERY: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3: Group "new_cons_gp": querying for coordinator: intervaled in state wait-broker-transport
2021-02-10 08:58:48.268: LOG-7-CGRPCOORD: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3: Group "new_cons_gp" coordinator is u-kafkatst-kafkadev-5.sd.firm.com:9092 id 5
2021-02-10 08:58:48.279: LOG-7-METADATA: [thrd:GroupCoordinator]: GroupCoordinator/5: Request metadata for brokers only: connected
2021-02-10 08:58:48.279: LOG-7-CGRPSTATE: [thrd:main]: Group "new_cons_gp" changed state wait-broker-transport -> up (join-state init)
2021-02-10 08:58:48.279: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": join with 0 subscribed topic(s)
2021-02-10 08:58:48.279: LOG-7-METADATA: [thrd:main]: Hinted cache of 1/1 topic(s) being queried
2021-02-10 08:58:48.279: LOG-7-CGRPMETADATA: [thrd:main]: consumer join: metadata for subscription only available for 0/1 topics (-1ms old)
2021-02-10 08:58:48.279: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3: Request metadata for 1 topic(s): consumer join
2021-02-10 08:58:48.279: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": postponing join until up-to-date metadata is available
2021-02-10 08:58:48.279: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state init -> wait-metadata (state up)
2021-02-10 08:58:48.279: LOG-7-DUMP: [thrd:main]: Assignment dump (started_cnt=0, wait_stop_cnt=0)
2021-02-10 08:58:48.279: LOG-7-DUMP_ALL: [thrd:main]: List with 0 partition(s):
2021-02-10 08:58:48.279: LOG-7-DUMP_PND: [thrd:main]: List with 0 partition(s):
2021-02-10 08:58:48.279: LOG-7-DUMP_QRY: [thrd:main]: List with 0 partition(s):
2021-02-10 08:58:48.279: LOG-7-DUMP_REM: [thrd:main]: List with 0 partition(s):
2021-02-10 08:58:48.279: LOG-7-ASSIGNDONE: [thrd:main]: Group "new_cons_gp": assignment operations done in join-state wait-metadata (rebalance rejoin=false)
2021-02-10 08:58:48.279: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3: ===== Received metadata (for 1 requested topics): consumer join =====
2021-02-10 08:58:48.279: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3: ClusterId: f2omDNr9THyyx9GLoe5bIA, ControllerId: 1
2021-02-10 08:58:48.279: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3: 5 brokers, 1 topics
2021-02-10 08:58:48.279: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3:   Broker #0/5: u-kafkatst-kafkadev-5.sd.firm.com:9092 NodeId 5
2021-02-10 08:58:48.279: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3:   Broker #1/5: u-kafkatst-kafkadev-4.sd.firm.com:9092 NodeId 4
2021-02-10 08:58:48.279: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3:   Broker #2/5: u-kafkatst-kafkadev-1.sd.firm.com:9092 NodeId 1
2021-02-10 08:58:48.279: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3:   Broker #3/5: u-kafkatst-kafkadev-2.sd.firm.com:9092 NodeId 2
2021-02-10 08:58:48.279: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3:   Broker #4/5: u-kafkatst-kafkadev-3.sd.firm.com:9092 NodeId 3
2021-02-10 08:58:48.279: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3:   Topic #0/1: fps.dhamodha.test_hello_9 with 0 partitions: Broker: Unknown topic or partition
2021-02-10 08:58:48.279: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3: 1/1 requested topic(s) seen in metadata
2021-02-10 08:58:48.279: LOG-7-TOPICERR: [thrd:main]: Subscribed topic not available: fps.dhamodha.test_hello_9: Broker: Unknown topic or partition
2021-02-10 08:58:48.279: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:58:48.279: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp": subscription updated from metadata change: rejoining group
2021-02-10 08:58:48.279: LOG-7-GRPLEADER: [thrd:main]: Group "new_cons_gp": resetting group leader info: group (re)join
2021-02-10 08:58:48.279: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp" (re)joining in join-state wait-metadata with 0 assigned partition(s): Metadata for subscribed topic(s) has changed
2021-02-10 08:58:48.279: LOG-7-REBALANCE: [thrd:main]: Group "new_cons_gp" initiating rebalance (NONE) in state up (join-state wait-metadata) with 0 assigned partition(s): Metadata for subscribed topic(s) has changed
2021-02-10 08:58:48.279: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp": Rejoining group without an assignment: Metadata for subscribed topic(s) has changed
2021-02-10 08:58:48.279: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state wait-metadata -> init (state up)
2021-02-10 08:58:48.279: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": join with 0 subscribed topic(s)
2021-02-10 08:58:48.279: LOG-7-CGRPMETADATA: [thrd:main]: consumer join: metadata for subscription is up to date (0ms old)
2021-02-10 08:58:48.279: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:58:48.279: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": no matching topics based on 0ms old metadata: next metadata refresh in 100000ms
2021-02-10 08:58:48.279: LOG-7-METADATA: [thrd:main]: GroupCoordinator/5: ===== Received metadata: connected =====
2021-02-10 08:58:48.279: LOG-7-METADATA: [thrd:main]: GroupCoordinator/5: ClusterId: f2omDNr9THyyx9GLoe5bIA, ControllerId: 1
2021-02-10 08:58:48.279: LOG-7-METADATA: [thrd:main]: GroupCoordinator/5: 5 brokers, 0 topics
2021-02-10 08:58:48.279: LOG-7-METADATA: [thrd:main]: GroupCoordinator/5:   Broker #0/5: u-kafkatst-kafkadev-5.sd.firm.com:9092 NodeId 5
2021-02-10 08:58:48.279: LOG-7-METADATA: [thrd:main]: GroupCoordinator/5:   Broker #1/5: u-kafkatst-kafkadev-4.sd.firm.com:9092 NodeId 4
2021-02-10 08:58:48.279: LOG-7-METADATA: [thrd:main]: GroupCoordinator/5:   Broker #2/5: u-kafkatst-kafkadev-1.sd.firm.com:9092 NodeId 1
2021-02-10 08:58:48.279: LOG-7-METADATA: [thrd:main]: GroupCoordinator/5:   Broker #3/5: u-kafkatst-kafkadev-2.sd.firm.com:9092 NodeId 2
2021-02-10 08:58:48.279: LOG-7-METADATA: [thrd:main]: GroupCoordinator/5:   Broker #4/5: u-kafkatst-kafkadev-3.sd.firm.com:9092 NodeId 3
2021-02-10 08:58:48.279: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:58:48.379: LOG-7-METADATA: [thrd:main]: Expired 1 entries from metadata cache (0 entries remain)
2021-02-10 08:58:50.254: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": join with 0 subscribed topic(s)
2021-02-10 08:58:50.254: LOG-7-METADATA: [thrd:main]: Hinted cache of 1/1 topic(s) being queried
2021-02-10 08:58:50.254: LOG-7-CGRPMETADATA: [thrd:main]: consumer join: metadata for subscription only available for 0/1 topics (-1ms old)
2021-02-10 08:58:50.254: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3: Request metadata for 1 topic(s): consumer join
2021-02-10 08:58:50.254: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": postponing join until up-to-date metadata is available
2021-02-10 08:58:50.254: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state init -> wait-metadata (state up)
2021-02-10 08:58:50.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3: ===== Received metadata (for 1 requested topics): consumer join =====
2021-02-10 08:58:50.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3: ClusterId: f2omDNr9THyyx9GLoe5bIA, ControllerId: 1
2021-02-10 08:58:50.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3: 5 brokers, 1 topics
2021-02-10 08:58:50.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3:   Broker #0/5: u-kafkatst-kafkadev-5.sd.firm.com:9092 NodeId 5
2021-02-10 08:58:50.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3:   Broker #1/5: u-kafkatst-kafkadev-4.sd.firm.com:9092 NodeId 4
2021-02-10 08:58:50.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3:   Broker #2/5: u-kafkatst-kafkadev-1.sd.firm.com:9092 NodeId 1
2021-02-10 08:58:50.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3:   Broker #3/5: u-kafkatst-kafkadev-2.sd.firm.com:9092 NodeId 2
2021-02-10 08:58:50.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3:   Broker #4/5: u-kafkatst-kafkadev-3.sd.firm.com:9092 NodeId 3
2021-02-10 08:58:50.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3:   Topic #0/1: fps.dhamodha.test_hello_9 with 0 partitions: Broker: Unknown topic or partition
2021-02-10 08:58:50.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3: 1/1 requested topic(s) seen in metadata
2021-02-10 08:58:50.255: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:58:50.255: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp": subscription updated from metadata change: rejoining group
2021-02-10 08:58:50.255: LOG-7-GRPLEADER: [thrd:main]: Group "new_cons_gp": resetting group leader info: group (re)join
2021-02-10 08:58:50.255: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp" (re)joining in join-state wait-metadata with 0 assigned partition(s): Metadata for subscribed topic(s) has changed
2021-02-10 08:58:50.255: LOG-7-REBALANCE: [thrd:main]: Group "new_cons_gp" initiating rebalance (NONE) in state up (join-state wait-metadata) with 0 assigned partition(s): Metadata for subscribed topic(s) has changed
2021-02-10 08:58:50.255: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp": Rejoining group without an assignment: Metadata for subscribed topic(s) has changed
2021-02-10 08:58:50.255: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state wait-metadata -> init (state up)
2021-02-10 08:58:50.255: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": join with 0 subscribed topic(s)
2021-02-10 08:58:50.255: LOG-7-CGRPMETADATA: [thrd:main]: consumer join: metadata for subscription is up to date (0ms old)
2021-02-10 08:58:50.255: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:58:50.255: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": no matching topics based on 0ms old metadata: next metadata refresh in 100000ms
2021-02-10 08:58:50.255: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:58:50.355: LOG-7-METADATA: [thrd:main]: Expired 1 entries from metadata cache (0 entries remain)
2021-02-10 08:58:51.255: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": join with 0 subscribed topic(s)
2021-02-10 08:58:51.255: LOG-7-METADATA: [thrd:main]: Hinted cache of 1/1 topic(s) being queried
2021-02-10 08:58:51.255: LOG-7-CGRPMETADATA: [thrd:main]: consumer join: metadata for subscription only available for 0/1 topics (-1ms old)
2021-02-10 08:58:51.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3: Request metadata for 1 topic(s): consumer join
2021-02-10 08:58:51.255: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": postponing join until up-to-date metadata is available
2021-02-10 08:58:51.255: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state init -> wait-metadata (state up)
2021-02-10 08:58:51.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3: ===== Received metadata (for 1 requested topics): consumer join =====
2021-02-10 08:58:51.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3: ClusterId: f2omDNr9THyyx9GLoe5bIA, ControllerId: 1
2021-02-10 08:58:51.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3: 5 brokers, 1 topics
2021-02-10 08:58:51.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3:   Broker #0/5: u-kafkatst-kafkadev-5.sd.firm.com:9092 NodeId 5
2021-02-10 08:58:51.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3:   Broker #1/5: u-kafkatst-kafkadev-4.sd.firm.com:9092 NodeId 4
2021-02-10 08:58:51.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3:   Broker #2/5: u-kafkatst-kafkadev-1.sd.firm.com:9092 NodeId 1
2021-02-10 08:58:51.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3:   Broker #3/5: u-kafkatst-kafkadev-2.sd.firm.com:9092 NodeId 2
2021-02-10 08:58:51.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3:   Broker #4/5: u-kafkatst-kafkadev-3.sd.firm.com:9092 NodeId 3
2021-02-10 08:58:51.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3:   Topic #0/1: fps.dhamodha.test_hello_9 with 0 partitions: Broker: Unknown topic or partition
2021-02-10 08:58:51.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3: 1/1 requested topic(s) seen in metadata
2021-02-10 08:58:51.255: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:58:51.255: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp": subscription updated from metadata change: rejoining group
2021-02-10 08:58:51.255: LOG-7-GRPLEADER: [thrd:main]: Group "new_cons_gp": resetting group leader info: group (re)join
2021-02-10 08:58:51.255: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp" (re)joining in join-state wait-metadata with 0 assigned partition(s): Metadata for subscribed topic(s) has changed
2021-02-10 08:58:51.255: LOG-7-REBALANCE: [thrd:main]: Group "new_cons_gp" initiating rebalance (NONE) in state up (join-state wait-metadata) with 0 assigned partition(s): Metadata for subscribed topic(s) has changed
2021-02-10 08:58:51.255: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp": Rejoining group without an assignment: Metadata for subscribed topic(s) has changed
2021-02-10 08:58:51.255: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state wait-metadata -> init (state up)
2021-02-10 08:58:51.255: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": join with 0 subscribed topic(s)
2021-02-10 08:58:51.255: LOG-7-CGRPMETADATA: [thrd:main]: consumer join: metadata for subscription is up to date (0ms old)
2021-02-10 08:58:51.255: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:58:51.255: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": no matching topics based on 0ms old metadata: next metadata refresh in 100000ms
2021-02-10 08:58:51.255: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:58:51.355: LOG-7-METADATA: [thrd:main]: Expired 1 entries from metadata cache (0 entries remain)
2021-02-10 08:58:53.254: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": join with 0 subscribed topic(s)
2021-02-10 08:58:53.254: LOG-7-METADATA: [thrd:main]: Hinted cache of 1/1 topic(s) being queried
2021-02-10 08:58:53.254: LOG-7-CGRPMETADATA: [thrd:main]: consumer join: metadata for subscription only available for 0/1 topics (-1ms old)
2021-02-10 08:58:53.254: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3: Request metadata for 1 topic(s): consumer join
2021-02-10 08:58:53.254: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": postponing join until up-to-date metadata is available
2021-02-10 08:58:53.254: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state init -> wait-metadata (state up)
2021-02-10 08:58:53.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3: ===== Received metadata (for 1 requested topics): consumer join =====
2021-02-10 08:58:53.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3: ClusterId: f2omDNr9THyyx9GLoe5bIA, ControllerId: 1
2021-02-10 08:58:53.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3: 5 brokers, 1 topics
2021-02-10 08:58:53.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3:   Broker #0/5: u-kafkatst-kafkadev-5.sd.firm.com:9092 NodeId 5
2021-02-10 08:58:53.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3:   Broker #1/5: u-kafkatst-kafkadev-4.sd.firm.com:9092 NodeId 4
2021-02-10 08:58:53.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3:   Broker #2/5: u-kafkatst-kafkadev-1.sd.firm.com:9092 NodeId 1
2021-02-10 08:58:53.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3:   Broker #3/5: u-kafkatst-kafkadev-2.sd.firm.com:9092 NodeId 2
2021-02-10 08:58:53.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3:   Broker #4/5: u-kafkatst-kafkadev-3.sd.firm.com:9092 NodeId 3
2021-02-10 08:58:53.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3:   Topic #0/1: fps.dhamodha.test_hello_9 with 0 partitions: Broker: Unknown topic or partition
2021-02-10 08:58:53.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3: 1/1 requested topic(s) seen in metadata
2021-02-10 08:58:53.255: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:58:53.255: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp": subscription updated from metadata change: rejoining group
2021-02-10 08:58:53.255: LOG-7-GRPLEADER: [thrd:main]: Group "new_cons_gp": resetting group leader info: group (re)join
2021-02-10 08:58:53.255: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp" (re)joining in join-state wait-metadata with 0 assigned partition(s): Metadata for subscribed topic(s) has changed
2021-02-10 08:58:53.255: LOG-7-REBALANCE: [thrd:main]: Group "new_cons_gp" initiating rebalance (NONE) in state up (join-state wait-metadata) with 0 assigned partition(s): Metadata for subscribed topic(s) has changed
2021-02-10 08:58:53.255: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp": Rejoining group without an assignment: Metadata for subscribed topic(s) has changed
2021-02-10 08:58:53.255: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state wait-metadata -> init (state up)
2021-02-10 08:58:53.255: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": join with 0 subscribed topic(s)
2021-02-10 08:58:53.255: LOG-7-CGRPMETADATA: [thrd:main]: consumer join: metadata for subscription is up to date (0ms old)
2021-02-10 08:58:53.255: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:58:53.255: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": no matching topics based on 0ms old metadata: next metadata refresh in 100000ms
2021-02-10 08:58:53.255: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:58:53.255: LOG-7-DUMP: [thrd:main]: Assignment dump (started_cnt=0, wait_stop_cnt=0)
2021-02-10 08:58:53.255: LOG-7-DUMP_ALL: [thrd:main]: List with 0 partition(s):
2021-02-10 08:58:53.255: LOG-7-DUMP_PND: [thrd:main]: List with 0 partition(s):
2021-02-10 08:58:53.255: LOG-7-DUMP_QRY: [thrd:main]: List with 0 partition(s):
2021-02-10 08:58:53.255: LOG-7-DUMP_REM: [thrd:main]: List with 0 partition(s):
2021-02-10 08:58:53.255: LOG-7-ASSIGNDONE: [thrd:main]: Group "new_cons_gp": assignment operations done in join-state init (rebalance rejoin=false)
2021-02-10 08:58:53.355: LOG-7-METADATA: [thrd:main]: Expired 1 entries from metadata cache (0 entries remain)
2021-02-10 08:58:54.255: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": join with 0 subscribed topic(s)
2021-02-10 08:58:54.255: LOG-7-METADATA: [thrd:main]: Hinted cache of 1/1 topic(s) being queried
2021-02-10 08:58:54.255: LOG-7-CGRPMETADATA: [thrd:main]: consumer join: metadata for subscription only available for 0/1 topics (-1ms old)
2021-02-10 08:58:54.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3: Request metadata for 1 topic(s): consumer join
2021-02-10 08:58:54.255: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": postponing join until up-to-date metadata is available
2021-02-10 08:58:54.255: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state init -> wait-metadata (state up)
2021-02-10 08:58:54.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3: ===== Received metadata (for 1 requested topics): consumer join =====
2021-02-10 08:58:54.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3: ClusterId: f2omDNr9THyyx9GLoe5bIA, ControllerId: 1
2021-02-10 08:58:54.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3: 5 brokers, 1 topics
2021-02-10 08:58:54.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3:   Broker #0/5: u-kafkatst-kafkadev-5.sd.firm.com:9092 NodeId 5
2021-02-10 08:58:54.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3:   Broker #1/5: u-kafkatst-kafkadev-4.sd.firm.com:9092 NodeId 4
2021-02-10 08:58:54.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3:   Broker #2/5: u-kafkatst-kafkadev-1.sd.firm.com:9092 NodeId 1
2021-02-10 08:58:54.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3:   Broker #3/5: u-kafkatst-kafkadev-2.sd.firm.com:9092 NodeId 2
2021-02-10 08:58:54.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3:   Broker #4/5: u-kafkatst-kafkadev-3.sd.firm.com:9092 NodeId 3
2021-02-10 08:58:54.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3:   Topic #0/1: fps.dhamodha.test_hello_9 with 0 partitions: Broker: Unknown topic or partition
2021-02-10 08:58:54.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3: 1/1 requested topic(s) seen in metadata
2021-02-10 08:58:54.255: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:58:54.255: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp": subscription updated from metadata change: rejoining group
2021-02-10 08:58:54.255: LOG-7-GRPLEADER: [thrd:main]: Group "new_cons_gp": resetting group leader info: group (re)join
2021-02-10 08:58:54.255: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp" (re)joining in join-state wait-metadata with 0 assigned partition(s): Metadata for subscribed topic(s) has changed
2021-02-10 08:58:54.255: LOG-7-REBALANCE: [thrd:main]: Group "new_cons_gp" initiating rebalance (NONE) in state up (join-state wait-metadata) with 0 assigned partition(s): Metadata for subscribed topic(s) has changed
2021-02-10 08:58:54.255: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp": Rejoining group without an assignment: Metadata for subscribed topic(s) has changed
2021-02-10 08:58:54.255: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state wait-metadata -> init (state up)
2021-02-10 08:58:54.255: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": join with 0 subscribed topic(s)
2021-02-10 08:58:54.255: LOG-7-CGRPMETADATA: [thrd:main]: consumer join: metadata for subscription is up to date (0ms old)
2021-02-10 08:58:54.255: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:58:54.255: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": no matching topics based on 0ms old metadata: next metadata refresh in 100000ms
2021-02-10 08:58:54.255: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:58:54.355: LOG-7-METADATA: [thrd:main]: Expired 1 entries from metadata cache (0 entries remain)
2021-02-10 08:58:56.254: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": join with 0 subscribed topic(s)
2021-02-10 08:58:56.254: LOG-7-METADATA: [thrd:main]: Hinted cache of 1/1 topic(s) being queried
2021-02-10 08:58:56.254: LOG-7-CGRPMETADATA: [thrd:main]: consumer join: metadata for subscription only available for 0/1 topics (-1ms old)
2021-02-10 08:58:56.254: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3: Request metadata for 1 topic(s): consumer join
2021-02-10 08:58:56.254: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": postponing join until up-to-date metadata is available
2021-02-10 08:58:56.254: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state init -> wait-metadata (state up)
2021-02-10 08:58:56.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3: ===== Received metadata (for 1 requested topics): consumer join =====
2021-02-10 08:58:56.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3: ClusterId: f2omDNr9THyyx9GLoe5bIA, ControllerId: 1
2021-02-10 08:58:56.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3: 5 brokers, 1 topics
2021-02-10 08:58:56.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3:   Broker #0/5: u-kafkatst-kafkadev-5.sd.firm.com:9092 NodeId 5
2021-02-10 08:58:56.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3:   Broker #1/5: u-kafkatst-kafkadev-4.sd.firm.com:9092 NodeId 4
2021-02-10 08:58:56.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3:   Broker #2/5: u-kafkatst-kafkadev-1.sd.firm.com:9092 NodeId 1
2021-02-10 08:58:56.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3:   Broker #3/5: u-kafkatst-kafkadev-2.sd.firm.com:9092 NodeId 2
2021-02-10 08:58:56.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3:   Broker #4/5: u-kafkatst-kafkadev-3.sd.firm.com:9092 NodeId 3
2021-02-10 08:58:56.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3:   Topic #0/1: fps.dhamodha.test_hello_9 with 0 partitions: Broker: Unknown topic or partition
2021-02-10 08:58:56.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3: 1/1 requested topic(s) seen in metadata
2021-02-10 08:58:56.255: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:58:56.255: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp": subscription updated from metadata change: rejoining group
2021-02-10 08:58:56.255: LOG-7-GRPLEADER: [thrd:main]: Group "new_cons_gp": resetting group leader info: group (re)join
2021-02-10 08:58:56.255: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp" (re)joining in join-state wait-metadata with 0 assigned partition(s): Metadata for subscribed topic(s) has changed
2021-02-10 08:58:56.255: LOG-7-REBALANCE: [thrd:main]: Group "new_cons_gp" initiating rebalance (NONE) in state up (join-state wait-metadata) with 0 assigned partition(s): Metadata for subscribed topic(s) has changed
2021-02-10 08:58:56.255: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp": Rejoining group without an assignment: Metadata for subscribed topic(s) has changed
2021-02-10 08:58:56.255: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state wait-metadata -> init (state up)
2021-02-10 08:58:56.255: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": join with 0 subscribed topic(s)
2021-02-10 08:58:56.255: LOG-7-CGRPMETADATA: [thrd:main]: consumer join: metadata for subscription is up to date (0ms old)
2021-02-10 08:58:56.255: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:58:56.255: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": no matching topics based on 0ms old metadata: next metadata refresh in 100000ms
2021-02-10 08:58:56.255: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:58:56.355: LOG-7-METADATA: [thrd:main]: Expired 1 entries from metadata cache (0 entries remain)
2021-02-10 08:58:57.255: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": join with 0 subscribed topic(s)
2021-02-10 08:58:57.255: LOG-7-METADATA: [thrd:main]: Hinted cache of 1/1 topic(s) being queried
2021-02-10 08:58:57.255: LOG-7-CGRPMETADATA: [thrd:main]: consumer join: metadata for subscription only available for 0/1 topics (-1ms old)
2021-02-10 08:58:57.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3: Request metadata for 1 topic(s): consumer join
2021-02-10 08:58:57.255: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": postponing join until up-to-date metadata is available
2021-02-10 08:58:57.255: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state init -> wait-metadata (state up)
2021-02-10 08:58:57.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3: ===== Received metadata (for 1 requested topics): consumer join =====
2021-02-10 08:58:57.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3: ClusterId: f2omDNr9THyyx9GLoe5bIA, ControllerId: 1
2021-02-10 08:58:57.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3: 5 brokers, 1 topics
2021-02-10 08:58:57.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3:   Broker #0/5: u-kafkatst-kafkadev-5.sd.firm.com:9092 NodeId 5
2021-02-10 08:58:57.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3:   Broker #1/5: u-kafkatst-kafkadev-4.sd.firm.com:9092 NodeId 4
2021-02-10 08:58:57.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3:   Broker #2/5: u-kafkatst-kafkadev-1.sd.firm.com:9092 NodeId 1
2021-02-10 08:58:57.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3:   Broker #3/5: u-kafkatst-kafkadev-2.sd.firm.com:9092 NodeId 2
2021-02-10 08:58:57.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3:   Broker #4/5: u-kafkatst-kafkadev-3.sd.firm.com:9092 NodeId 3
2021-02-10 08:58:57.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3:   Topic #0/1: fps.dhamodha.test_hello_9 with 0 partitions: Broker: Unknown topic or partition
2021-02-10 08:58:57.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3: 1/1 requested topic(s) seen in metadata
2021-02-10 08:58:57.255: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:58:57.255: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp": subscription updated from metadata change: rejoining group
2021-02-10 08:58:57.255: LOG-7-GRPLEADER: [thrd:main]: Group "new_cons_gp": resetting group leader info: group (re)join
2021-02-10 08:58:57.255: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp" (re)joining in join-state wait-metadata with 0 assigned partition(s): Metadata for subscribed topic(s) has changed
2021-02-10 08:58:57.255: LOG-7-REBALANCE: [thrd:main]: Group "new_cons_gp" initiating rebalance (NONE) in state up (join-state wait-metadata) with 0 assigned partition(s): Metadata for subscribed topic(s) has changed
2021-02-10 08:58:57.255: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp": Rejoining group without an assignment: Metadata for subscribed topic(s) has changed
2021-02-10 08:58:57.255: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state wait-metadata -> init (state up)
2021-02-10 08:58:57.255: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": join with 0 subscribed topic(s)
2021-02-10 08:58:57.255: LOG-7-CGRPMETADATA: [thrd:main]: consumer join: metadata for subscription is up to date (0ms old)
2021-02-10 08:58:57.255: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:58:57.255: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": no matching topics based on 0ms old metadata: next metadata refresh in 100000ms
2021-02-10 08:58:57.255: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:58:57.355: LOG-7-METADATA: [thrd:main]: Expired 1 entries from metadata cache (0 entries remain)
2021-02-10 08:58:58.255: LOG-7-DUMP: [thrd:main]: Assignment dump (started_cnt=0, wait_stop_cnt=0)
2021-02-10 08:58:58.255: LOG-7-DUMP_ALL: [thrd:main]: List with 0 partition(s):
2021-02-10 08:58:58.255: LOG-7-DUMP_PND: [thrd:main]: List with 0 partition(s):
2021-02-10 08:58:58.255: LOG-7-DUMP_QRY: [thrd:main]: List with 0 partition(s):
2021-02-10 08:58:58.255: LOG-7-DUMP_REM: [thrd:main]: List with 0 partition(s):
2021-02-10 08:58:58.255: LOG-7-ASSIGNDONE: [thrd:main]: Group "new_cons_gp": assignment operations done in join-state init (rebalance rejoin=false)
2021-02-10 08:58:59.254: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": join with 0 subscribed topic(s)
2021-02-10 08:58:59.254: LOG-7-METADATA: [thrd:main]: Hinted cache of 1/1 topic(s) being queried
2021-02-10 08:58:59.254: LOG-7-CGRPMETADATA: [thrd:main]: consumer join: metadata for subscription only available for 0/1 topics (-1ms old)
2021-02-10 08:58:59.254: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3: Request metadata for 1 topic(s): consumer join
2021-02-10 08:58:59.254: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": postponing join until up-to-date metadata is available
2021-02-10 08:58:59.254: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state init -> wait-metadata (state up)
2021-02-10 08:58:59.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3: ===== Received metadata (for 1 requested topics): consumer join =====
2021-02-10 08:58:59.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3: ClusterId: f2omDNr9THyyx9GLoe5bIA, ControllerId: 1
2021-02-10 08:58:59.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3: 5 brokers, 1 topics
2021-02-10 08:58:59.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3:   Broker #0/5: u-kafkatst-kafkadev-5.sd.firm.com:9092 NodeId 5
2021-02-10 08:58:59.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3:   Broker #1/5: u-kafkatst-kafkadev-4.sd.firm.com:9092 NodeId 4
2021-02-10 08:58:59.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3:   Broker #2/5: u-kafkatst-kafkadev-1.sd.firm.com:9092 NodeId 1
2021-02-10 08:58:59.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3:   Broker #3/5: u-kafkatst-kafkadev-2.sd.firm.com:9092 NodeId 2
2021-02-10 08:58:59.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3:   Broker #4/5: u-kafkatst-kafkadev-3.sd.firm.com:9092 NodeId 3
2021-02-10 08:58:59.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3:   Topic #0/1: fps.dhamodha.test_hello_9 with 0 partitions: Broker: Unknown topic or partition
2021-02-10 08:58:59.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3: 1/1 requested topic(s) seen in metadata
2021-02-10 08:58:59.255: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:58:59.255: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp": subscription updated from metadata change: rejoining group
2021-02-10 08:58:59.255: LOG-7-GRPLEADER: [thrd:main]: Group "new_cons_gp": resetting group leader info: group (re)join
2021-02-10 08:58:59.255: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp" (re)joining in join-state wait-metadata with 0 assigned partition(s): Metadata for subscribed topic(s) has changed
2021-02-10 08:58:59.255: LOG-7-REBALANCE: [thrd:main]: Group "new_cons_gp" initiating rebalance (NONE) in state up (join-state wait-metadata) with 0 assigned partition(s): Metadata for subscribed topic(s) has changed
2021-02-10 08:58:59.255: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp": Rejoining group without an assignment: Metadata for subscribed topic(s) has changed
2021-02-10 08:58:59.255: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state wait-metadata -> init (state up)
2021-02-10 08:58:59.255: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": join with 0 subscribed topic(s)
2021-02-10 08:58:59.255: LOG-7-CGRPMETADATA: [thrd:main]: consumer join: metadata for subscription is up to date (0ms old)
2021-02-10 08:58:59.255: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:58:59.255: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": no matching topics based on 0ms old metadata: next metadata refresh in 100000ms
2021-02-10 08:58:59.255: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:58:59.355: LOG-7-METADATA: [thrd:main]: Expired 1 entries from metadata cache (0 entries remain)
2021-02-10 08:59:00.255: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": join with 0 subscribed topic(s)
2021-02-10 08:59:00.255: LOG-7-METADATA: [thrd:main]: Hinted cache of 1/1 topic(s) being queried
2021-02-10 08:59:00.255: LOG-7-CGRPMETADATA: [thrd:main]: consumer join: metadata for subscription only available for 0/1 topics (-1ms old)
2021-02-10 08:59:00.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3: Request metadata for 1 topic(s): consumer join
2021-02-10 08:59:00.255: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": postponing join until up-to-date metadata is available
2021-02-10 08:59:00.255: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state init -> wait-metadata (state up)
2021-02-10 08:59:00.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3: ===== Received metadata (for 1 requested topics): consumer join =====
2021-02-10 08:59:00.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3: ClusterId: f2omDNr9THyyx9GLoe5bIA, ControllerId: 1
2021-02-10 08:59:00.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3: 5 brokers, 1 topics
2021-02-10 08:59:00.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3:   Broker #0/5: u-kafkatst-kafkadev-5.sd.firm.com:9092 NodeId 5
2021-02-10 08:59:00.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3:   Broker #1/5: u-kafkatst-kafkadev-4.sd.firm.com:9092 NodeId 4
2021-02-10 08:59:00.256: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3:   Broker #2/5: u-kafkatst-kafkadev-1.sd.firm.com:9092 NodeId 1
2021-02-10 08:59:00.256: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3:   Broker #3/5: u-kafkatst-kafkadev-2.sd.firm.com:9092 NodeId 2
2021-02-10 08:59:00.256: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3:   Broker #4/5: u-kafkatst-kafkadev-3.sd.firm.com:9092 NodeId 3
2021-02-10 08:59:00.256: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3:   Topic #0/1: fps.dhamodha.test_hello_9 with 0 partitions: Broker: Unknown topic or partition
2021-02-10 08:59:00.256: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3: 1/1 requested topic(s) seen in metadata
2021-02-10 08:59:00.256: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:59:00.256: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp": subscription updated from metadata change: rejoining group
2021-02-10 08:59:00.256: LOG-7-GRPLEADER: [thrd:main]: Group "new_cons_gp": resetting group leader info: group (re)join
2021-02-10 08:59:00.256: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp" (re)joining in join-state wait-metadata with 0 assigned partition(s): Metadata for subscribed topic(s) has changed
2021-02-10 08:59:00.256: LOG-7-REBALANCE: [thrd:main]: Group "new_cons_gp" initiating rebalance (NONE) in state up (join-state wait-metadata) with 0 assigned partition(s): Metadata for subscribed topic(s) has changed
2021-02-10 08:59:00.256: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp": Rejoining group without an assignment: Metadata for subscribed topic(s) has changed
2021-02-10 08:59:00.256: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state wait-metadata -> init (state up)
2021-02-10 08:59:00.256: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": join with 0 subscribed topic(s)
2021-02-10 08:59:00.256: LOG-7-CGRPMETADATA: [thrd:main]: consumer join: metadata for subscription is up to date (0ms old)
2021-02-10 08:59:00.256: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:59:00.256: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": no matching topics based on 0ms old metadata: next metadata refresh in 100000ms
2021-02-10 08:59:00.256: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:59:00.356: LOG-7-METADATA: [thrd:main]: Expired 1 entries from metadata cache (0 entries remain)
2021-02-10 08:59:02.254: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": join with 0 subscribed topic(s)
2021-02-10 08:59:02.254: LOG-7-METADATA: [thrd:main]: Hinted cache of 1/1 topic(s) being queried
2021-02-10 08:59:02.254: LOG-7-CGRPMETADATA: [thrd:main]: consumer join: metadata for subscription only available for 0/1 topics (-1ms old)
2021-02-10 08:59:02.254: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3: Request metadata for 1 topic(s): consumer join
2021-02-10 08:59:02.254: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": postponing join until up-to-date metadata is available
2021-02-10 08:59:02.254: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state init -> wait-metadata (state up)
2021-02-10 08:59:02.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3: ===== Received metadata (for 1 requested topics): consumer join =====
2021-02-10 08:59:02.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3: ClusterId: f2omDNr9THyyx9GLoe5bIA, ControllerId: 1
2021-02-10 08:59:02.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3: 5 brokers, 1 topics
2021-02-10 08:59:02.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3:   Broker #0/5: u-kafkatst-kafkadev-5.sd.firm.com:9092 NodeId 5
2021-02-10 08:59:02.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3:   Broker #1/5: u-kafkatst-kafkadev-4.sd.firm.com:9092 NodeId 4
2021-02-10 08:59:02.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3:   Broker #2/5: u-kafkatst-kafkadev-1.sd.firm.com:9092 NodeId 1
2021-02-10 08:59:02.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3:   Broker #3/5: u-kafkatst-kafkadev-2.sd.firm.com:9092 NodeId 2
2021-02-10 08:59:02.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3:   Broker #4/5: u-kafkatst-kafkadev-3.sd.firm.com:9092 NodeId 3
2021-02-10 08:59:02.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3:   Topic #0/1: fps.dhamodha.test_hello_9 with 0 partitions: Broker: Unknown topic or partition
2021-02-10 08:59:02.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3: 1/1 requested topic(s) seen in metadata
2021-02-10 08:59:02.255: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:59:02.255: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp": subscription updated from metadata change: rejoining group
2021-02-10 08:59:02.255: LOG-7-GRPLEADER: [thrd:main]: Group "new_cons_gp": resetting group leader info: group (re)join
2021-02-10 08:59:02.255: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp" (re)joining in join-state wait-metadata with 0 assigned partition(s): Metadata for subscribed topic(s) has changed
2021-02-10 08:59:02.255: LOG-7-REBALANCE: [thrd:main]: Group "new_cons_gp" initiating rebalance (NONE) in state up (join-state wait-metadata) with 0 assigned partition(s): Metadata for subscribed topic(s) has changed
2021-02-10 08:59:02.255: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp": Rejoining group without an assignment: Metadata for subscribed topic(s) has changed
2021-02-10 08:59:02.255: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state wait-metadata -> init (state up)
2021-02-10 08:59:02.255: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": join with 0 subscribed topic(s)
2021-02-10 08:59:02.255: LOG-7-CGRPMETADATA: [thrd:main]: consumer join: metadata for subscription is up to date (0ms old)
2021-02-10 08:59:02.255: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:59:02.255: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": no matching topics based on 0ms old metadata: next metadata refresh in 100000ms
2021-02-10 08:59:02.255: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": no topics in metadata matched subscription
2021-02-10 08:59:02.355: LOG-7-METADATA: [thrd:main]: Expired 1 entries from metadata cache (0 entries remain)
2021-02-10 08:59:03.255: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": join with 0 subscribed topic(s)
2021-02-10 08:59:03.255: LOG-7-METADATA: [thrd:main]: Hinted cache of 1/1 topic(s) being queried
2021-02-10 08:59:03.255: LOG-7-CGRPMETADATA: [thrd:main]: consumer join: metadata for subscription only available for 0/1 topics (-1ms old)
2021-02-10 08:59:03.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3: Request metadata for 1 topic(s): consumer join
2021-02-10 08:59:03.255: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": postponing join until up-to-date metadata is available
2021-02-10 08:59:03.255: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state init -> wait-metadata (state up)
2021-02-10 08:59:03.255: LOG-7-DUMP: [thrd:main]: Assignment dump (started_cnt=0, wait_stop_cnt=0)
2021-02-10 08:59:03.255: LOG-7-DUMP_ALL: [thrd:main]: List with 0 partition(s):
2021-02-10 08:59:03.255: LOG-7-DUMP_PND: [thrd:main]: List with 0 partition(s):
2021-02-10 08:59:03.255: LOG-7-DUMP_QRY: [thrd:main]: List with 0 partition(s):
2021-02-10 08:59:03.255: LOG-7-DUMP_REM: [thrd:main]: List with 0 partition(s):
2021-02-10 08:59:03.255: LOG-7-ASSIGNDONE: [thrd:main]: Group "new_cons_gp": assignment operations done in join-state wait-metadata (rebalance rejoin=false)
2021-02-10 08:59:03.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3: ===== Received metadata (for 1 requested topics): consumer join =====
2021-02-10 08:59:03.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3: ClusterId: f2omDNr9THyyx9GLoe5bIA, ControllerId: 1
2021-02-10 08:59:03.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3: 5 brokers, 1 topics
2021-02-10 08:59:03.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3:   Broker #0/5: u-kafkatst-kafkadev-5.sd.firm.com:9092 NodeId 5
2021-02-10 08:59:03.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3:   Broker #1/5: u-kafkatst-kafkadev-4.sd.firm.com:9092 NodeId 4
2021-02-10 08:59:03.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3:   Broker #2/5: u-kafkatst-kafkadev-1.sd.firm.com:9092 NodeId 1
2021-02-10 08:59:03.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3:   Broker #3/5: u-kafkatst-kafkadev-2.sd.firm.com:9092 NodeId 2
2021-02-10 08:59:03.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3:   Broker #4/5: u-kafkatst-kafkadev-3.sd.firm.com:9092 NodeId 3
2021-02-10 08:59:03.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3:   Topic #0/1: fps.dhamodha.test_hello_9 with 1 partitions
2021-02-10 08:59:03.255: LOG-7-METADATA: [thrd:main]: sasl_plaintext://u-kafkatst-kafkadev-3.sd.firm.com:9092/3: 1/1 requested topic(s) seen in metadata
2021-02-10 08:59:03.255: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": effective subscription list changed from 0 to 1 topic(s):
2021-02-10 08:59:03.255: LOG-7-SUBSCRIPTION: [thrd:main]:  Topic fps.dhamodha.test_hello_9 with 1 partition(s)
2021-02-10 08:59:03.255: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp": subscription updated from metadata change: rejoining group
2021-02-10 08:59:03.255: LOG-7-GRPLEADER: [thrd:main]: Group "new_cons_gp": resetting group leader info: group (re)join
2021-02-10 08:59:03.255: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp" (re)joining in join-state wait-metadata with 0 assigned partition(s): Metadata for subscribed topic(s) has changed
2021-02-10 08:59:03.255: LOG-7-REBALANCE: [thrd:main]: Group "new_cons_gp" initiating rebalance (NONE) in state up (join-state wait-metadata) with 0 assigned partition(s): Metadata for subscribed topic(s) has changed
2021-02-10 08:59:03.255: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp": Rejoining group without an assignment: Metadata for subscribed topic(s) has changed
2021-02-10 08:59:03.255: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state wait-metadata -> init (state up)
2021-02-10 08:59:03.255: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": join with 1 subscribed topic(s)
2021-02-10 08:59:03.255: LOG-7-CGRPMETADATA: [thrd:main]: consumer join: metadata for subscription is up to date (0ms old)
2021-02-10 08:59:03.255: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state init -> wait-join (state up)
2021-02-10 08:59:03.256: LOG-7-JOINGROUP: [thrd:main]: JoinGroup response: GenerationId -1, Protocol , LeaderId , my MemberId cppcona-cd562f47-8b63-41a6-b986-5d7546b682cf, member metadata count 0: Broker: Group member needs a valid member ID
2021-02-10 08:59:03.256: LOG-7-MEMBERID: [thrd:main]: Group "new_cons_gp": updating member id "" -> "cppcona-cd562f47-8b63-41a6-b986-5d7546b682cf"
2021-02-10 08:59:03.256: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp": Rejoining group without an assignment: JoinGroup error: Broker: Group member needs a valid member ID
2021-02-10 08:59:03.256: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state wait-join -> init (state up)
2021-02-10 08:59:03.256: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": join with 1 subscribed topic(s)
2021-02-10 08:59:03.256: LOG-7-CGRPMETADATA: [thrd:main]: consumer join: metadata for subscription is up to date (0ms old)
2021-02-10 08:59:03.256: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state init -> wait-join (state up)
2021-02-10 08:59:05.649: LOG-7-JOINGROUP: [thrd:main]: JoinGroup response: GenerationId 39, Protocol range, LeaderId cppconz-7f2bde5e-0b9c-4c69-9790-4a68020a948f, my MemberId cppcona-cd562f47-8b63-41a6-b986-5d7546b682cf, member metadata count 0: (no error)
2021-02-10 08:59:05.649: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state wait-join -> wait-sync (state up)
2021-02-10 08:59:05.650: LOG-7-SYNCGROUP: [thrd:main]: SyncGroup response: Success (45 bytes of MemberState data)
2021-02-10 08:59:05.650: LOG-7-ASSIGNMENT: [thrd:main]: List with 1 partition(s):
2021-02-10 08:59:05.650: LOG-7-ASSIGNMENT: [thrd:main]:  fps.dhamodha.test_hello_9 [0] offset INVALID
2021-02-10 08:59:05.650: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state wait-sync -> wait-assign-call (state up)
2021-02-10 08:59:05.650: LOG-7-ASSIGN: [thrd:main]: Group "new_cons_gp": delegating assign of 1 partition(s) to application on queue rd_kafka_cgrp_new: new assignment
2021-02-10 08:59:05.650: LOG-7-ASSIGNMENT: [thrd:main]: Group "new_cons_gp": setting group assignment to 1 partition(s)
2021-02-10 08:59:05.650: LOG-7-GRPASSIGNMENT: [thrd:main]: List with 1 partition(s):
2021-02-10 08:59:05.650: LOG-7-GRPASSIGNMENT: [thrd:main]:  fps.dhamodha.test_hello_9 [0] offset INVALID
2021-02-10 08:59:05.650: LOG-7-HEARTBEAT: [thrd:main]: GroupCoordinator/5: Heartbeat for group "new_cons_gp" generation id 39
RebalanceCb: Local: Assign partitions: fps.dhamodha.test_hello_9[0], 
2021-02-10 08:59:05.650: LOG-7-CGRPOP: [thrd:main]: Group "new_cons_gp" received op GET_REBALANCE_PROTOCOL in state up (join-state wait-assign-call)
2021-02-10 08:59:05.650: LOG-7-CGRPOP: [thrd:main]: Group "new_cons_gp" received op ASSIGN in state up (join-state wait-assign-call)
2021-02-10 08:59:05.650: LOG-7-ASSIGN: [thrd:main]: Group "new_cons_gp": new assignment of 1 partition(s) in join-state wait-assign-call
2021-02-10 08:59:05.650: LOG-7-CLEARASSIGN: [thrd:main]: No current assignment to clear
2021-02-10 08:59:05.650: LOG-7-TOPIC: [thrd:main]: New local topic: fps.dhamodha.test_hello_9
2021-02-10 08:59:05.650: LOG-7-TOPPARNEW: [thrd:main]: NEW fps.dhamodha.test_hello_9 [-1] 0x7f587c0017f0 refcnt 0x7f587c001880 (at rd_kafka_topic_new0:465)
2021-02-10 08:59:05.650: LOG-7-STATE: [thrd:main]: Topic fps.dhamodha.test_hello_9 changed state unknown -> exists
2021-02-10 08:59:05.650: LOG-7-PARTCNT: [thrd:main]: Topic fps.dhamodha.test_hello_9 partition count changed from 0 to 1
2021-02-10 08:59:05.650: LOG-7-TOPPARNEW: [thrd:main]: NEW fps.dhamodha.test_hello_9 [0] 0x7f587c001c90 refcnt 0x7f587c001d20 (at rd_kafka_topic_partition_cnt_update:798)
2021-02-10 08:59:05.650: LOG-7-METADATA: [thrd:main]:   Topic fps.dhamodha.test_hello_9 partition 0 Leader 5
2021-02-10 08:59:05.650: LOG-7-BRKDELGT: [thrd:main]: fps.dhamodha.test_hello_9 [0]: delegate to broker sasl_plaintext://u-kafkatst-kafkadev-5.sd.firm.com:9092/5 (rktp 0x7f587c001c90, term 0, ref 2)
2021-02-10 08:59:05.650: LOG-7-BRKDELGT: [thrd:main]: fps.dhamodha.test_hello_9 [0]: delegating to broker sasl_plaintext://u-kafkatst-kafkadev-5.sd.firm.com:9092/5 for partition with 0 messages (0 bytes) queued
2021-02-10 08:59:05.650: LOG-7-BRKMIGR: [thrd:main]: Migrating topic fps.dhamodha.test_hello_9 [0] 0x7f587c001c90 from (none) to sasl_plaintext://u-kafkatst-kafkadev-5.sd.firm.com:9092/5 (sending PARTITION_JOIN to sasl_plaintext://u-kafkatst-kafkadev-5.sd.firm.com:9092/5)
2021-02-10 08:59:05.650: LOG-7-DESIRED: [thrd:main]: fps.dhamodha.test_hello_9 [0]: marking as DESIRED
2021-02-10 08:59:05.650: LOG-7-ASSIGNMENT: [thrd:main]: Added 1 partition(s) to assignment which now consists of 1 partition(s) where of 1 are in pending state and 0 are being queried
2021-02-10 08:59:05.650: LOG-7-PAUSE: [thrd:main]: Resuming fetchers for 1 assigned partition(s): assign called
2021-02-10 08:59:05.650: LOG-7-RESUME: [thrd:main]: Library resuming 1 partition(s)
2021-02-10 08:59:05.650: LOG-7-BARRIER: [thrd:main]: fps.dhamodha.test_hello_9 [0]: rd_kafka_toppar_op_pause_resume:2415: new version barrier v2
2021-02-10 08:59:05.650: LOG-7-RESUME: [thrd:main]: Resume fps.dhamodha.test_hello_9 [0] (v2)
2021-02-10 08:59:05.650: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state wait-assign-call -> steady (state up)
2021-02-10 08:59:05.650: LOG-7-DUMP: [thrd:main]: Assignment dump (started_cnt=0, wait_stop_cnt=0)
2021-02-10 08:59:05.650: LOG-7-DUMP_ALL: [thrd:main]: List with 1 partition(s):
2021-02-10 08:59:05.650: 2021-02-10 08:59:05.650: LOG-7-TOPBRK: [thrd:sasl_plaintext://u-kafkatst-kafkadev-5.sd.firm.com:9092/boots]: sasl_plaintext://u-kafkatst-kafkadev-5.sd.firm.com:9092/5: Topic fps.dhamodha.test_hello_9 [0]: joining broker (rktp 0x7f587c001c90, 0 message(s) queued)
LOG-7-DUMP_ALL: [thrd:main]:  fps.dhamodha.test_hello_9 [0] offset STORED
2021-02-10 08:59:05.650: LOG-7-DUMP_PND: [thrd:main]: List with 1 partition(s):
2021-02-10 08:59:05.650: LOG-7-DUMP_PND: [thrd:main]:  fps.dhamodha.test_hello_9 [0] offset STORED
2021-02-10 08:59:05.650: LOG-7-DUMP_QRY: [thrd:main]: List with 0 partition(s):
2021-02-10 08:59:05.650: LOG-7-DUMP_REM: [thrd:main]: List with 0 partition(s):
2021-02-10 08:59:05.650: LOG-7-SRVPEND: [thrd:main]: Querying committed offset for pending assigned partition fps.dhamodha.test_hello_9 [0]
2021-02-10 08:59:05.650: LOG-7-OFFSETFETCH: [thrd:main]: Fetching committed offsets for 1 pending partition(s) in assignment
2021-02-10 08:59:05.650: LOG-7-OFFSET: [thrd:main]: GroupCoordinator/5: OffsetFetchRequest(v7) for 1/1 partition(s)
2021-02-10 08:59:05.650: LOG-7-OFFSET: [thrd:main]: GroupCoordinator/5: Fetch committed offsets for 1/1 partition(s)
2021-02-10 08:59:05.650: LOG-7-ASSIGNMENT: [thrd:main]: Current assignment of 1 partition(s) with 1 pending adds, 1 offset queries, 0 partitions awaiting stop and 0 offset commits in progress
2021-02-10 08:59:05.650: LOG-7-OP: [thrd:main]: fps.dhamodha.test_hello_9 [0] received op PAUSE (v2) in fetch-state none (opv1)
2021-02-10 08:59:05.650: LOG-7-RESUME: [thrd:main]: Not resuming fps.dhamodha.test_hello_9 [0]: partition is not paused by library
2021-02-10 08:59:05.651: LOG-7-OFFSETFETCH: [thrd:main]: GroupCoordinator/5: OffsetFetchResponse: fps.dhamodha.test_hello_9 [0] offset 1, metadata 0 byte(s): NO_ERROR
2021-02-10 08:59:05.651: LOG-7-OFFFETCH: [thrd:main]: GroupCoordinator/5: OffsetFetch for 1/1 partition(s) (0 unstable partition(s)) returned Success
2021-02-10 08:59:05.651: LOG-7-OFFSETFETCH: [thrd:main]: Adding fps.dhamodha.test_hello_9 [0] back to pending list with offset 1
2021-02-10 08:59:05.651: LOG-7-DUMP: [thrd:main]: Assignment dump (started_cnt=0, wait_stop_cnt=0)
2021-02-10 08:59:05.651: LOG-7-DUMP_ALL: [thrd:main]: List with 1 partition(s):
2021-02-10 08:59:05.651: LOG-7-DUMP_ALL: [thrd:main]:  fps.dhamodha.test_hello_9 [0] offset STORED
2021-02-10 08:59:05.651: LOG-7-DUMP_PND: [thrd:main]: List with 1 partition(s):
2021-02-10 08:59:05.651: LOG-7-DUMP_PND: [thrd:main]:  fps.dhamodha.test_hello_9 [0] offset 1
2021-02-10 08:59:05.651: LOG-7-DUMP_QRY: [thrd:main]: List with 0 partition(s):
2021-02-10 08:59:05.651: LOG-7-DUMP_REM: [thrd:main]: List with 0 partition(s):
2021-02-10 08:59:05.651: LOG-7-SRVPEND: [thrd:main]: Starting pending assigned partition fps.dhamodha.test_hello_9 [0] at offset 1
2021-02-10 08:59:05.651: LOG-7-BARRIER: [thrd:main]: fps.dhamodha.test_hello_9 [0]: rd_kafka_toppar_op_pause_resume:2415: new version barrier v3
2021-02-10 08:59:05.651: LOG-7-RESUME: [thrd:main]: Resume fps.dhamodha.test_hello_9 [0] (v3)
2021-02-10 08:59:05.651: LOG-7-BARRIER: [thrd:main]: fps.dhamodha.test_hello_9 [0]: rd_kafka_toppar_op_fetch_start:2329: new version barrier v4
2021-02-10 08:59:05.651: LOG-7-CONSUMER: [thrd:main]: Start consuming fps.dhamodha.test_hello_9 [0] at offset 1 (v4)
2021-02-10 08:59:05.651: LOG-7-ASSIGNDONE: [thrd:main]: Group "new_cons_gp": assignment operations done in join-state steady (rebalance rejoin=false)
2021-02-10 08:59:05.651: LOG-7-OP: [thrd:main]: fps.dhamodha.test_hello_9 [0] received op PAUSE (v3) in fetch-state none (opv2)
2021-02-10 08:59:05.651: LOG-7-RESUME: [thrd:main]: Not resuming fps.dhamodha.test_hello_9 [0]: partition is not paused by library
2021-02-10 08:59:05.651: LOG-7-OP: [thrd:main]: fps.dhamodha.test_hello_9 [0] received op FETCH_START (v4) in fetch-state none (opv3)
2021-02-10 08:59:05.651: LOG-7-FETCH: [thrd:main]: Start fetch for fps.dhamodha.test_hello_9 [0] in state none at offset 1 (v4)
2021-02-10 08:59:05.651: LOG-7-PARTSTATE: [thrd:main]: Partition fps.dhamodha.test_hello_9 [0] changed fetch state none -> active
2021-02-10 08:59:05.651: LOG-7-FETCH: [thrd:main]: Partition fps.dhamodha.test_hello_9 [0] start fetching at offset 1
2021-02-10 08:59:05.651: LOG-7-CGRPOP: [thrd:main]: Group "new_cons_gp" received op PARTITION_JOIN in state up (join-state steady) for fps.dhamodha.test_hello_9 [0]
2021-02-10 08:59:05.651: LOG-7-PARTADD: [thrd:main]: Group "new_cons_gp": add fps.dhamodha.test_hello_9 [0]
2021-02-10 08:59:05.651: LOG-7-FETCHDEC: [thrd:sasl_plaintext://u-kafkatst-kafkadev-5.sd.firm.com:9092/boots]: Topic fps.dhamodha.test_hello_9 [0]: fetch decide: updating to version 4 (was 0) at offset 1 (was 0)
2021-02-10 08:59:05.651: LOG-7-FETCHADD: [thrd:sasl_plaintext://u-kafkatst-kafkadev-5.sd.firm.com:9092/boots]: sasl_plaintext://u-kafkatst-kafkadev-5.sd.firm.com:9092/5: Added fps.dhamodha.test_hello_9 [0] to fetch list (1 entries, opv 4, 0 messages queued): fetchable
2021-02-10 08:59:05.655: LOG-7-METADATA: [thrd:sasl_plaintext://u-kafkatst-kafkadev-5.sd.firm.com:9092/boots]: Skipping metadata refresh of 1 topic(s): connected: already being requested
2021-02-10 08:59:08.255: LOG-7-OFFSET: [thrd:main]: Topic fps.dhamodha.test_hello_9 [0]: stored offset -1001, committed offset 1: not including in commit
2021-02-10 08:59:08.255: LOG-7-DUMP: [thrd:main]: Assignment dump (started_cnt=1, wait_stop_cnt=0)
2021-02-10 08:59:08.255: LOG-7-DUMP_ALL: [thrd:main]: List with 1 partition(s):
2021-02-10 08:59:08.255: LOG-7-DUMP_ALL: [thrd:main]:  fps.dhamodha.test_hello_9 [0] offset STORED
2021-02-10 08:59:08.255: LOG-7-DUMP_PND: [thrd:main]: List with 0 partition(s):
2021-02-10 08:59:08.255: LOG-7-DUMP_QRY: [thrd:main]: List with 0 partition(s):
2021-02-10 08:59:08.255: LOG-7-DUMP_REM: [thrd:main]: List with 0 partition(s):
2021-02-10 08:59:08.255: LOG-7-ASSIGNDONE: [thrd:main]: Group "new_cons_gp": assignment operations done in join-state steady (rebalance rejoin=false)
2021-02-10 08:59:08.650: LOG-7-HEARTBEAT: [thrd:main]: GroupCoordinator/5: Heartbeat for group "new_cons_gp" generation id 39
2021-02-10 08:59:11.650: LOG-7-HEARTBEAT: [thrd:main]: GroupCoordinator/5: Heartbeat for group "new_cons_gp" generation id 39
2021-02-10 08:59:13.255: LOG-7-OFFSET: [thrd:main]: Topic fps.dhamodha.test_hello_9 [0]: stored offset -1001, committed offset 1: not including in commit
2021-02-10 08:59:13.255: LOG-7-DUMP: [thrd:main]: Assignment dump (started_cnt=1, wait_stop_cnt=0)
2021-02-10 08:59:13.255: LOG-7-DUMP_ALL: [thrd:main]: List with 1 partition(s):
2021-02-10 08:59:13.255: LOG-7-DUMP_ALL: [thrd:main]:  fps.dhamodha.test_hello_9 [0] offset STORED
2021-02-10 08:59:13.255: LOG-7-DUMP_PND: [thrd:main]: List with 0 partition(s):
2021-02-10 08:59:13.255: LOG-7-DUMP_QRY: [thrd:main]: List with 0 partition(s):
2021-02-10 08:59:13.255: LOG-7-DUMP_REM: [thrd:main]: List with 0 partition(s):
2021-02-10 08:59:13.255: LOG-7-ASSIGNDONE: [thrd:main]: Group "new_cons_gp": assignment operations done in join-state steady (rebalance rejoin=false)
2021-02-10 08:59:14.650: LOG-7-HEARTBEAT: [thrd:main]: GroupCoordinator/5: Heartbeat for group "new_cons_gp" generation id 39
2021-02-10 08:59:17.650: LOG-7-HEARTBEAT: [thrd:main]: GroupCoordinator/5: Heartbeat for group "new_cons_gp" generation id 39
2021-02-10 08:59:18.255: LOG-7-OFFSET: [thrd:main]: Topic fps.dhamodha.test_hello_9 [0]: stored offset -1001, committed offset 1: not including in commit
2021-02-10 08:59:18.255: LOG-7-DUMP: [thrd:main]: Assignment dump (started_cnt=1, wait_stop_cnt=0)
2021-02-10 08:59:18.255: LOG-7-DUMP_ALL: [thrd:main]: List with 1 partition(s):
2021-02-10 08:59:18.255: LOG-7-DUMP_ALL: [thrd:main]:  fps.dhamodha.test_hello_9 [0] offset STORED
2021-02-10 08:59:18.255: LOG-7-DUMP_PND: [thrd:main]: List with 0 partition(s):
2021-02-10 08:59:18.255: LOG-7-DUMP_QRY: [thrd:main]: List with 0 partition(s):
2021-02-10 08:59:18.255: LOG-7-DUMP_REM: [thrd:main]: List with 0 partition(s):
2021-02-10 08:59:18.255: LOG-7-ASSIGNDONE: [thrd:main]: Group "new_cons_gp": assignment operations done in join-state steady (rebalance rejoin=false)
2021-02-10 08:59:20.650: LOG-7-HEARTBEAT: [thrd:main]: GroupCoordinator/5: Heartbeat for group "new_cons_gp" generation id 39
2021-02-10 08:59:23.255: LOG-7-OFFSET: [thrd:main]: Topic fps.dhamodha.test_hello_9 [0]: stored offset -1001, committed offset 1: not including in commit
2021-02-10 08:59:23.255: LOG-7-DUMP: [thrd:main]: Assignment dump (started_cnt=1, wait_stop_cnt=0)
2021-02-10 08:59:23.255: LOG-7-DUMP_ALL: [thrd:main]: List with 1 partition(s):
2021-02-10 08:59:23.255: LOG-7-DUMP_ALL: [thrd:main]:  fps.dhamodha.test_hello_9 [0] offset STORED
2021-02-10 08:59:23.255: LOG-7-DUMP_PND: [thrd:main]: List with 0 partition(s):
2021-02-10 08:59:23.255: LOG-7-DUMP_QRY: [thrd:main]: List with 0 partition(s):
2021-02-10 08:59:23.255: LOG-7-DUMP_REM: [thrd:main]: List with 0 partition(s):
2021-02-10 08:59:23.255: LOG-7-ASSIGNDONE: [thrd:main]: Group "new_cons_gp": assignment operations done in join-state steady (rebalance rejoin=false)
2021-02-10 08:59:23.650: LOG-7-HEARTBEAT: [thrd:main]: GroupCoordinator/5: Heartbeat for group "new_cons_gp" generation id 39
2021-02-10 08:59:26.650: LOG-7-HEARTBEAT: [thrd:main]: GroupCoordinator/5: Heartbeat for group "new_cons_gp" generation id 39
2021-02-10 08:59:28.255: LOG-7-OFFSET: [thrd:main]: Topic fps.dhamodha.test_hello_9 [0]: stored offset -1001, committed offset 1: not including in commit
2021-02-10 08:59:28.255: LOG-7-DUMP: [thrd:main]: Assignment dump (started_cnt=1, wait_stop_cnt=0)
2021-02-10 08:59:28.255: LOG-7-DUMP_ALL: [thrd:main]: List with 1 partition(s):
2021-02-10 08:59:28.255: LOG-7-DUMP_ALL: [thrd:main]:  fps.dhamodha.test_hello_9 [0] offset STORED
2021-02-10 08:59:28.255: LOG-7-DUMP_PND: [thrd:main]: List with 0 partition(s):
2021-02-10 08:59:28.255: LOG-7-DUMP_QRY: [thrd:main]: List with 0 partition(s):
2021-02-10 08:59:28.255: LOG-7-DUMP_REM: [thrd:main]: List with 0 partition(s):
2021-02-10 08:59:28.255: LOG-7-ASSIGNDONE: [thrd:main]: Group "new_cons_gp": assignment operations done in join-state steady (rebalance rejoin=false)
2021-02-10 08:59:29.650: LOG-7-HEARTBEAT: [thrd:main]: GroupCoordinator/5: Heartbeat for group "new_cons_gp" generation id 39
2021-02-10 08:59:32.650: LOG-7-HEARTBEAT: [thrd:main]: GroupCoordinator/5: Heartbeat for group "new_cons_gp" generation id 39
2021-02-10 08:59:33.255: LOG-7-OFFSET: [thrd:main]: Topic fps.dhamodha.test_hello_9 [0]: stored offset -1001, committed offset 1: not including in commit
2021-02-10 08:59:33.255: LOG-7-DUMP: [thrd:main]: Assignment dump (started_cnt=1, wait_stop_cnt=0)
2021-02-10 08:59:33.255: LOG-7-DUMP_ALL: [thrd:main]: List with 1 partition(s):
2021-02-10 08:59:33.255: LOG-7-DUMP_ALL: [thrd:main]:  fps.dhamodha.test_hello_9 [0] offset STORED
2021-02-10 08:59:33.255: LOG-7-DUMP_PND: [thrd:main]: List with 0 partition(s):
2021-02-10 08:59:33.255: LOG-7-DUMP_QRY: [thrd:main]: List with 0 partition(s):
2021-02-10 08:59:33.255: LOG-7-DUMP_REM: [thrd:main]: List with 0 partition(s):
2021-02-10 08:59:33.255: LOG-7-ASSIGNDONE: [thrd:main]: Group "new_cons_gp": assignment operations done in join-state steady (rebalance rejoin=false)
2021-02-10 08:59:35.650: LOG-7-HEARTBEAT: [thrd:main]: GroupCoordinator/5: Heartbeat for group "new_cons_gp" generation id 39
2021-02-10 08:59:38.255: LOG-7-OFFSET: [thrd:main]: Topic fps.dhamodha.test_hello_9 [0]: stored offset -1001, committed offset 1: not including in commit
2021-02-10 08:59:38.255: LOG-7-DUMP: [thrd:main]: Assignment dump (started_cnt=1, wait_stop_cnt=0)
2021-02-10 08:59:38.255: LOG-7-DUMP_ALL: [thrd:main]: List with 1 partition(s):
2021-02-10 08:59:38.255: LOG-7-DUMP_ALL: [thrd:main]:  fps.dhamodha.test_hello_9 [0] offset STORED
2021-02-10 08:59:38.255: LOG-7-DUMP_PND: [thrd:main]: List with 0 partition(s):
2021-02-10 08:59:38.255: LOG-7-DUMP_QRY: [thrd:main]: List with 0 partition(s):
2021-02-10 08:59:38.255: LOG-7-DUMP_REM: [thrd:main]: List with 0 partition(s):
2021-02-10 08:59:38.255: LOG-7-ASSIGNDONE: [thrd:main]: Group "new_cons_gp": assignment operations done in join-state steady (rebalance rejoin=false)
2021-02-10 08:59:38.650: LOG-7-HEARTBEAT: [thrd:main]: GroupCoordinator/5: Heartbeat for group "new_cons_gp" generation id 39
2021-02-10 08:59:41.650: LOG-7-HEARTBEAT: [thrd:main]: GroupCoordinator/5: Heartbeat for group "new_cons_gp" generation id 39

2021-02-10 08:59:43.255: LOG-7-OFFSET: [thrd:main]: Topic fps.dhamodha.test_hello_9 [0]: stored offset 2, committed offset 1: setting stored offset 2 for commit
2021-02-10 08:59:43.255: LOG-7-OFFSET: [thrd:main]: GroupCoordinator/5: Enqueue OffsetCommitRequest(v7, 1/1 partition(s))): cgrp auto commit timer
2021-02-10 08:59:43.256: LOG-7-COMMIT: [thrd:main]: GroupCoordinator/5: OffsetCommit for 1 partition(s) in join-state steady: cgrp auto commit timer: returned: Success
2021-02-10 08:59:43.256: LOG-7-DUMP: [thrd:main]: Assignment dump (started_cnt=1, wait_stop_cnt=0)
2021-02-10 08:59:43.256: LOG-7-DUMP_ALL: [thrd:main]: List with 1 partition(s):
2021-02-10 08:59:43.256: LOG-7-DUMP_ALL: [thrd:main]:  fps.dhamodha.test_hello_9 [0] offset STORED
2021-02-10 08:59:43.256: LOG-7-DUMP_PND: [thrd:main]: List with 0 partition(s):
2021-02-10 08:59:43.256: LOG-7-DUMP_QRY: [thrd:main]: List with 0 partition(s):
2021-02-10 08:59:43.256: LOG-7-DUMP_REM: [thrd:main]: List with 0 partition(s):
2021-02-10 08:59:43.256: LOG-7-ASSIGNDONE: [thrd:main]: Group "new_cons_gp": assignment operations done in join-state steady (rebalance rejoin=false)


2021-02-10 08:59:44.650: LOG-7-HEARTBEAT: [thrd:main]: GroupCoordinator/5: Heartbeat for group "new_cons_gp" generation id 39
2021-02-10 08:59:47.650: LOG-7-HEARTBEAT: [thrd:main]: GroupCoordinator/5: Heartbeat for group "new_cons_gp" generation id 39
2021-02-10 08:59:47.650: LOG-7-HEARTBEAT: [thrd:main]: Group "new_cons_gp" heartbeat error response in state up (join-state steady, 1 partition(s) assigned): Broker: Group rebalance in progress
2021-02-10 08:59:47.650: LOG-7-REBALANCE: [thrd:main]: Group "new_cons_gp" is rebalancing (EAGER) in state up (join-state steady) with 1 assigned partition(s): rebalance in progress
2021-02-10 08:59:47.650: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state steady -> wait-unassign-call (state up)
2021-02-10 08:59:47.650: LOG-7-ASSIGN: [thrd:main]: Group "new_cons_gp": delegating revoke of 1 partition(s) to application on queue rd_kafka_cgrp_new: rebalance in progress
2021-02-10 08:59:47.650: LOG-7-PAUSE: [thrd:main]: Pausing fetchers for 1 assigned partition(s): rebalance
2021-02-10 08:59:47.650: LOG-7-PAUSE: [thrd:main]: Library pausing 1 partition(s)
2021-02-10 08:59:47.650: LOG-7-BARRIER: [thrd:main]: fps.dhamodha.test_hello_9 [0]: rd_kafka_toppar_op_pause_resume:2415: new version barrier v5
2021-02-10 08:59:47.650: LOG-7-PAUSE: [thrd:main]: Pause fps.dhamodha.test_hello_9 [0] (v5)
2021-02-10 08:59:47.650: LOG-7-ASSIGNMENT: [thrd:main]: Group "new_cons_gp": clearing group assignment
2021-02-10 08:59:47.650: LOG-7-OP: [thrd:main]: fps.dhamodha.test_hello_9 [0] received op PAUSE (v5) in fetch-state active (opv4)
2021-02-10 08:59:47.650: LOG-7-PAUSE: [thrd:main]: Pause fps.dhamodha.test_hello_9 [0]: at offset 4 (state active, v5)
RebalanceCb: Local: Revoke partitions: fps.dhamodha.test_hello_9[0], 
2021-02-10 08:59:47.650: LOG-7-CGRPOP: [thrd:main]: Group "new_cons_gp" received op GET_REBALANCE_PROTOCOL in state up (join-state wait-unassign-call)
2021-02-10 08:59:47.650: LOG-7-CGRPOP: [thrd:main]: Group "new_cons_gp" received op ASSIGN in state up (join-state wait-unassign-call)
2021-02-10 08:59:47.650: LOG-7-CLEARASSIGN: [thrd:main]: Clearing current assignment of 1 partition(s)
2021-02-10 08:59:47.651: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state wait-unassign-call -> wait-unassign-to-complete (state up)
2021-02-10 08:59:47.651: LOG-7-DUMP: [thrd:main]: Assignment dump (started_cnt=1, wait_stop_cnt=0)
2021-02-10 08:59:47.651: LOG-7-DUMP_ALL: [thrd:main]: List with 0 partition(s):
2021-02-10 08:59:47.651: LOG-7-DUMP_PND: [thrd:main]: List with 0 partition(s):
2021-02-10 08:59:47.651: LOG-7-DUMP_QRY: [thrd:main]: List with 0 partition(s):
2021-02-10 08:59:47.651: LOG-7-DUMP_REM: [thrd:main]: List with 1 partition(s):
2021-02-10 08:59:47.651: LOG-7-DUMP_REM: [thrd:main]:  fps.dhamodha.test_hello_9 [0] offset STORED
2021-02-10 08:59:47.651: LOG-7-BARRIER: [thrd:main]: fps.dhamodha.test_hello_9 [0]: rd_kafka_toppar_op_fetch_stop:2356: new version barrier v6
2021-02-10 08:59:47.651: LOG-7-CONSUMER: [thrd:main]: Stop consuming fps.dhamodha.test_hello_9 [0] (v6)
2021-02-10 08:59:47.651: LOG-7-BARRIER: [thrd:main]: fps.dhamodha.test_hello_9 [0]: rd_kafka_toppar_op_pause_resume:2415: new version barrier v7
2021-02-10 08:59:47.651: LOG-7-RESUME: [thrd:main]: Resume fps.dhamodha.test_hello_9 [0] (v7)
2021-02-10 08:59:47.651: LOG-7-DESP: [thrd:main]: Removing (un)desired topic fps.dhamodha.test_hello_9 [0]
2021-02-10 08:59:47.651: LOG-7-REMOVE: [thrd:main]: Removing fps.dhamodha.test_hello_9 [0] from assignment (started=true, pending=false, queried=false, stored offset=4)
2021-02-10 08:59:47.651: LOG-7-REMOVE: [thrd:main]: Served 1 removed partition(s), with 1 offset(s) to commit
2021-02-10 08:59:47.651: LOG-7-OFFSET: [thrd:main]: GroupCoordinator/5: Enqueue OffsetCommitRequest(v7, 1/1 partition(s))): unassigned partitions
2021-02-10 08:59:47.651: LOG-7-ASSIGNMENT: [thrd:main]: Current assignment of 0 partition(s) with 0 pending adds, 0 offset queries, 1 partitions awaiting stop and 1 offset commits in progress
2021-02-10 08:59:47.651: LOG-7-OP: [thrd:main]: fps.dhamodha.test_hello_9 [0] received op FETCH_STOP (v6) in fetch-state active (opv5)
2021-02-10 08:59:47.651: LOG-7-FETCH: [thrd:main]: Stopping fetch for fps.dhamodha.test_hello_9 [0] in state active (v6)
2021-02-10 08:59:47.651: LOG-7-PARTSTATE: [thrd:main]: Partition fps.dhamodha.test_hello_9 [0] changed fetch state active -> stopping
2021-02-10 08:59:47.651: LOG-7-STORETERM: [thrd:main]: fps.dhamodha.test_hello_9 [0]: offset store terminating
2021-02-10 08:59:47.651: LOG-7-PARTSTATE: [thrd:main]: Partition fps.dhamodha.test_hello_9 [0] changed fetch state stopping -> stopped
2021-02-10 08:59:47.651: LOG-7-OP: [thrd:main]: fps.dhamodha.test_hello_9 [0] received op PAUSE (v7) in fetch-state stopped (opv6)
2021-02-10 08:59:47.651: LOG-7-RESUME: [thrd:main]: Not resuming stopped fps.dhamodha.test_hello_9 [0]: at offset 4 (state stopped, v7)
2021-02-10 08:59:47.651: LOG-7-CGRPOP: [thrd:main]: Group "new_cons_gp" received op PARTITION_LEAVE in state up (join-state wait-unassign-to-complete) for fps.dhamodha.test_hello_9 [0]
2021-02-10 08:59:47.651: LOG-7-PARTDEL: [thrd:main]: Group "new_cons_gp": delete fps.dhamodha.test_hello_9 [0]
2021-02-10 08:59:47.651: LOG-7-STOPSERVE: [thrd:main]: All partitions awaiting stop are now stopped: serving assignment
2021-02-10 08:59:47.651: LOG-7-DUMP: [thrd:main]: Assignment dump (started_cnt=0, wait_stop_cnt=0)
2021-02-10 08:59:47.651: LOG-7-DUMP_ALL: [thrd:main]: List with 0 partition(s):
2021-02-10 08:59:47.651: LOG-7-DUMP_PND: [thrd:main]: List with 0 partition(s):
2021-02-10 08:59:47.651: LOG-7-DUMP_QRY: [thrd:main]: List with 0 partition(s):
2021-02-10 08:59:47.651: LOG-7-DUMP_REM: [thrd:main]: List with 0 partition(s):
2021-02-10 08:59:47.651: LOG-7-ASSIGNMENT: [thrd:main]: Current assignment of 0 partition(s) with 0 pending adds, 0 offset queries, 0 partitions awaiting stop and 1 offset commits in progress
2021-02-10 08:59:47.651: LOG-7-COMMIT: [thrd:main]: GroupCoordinator/5: OffsetCommit for 1 partition(s) in join-state wait-unassign-to-complete: unassigned partitions: returned: Success
2021-02-10 08:59:47.651: LOG-7-DUMP: [thrd:main]: Assignment dump (started_cnt=0, wait_stop_cnt=0)
2021-02-10 08:59:47.651: LOG-7-DUMP_ALL: [thrd:main]: List with 0 partition(s):
2021-02-10 08:59:47.651: LOG-7-DUMP_PND: [thrd:main]: List with 0 partition(s):
2021-02-10 08:59:47.651: LOG-7-DUMP_QRY: [thrd:main]: List with 0 partition(s):
2021-02-10 08:59:47.651: LOG-7-DUMP_REM: [thrd:main]: List with 0 partition(s):
2021-02-10 08:59:47.651: LOG-7-ASSIGNDONE: [thrd:main]: Group "new_cons_gp": assignment operations done in join-state wait-unassign-to-complete (rebalance rejoin=false)
2021-02-10 08:59:47.651: LOG-7-UNASSIGN: [thrd:main]: Group "new_cons_gp": unassign done in state up (join-state wait-unassign-to-complete)
2021-02-10 08:59:47.651: LOG-7-REJOIN: [thrd:main]: Group "new_cons_gp": Rejoining group without an assignment: Unassignment done
2021-02-10 08:59:47.651: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state wait-unassign-to-complete -> init (state up)
2021-02-10 08:59:47.651: LOG-7-JOIN: [thrd:main]: Group "new_cons_gp": join with 1 subscribed topic(s)
2021-02-10 08:59:47.651: LOG-7-CGRPMETADATA: [thrd:main]: consumer join: metadata for subscription is up to date (44395ms old)
2021-02-10 08:59:47.651: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state init -> wait-join (state up)
2021-02-10 08:59:47.652: LOG-7-JOINGROUP: [thrd:main]: JoinGroup response: GenerationId 40, Protocol range, LeaderId cppcona-cd562f47-8b63-41a6-b986-5d7546b682cf (me), my MemberId cppcona-cd562f47-8b63-41a6-b986-5d7546b682cf, member metadata count 1: (no error)
2021-02-10 08:59:47.652: LOG-7-JOINGROUP: [thrd:main]: I am elected leader for group "new_cons_gp" with 1 member(s)
2021-02-10 08:59:47.652: LOG-7-GRPLEADER: [thrd:main]: Group "new_cons_gp": resetting group leader info: JoinGroup response clean-up
2021-02-10 08:59:47.652: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state wait-join -> wait-metadata (state up)
2021-02-10 08:59:47.652: LOG-7-METADATA: [thrd:main]: GroupCoordinator/5: Request metadata for 1 topic(s): partition assignor
2021-02-10 08:59:47.652: LOG-7-METADATA: [thrd:main]: GroupCoordinator/5: ===== Received metadata (for 1 requested topics): partition assignor =====
2021-02-10 08:59:47.652: LOG-7-METADATA: [thrd:main]: GroupCoordinator/5: ClusterId: f2omDNr9THyyx9GLoe5bIA, ControllerId: 1
2021-02-10 08:59:47.652: LOG-7-METADATA: [thrd:main]: GroupCoordinator/5: 5 brokers, 1 topics
2021-02-10 08:59:47.652: LOG-7-METADATA: [thrd:main]: GroupCoordinator/5:   Broker #0/5: u-kafkatst-kafkadev-5.sd.firm.com:9092 NodeId 5
2021-02-10 08:59:47.652: LOG-7-METADATA: [thrd:main]: GroupCoordinator/5:   Broker #1/5: u-kafkatst-kafkadev-4.sd.firm.com:9092 NodeId 4
2021-02-10 08:59:47.652: LOG-7-METADATA: [thrd:main]: GroupCoordinator/5:   Broker #2/5: u-kafkatst-kafkadev-1.sd.firm.com:9092 NodeId 1
2021-02-10 08:59:47.652: LOG-7-METADATA: [thrd:main]: GroupCoordinator/5:   Broker #3/5: u-kafkatst-kafkadev-2.sd.firm.com:9092 NodeId 2
2021-02-10 08:59:47.652: LOG-7-METADATA: [thrd:main]: GroupCoordinator/5:   Broker #4/5: u-kafkatst-kafkadev-3.sd.firm.com:9092 NodeId 3
2021-02-10 08:59:47.652: LOG-7-METADATA: [thrd:main]: GroupCoordinator/5:   Topic #0/1: fps.dhamodha.test_hello_9 with 1 partitions
2021-02-10 08:59:47.652: LOG-7-METADATA: [thrd:main]:   Topic fps.dhamodha.test_hello_9 partition 0 Leader 5
2021-02-10 08:59:47.652: LOG-7-METADATA: [thrd:main]: GroupCoordinator/5: 1/1 requested topic(s) seen in metadata
2021-02-10 08:59:47.652: LOG-7-ASSIGN: [thrd:main]: Group "new_cons_gp" running range assignor for 1 member(s) and 1 eligible subscribed topic(s):
2021-02-10 08:59:47.652: LOG-7-ASSIGN: [thrd:main]:  Member "cppcona-cd562f47-8b63-41a6-b986-5d7546b682cf" (me) with 0 assigned partition(s) and 1 subscribed topic(s):
2021-02-10 08:59:47.652: LOG-7-ASSIGN: [thrd:main]:   fps.dhamodha.test_hello_9 [-1]
2021-02-10 08:59:47.652: LOG-7-ASSIGN: [thrd:main]: range: Topic fps.dhamodha.test_hello_9 with 1 partition(s) and 1 subscribing member(s)
2021-02-10 08:59:47.652: LOG-7-ASSIGN: [thrd:main]: range: Member "cppcona-cd562f47-8b63-41a6-b986-5d7546b682cf": assigned topic fps.dhamodha.test_hello_9 partitions 0..0
2021-02-10 08:59:47.653: LOG-7-ASSIGN: [thrd:main]: Group "new_cons_gp" range assignment for 1 member(s) finished in 0.026ms:
2021-02-10 08:59:47.653: LOG-7-ASSIGN: [thrd:main]:  Member "cppcona-cd562f47-8b63-41a6-b986-5d7546b682cf" (me) assigned 1 partition(s):
2021-02-10 08:59:47.653: LOG-7-ASSIGN: [thrd:main]:   fps.dhamodha.test_hello_9 [0]
2021-02-10 08:59:47.653: LOG-7-ASSIGNOR: [thrd:main]: Group "new_cons_gp": "range" assignor run for 1 member(s)
2021-02-10 08:59:47.653: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state wait-metadata -> wait-sync (state up)
2021-02-10 08:59:47.653: LOG-7-SYNCGROUP: [thrd:main]: SyncGroup response: Success (45 bytes of MemberState data)
2021-02-10 08:59:47.653: LOG-7-ASSIGNMENT: [thrd:main]: List with 1 partition(s):
2021-02-10 08:59:47.653: LOG-7-ASSIGNMENT: [thrd:main]:  fps.dhamodha.test_hello_9 [0] offset INVALID
2021-02-10 08:59:47.653: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state wait-sync -> wait-assign-call (state up)
2021-02-10 08:59:47.653: LOG-7-ASSIGN: [thrd:main]: Group "new_cons_gp": delegating assign of 1 partition(s) to application on queue rd_kafka_cgrp_new: new assignment
2021-02-10 08:59:47.653: LOG-7-ASSIGNMENT: [thrd:main]: Group "new_cons_gp": setting group assignment to 1 partition(s)
2021-02-10 08:59:47.653: LOG-7-GRPASSIGNMENT: [thrd:main]: List with 1 partition(s):
2021-02-10 08:59:47.653: LOG-7-GRPASSIGNMENT: [thrd:main]:  fps.dhamodha.test_hello_9 [0] offset INVALID
RebalanceCb: Local: Assign partitions: fps.dhamodha.test_hello_9[0], 
2021-02-10 08:59:47.653: LOG-7-CGRPOP: [thrd:main]: Group "new_cons_gp" received op GET_REBALANCE_PROTOCOL in state up (join-state wait-assign-call)
2021-02-10 08:59:47.653: LOG-7-CGRPOP: [thrd:main]: Group "new_cons_gp" received op ASSIGN in state up (join-state wait-assign-call)
2021-02-10 08:59:47.653: LOG-7-ASSIGN: [thrd:main]: Group "new_cons_gp": new assignment of 1 partition(s) in join-state wait-assign-call
2021-02-10 08:59:47.653: LOG-7-CLEARASSIGN: [thrd:main]: No current assignment to clear
2021-02-10 08:59:47.653: LOG-7-DESIRED: [thrd:main]: fps.dhamodha.test_hello_9 [0]: marking as DESIRED
2021-02-10 08:59:47.653: LOG-7-ASSIGNMENT: [thrd:main]: Added 1 partition(s) to assignment which now consists of 1 partition(s) where of 1 are in pending state and 0 are being queried
2021-02-10 08:59:47.653: LOG-7-PAUSE: [thrd:main]: Resuming fetchers for 1 assigned partition(s): assign called
2021-02-10 08:59:47.653: LOG-7-RESUME: [thrd:main]: Library resuming 1 partition(s)
2021-02-10 08:59:47.653: LOG-7-BARRIER: [thrd:main]: fps.dhamodha.test_hello_9 [0]: rd_kafka_toppar_op_pause_resume:2415: new version barrier v8
2021-02-10 08:59:47.653: LOG-7-RESUME: [thrd:main]: Resume fps.dhamodha.test_hello_9 [0] (v8)
2021-02-10 08:59:47.653: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state wait-assign-call -> steady (state up)
2021-02-10 08:59:47.653: LOG-7-DUMP: [thrd:main]: Assignment dump (started_cnt=0, wait_stop_cnt=0)
2021-02-10 08:59:47.653: LOG-7-DUMP_ALL: [thrd:main]: List with 1 partition(s):
2021-02-10 08:59:47.653: LOG-7-DUMP_ALL: [thrd:main]:  fps.dhamodha.test_hello_9 [0] offset STORED
2021-02-10 08:59:47.653: LOG-7-DUMP_PND: [thrd:main]: List with 1 partition(s):
2021-02-10 08:59:47.653: LOG-7-DUMP_PND: [thrd:main]:  fps.dhamodha.test_hello_9 [0] offset STORED
2021-02-10 08:59:47.653: LOG-7-DUMP_QRY: [thrd:main]: List with 0 partition(s):
2021-02-10 08:59:47.653: LOG-7-DUMP_REM: [thrd:main]: List with 0 partition(s):
2021-02-10 08:59:47.653: LOG-7-SRVPEND: [thrd:main]: Querying committed offset for pending assigned partition fps.dhamodha.test_hello_9 [0]
2021-02-10 08:59:47.653: LOG-7-OFFSETFETCH: [thrd:main]: Fetching committed offsets for 1 pending partition(s) in assignment
2021-02-10 08:59:47.653: LOG-7-OFFSET: [thrd:main]: GroupCoordinator/5: OffsetFetchRequest(v7) for 1/1 partition(s)
2021-02-10 08:59:47.653: LOG-7-OFFSET: [thrd:main]: GroupCoordinator/5: Fetch committed offsets for 1/1 partition(s)
2021-02-10 08:59:47.653: LOG-7-ASSIGNMENT: [thrd:main]: Current assignment of 1 partition(s) with 1 pending adds, 1 offset queries, 0 partitions awaiting stop and 0 offset commits in progress
2021-02-10 08:59:47.653: LOG-7-OP: [thrd:main]: fps.dhamodha.test_hello_9 [0] received op PAUSE (v8) in fetch-state stopped (opv7)
2021-02-10 08:59:47.653: LOG-7-RESUME: [thrd:main]: Not resuming fps.dhamodha.test_hello_9 [0]: partition is not paused by library
2021-02-10 08:59:47.654: LOG-7-OFFSETFETCH: [thrd:main]: GroupCoordinator/5: OffsetFetchResponse: fps.dhamodha.test_hello_9 [0] offset 4, metadata 0 byte(s): NO_ERROR
2021-02-10 08:59:47.654: LOG-7-OFFFETCH: [thrd:main]: GroupCoordinator/5: OffsetFetch for 1/1 partition(s) (0 unstable partition(s)) returned Success
2021-02-10 08:59:47.654: LOG-7-OFFSETFETCH: [thrd:main]: Adding fps.dhamodha.test_hello_9 [0] back to pending list with offset 4
2021-02-10 08:59:47.654: LOG-7-DUMP: [thrd:main]: Assignment dump (started_cnt=0, wait_stop_cnt=0)
2021-02-10 08:59:47.654: LOG-7-DUMP_ALL: [thrd:main]: List with 1 partition(s):
2021-02-10 08:59:47.654: LOG-7-DUMP_ALL: [thrd:main]:  fps.dhamodha.test_hello_9 [0] offset STORED
2021-02-10 08:59:47.654: LOG-7-DUMP_PND: [thrd:main]: List with 1 partition(s):
2021-02-10 08:59:47.654: LOG-7-DUMP_PND: [thrd:main]:  fps.dhamodha.test_hello_9 [0] offset 4
2021-02-10 08:59:47.654: LOG-7-DUMP_QRY: [thrd:main]: List with 0 partition(s):
2021-02-10 08:59:47.654: LOG-7-DUMP_REM: [thrd:main]: List with 0 partition(s):
2021-02-10 08:59:47.654: LOG-7-SRVPEND: [thrd:main]: Starting pending assigned partition fps.dhamodha.test_hello_9 [0] at offset 4
2021-02-10 08:59:47.654: LOG-7-BARRIER: [thrd:main]: fps.dhamodha.test_hello_9 [0]: rd_kafka_toppar_op_pause_resume:2415: new version barrier v9
2021-02-10 08:59:47.654: LOG-7-RESUME: [thrd:main]: Resume fps.dhamodha.test_hello_9 [0] (v9)
2021-02-10 08:59:47.654: LOG-7-BARRIER: [thrd:main]: fps.dhamodha.test_hello_9 [0]: rd_kafka_toppar_op_fetch_start:2329: new version barrier v10
2021-02-10 08:59:47.654: LOG-7-CONSUMER: [thrd:main]: Start consuming fps.dhamodha.test_hello_9 [0] at offset 4 (v10)
2021-02-10 08:59:47.654: LOG-7-ASSIGNDONE: [thrd:main]: Group "new_cons_gp": assignment operations done in join-state steady (rebalance rejoin=false)
2021-02-10 08:59:47.654: LOG-7-OP: [thrd:main]: fps.dhamodha.test_hello_9 [0] received op PAUSE (v9) in fetch-state stopped (opv8)
2021-02-10 08:59:47.654: LOG-7-RESUME: [thrd:main]: Not resuming fps.dhamodha.test_hello_9 [0]: partition is not paused by library
2021-02-10 08:59:47.654: LOG-7-OP: [thrd:main]: fps.dhamodha.test_hello_9 [0] received op FETCH_START (v10) in fetch-state stopped (opv9)
2021-02-10 08:59:47.654: LOG-7-FETCH: [thrd:main]: Start fetch for fps.dhamodha.test_hello_9 [0] in state stopped at offset 4 (v10)
2021-02-10 08:59:47.654: LOG-7-PARTSTATE: [thrd:main]: Partition fps.dhamodha.test_hello_9 [0] changed fetch state stopped -> active
2021-02-10 08:59:47.654: LOG-7-FETCH: [thrd:main]: Partition fps.dhamodha.test_hello_9 [0] start fetching at offset 4
2021-02-10 08:59:47.654: LOG-7-CGRPOP: [thrd:main]: Group "new_cons_gp" received op PARTITION_JOIN in state up (join-state steady) for fps.dhamodha.test_hello_9 [0]
2021-02-10 08:59:47.654: LOG-7-PARTADD: [thrd:main]: Group "new_cons_gp": add fps.dhamodha.test_hello_9 [0]
2021-02-10 08:59:47.654: LOG-7-FETCHDEC: [thrd:sasl_plaintext://u-kafkatst-kafkadev-5.sd.firm.com:9092/boots]: Topic fps.dhamodha.test_hello_9 [0]: fetch decide: updating to version 10 (was 4) at offset 4 (was 4)
dhamodha acquired ticket: client dhamodha/[email protected], server krbtgt/[email protected]
2021-02-10 08:59:48.263: LOG-7-CGRPOP: [thrd:main]: Group "new_cons_gp" received op TERMINATE in state up (join-state steady)
2021-02-10 08:59:48.263: LOG-7-CGRPTERM: [thrd:main]: Terminating group "new_cons_gp" in state up with 1 partition(s)
2021-02-10 08:59:48.263: LOG-7-UNSUBSCRIBE: [thrd:main]: Group "new_cons_gp": unsubscribe from current subscription of size 1 (leave group=true, has joined=true, cppcona-cd562f47-8b63-41a6-b986-5d7546b682cf, join-state steady)
2021-02-10 08:59:48.263: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": clearing subscribed topics list (1)
2021-02-10 08:59:48.263: LOG-7-SUBSCRIPTION: [thrd:main]: Group "new_cons_gp": effective subscription list changed from 1 to 0 topic(s):
2021-02-10 08:59:48.263: LOG-7-GRPLEADER: [thrd:main]: Group "new_cons_gp": resetting group leader info: unsubscribe
2021-02-10 08:59:48.263: LOG-7-REBALANCE: [thrd:main]: Group "new_cons_gp" initiating rebalance (EAGER) in state up (join-state steady) with 1 assigned partition(s): unsubscribe
2021-02-10 08:59:48.263: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state steady -> wait-unassign-call (state up)
2021-02-10 08:59:48.263: LOG-7-ASSIGN: [thrd:main]: Group "new_cons_gp": delegating revoke of 1 partition(s) to application on queue rd_kafka_consumer_close: unsubscribe
2021-02-10 08:59:48.263: LOG-7-PAUSE: [thrd:main]: Pausing fetchers for 1 assigned partition(s): rebalance
2021-02-10 08:59:48.263: LOG-7-PAUSE: [thrd:main]: Library pausing 1 partition(s)
2021-02-10 08:59:48.263: LOG-7-BARRIER: [thrd:main]: fps.dhamodha.test_hello_9 [0]: rd_kafka_toppar_op_pause_resume:2415: new version barrier v11
2021-02-10 08:59:48.263: LOG-7-PAUSE: [thrd:main]: Pause fps.dhamodha.test_hello_9 [0] (v11)
2021-02-10 08:59:48.263: LOG-7-ASSIGNMENT: [thrd:main]: Group "new_cons_gp": clearing group assignment
2021-02-10 08:59:48.263: LOG-7-DUMP: [thrd:main]: Assignment dump (started_cnt=1, wait_stop_cnt=0)
2021-02-10 08:59:48.263: LOG-7-DUMP_ALL: [thrd:main]: List with 1 partition(s):
RebalanceCb: Local: Revoke partitions: fps.dhamodha.test_hello_9[2021-02-10 08:59:48.263: LOG-7-DUMP_ALL: [thrd:main]:  fps.dhamodha.test_hello_9 [0] offset STORED
02021-02-10 08:59:48.264: LOG-7-DUMP_PND: [thrd:main]: List with 0 partition(s):
], 
2021-02-10 08:59:48.264: LOG-7-DUMP_QRY: [thrd:main]: List with 0 partition(s):
2021-02-10 08:59:48.264: LOG-7-DUMP_REM: [thrd:main]: List with 0 partition(s):
2021-02-10 08:59:48.264: LOG-7-ASSIGNDONE: [thrd:main]: Group "new_cons_gp": assignment operations done in join-state wait-unassign-call (rebalance rejoin=false)
2021-02-10 08:59:48.264: LOG-7-CGRPTERM: [thrd:main]: Group "new_cons_gp": waiting for assign call, 1 toppar(s), 0 commit(s) (state up, join-state wait-unassign-call) before terminating
2021-02-10 08:59:48.264: LOG-7-CGRPTERM: [thrd:main]: Group "new_cons_gp": waiting for assign call, 1 toppar(s), 0 commit(s) (state up, join-state wait-unassign-call) before terminating
2021-02-10 08:59:48.264: LOG-7-OFFSET: [thrd:main]: Topic fps.dhamodha.test_hello_9 [0]: stored offset -1001, committed offset 4: not including in commit
2021-02-10 08:59:48.264: LOG-7-OP: [thrd:main]: fps.dhamodha.test_hello_9 [0] received op PAUSE (v11) in fetch-state active (opv10)
2021-02-10 08:59:48.264: LOG-7-PAUSE: [thrd:main]: Pause fps.dhamodha.test_hello_9 [0]: at offset 4 (state active, v11)
2021-02-10 08:59:48.264: LOG-7-CGRPOP: [thrd:main]: Group "new_cons_gp" received op GET_REBALANCE_PROTOCOL in state up (join-state wait-unassign-call)
2021-02-10 08:59:48.264: LOG-7-DUMP: [thrd:main]: Assignment dump (started_cnt=1, wait_stop_cnt=0)
2021-02-10 08:59:48.264: LOG-7-DUMP_ALL: [thrd:main]: List with 1 partition(s):
2021-02-10 08:59:48.264: LOG-7-DUMP_ALL: [thrd:main]:  fps.dhamodha.test_hello_9 [0] offset STORED
2021-02-10 08:59:48.264: LOG-7-DUMP_PND: [thrd:main]: List with 0 partition(s):
2021-02-10 08:59:48.264: LOG-7-DUMP_QRY: [thrd:main]: List with 0 partition(s):
2021-02-10 08:59:48.264: LOG-7-DUMP_REM: [thrd:main]: List with 0 partition(s):
2021-02-10 08:59:48.264: LOG-7-ASSIGNDONE: [thrd:main]: Group "new_cons_gp": assignment operations done in join-state wait-unassign-call (rebalance rejoin=false)
2021-02-10 08:59:48.264: LOG-7-CGRPTERM: [thrd:main]: Group "new_cons_gp": waiting for assign call, 1 toppar(s), 0 commit(s) (state up, join-state wait-unassign-call) before terminating
2021-02-10 08:59:48.264: LOG-7-CGRPOP: [thrd:main]: Group "new_cons_gp" received op ASSIGN in state up (join-state wait-unassign-call)
2021-02-10 08:59:48.264: LOG-7-ASSIGN: [thrd:main]: Group "new_cons_gp": Consumer is terminating: treating assign as unassign
2021-02-10 08:59:48.264: LOG-7-CLEARASSIGN: [thrd:main]: Clearing current assignment of 1 partition(s)
2021-02-10 08:59:48.264: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state wait-unassign-call -> wait-unassign-to-complete (state up)
2021-02-10 08:59:48.264: LOG-7-DUMP: [thrd:main]: Assignment dump (started_cnt=1, wait_stop_cnt=0)
2021-02-10 08:59:48.264: LOG-7-DUMP_ALL: [thrd:main]: List with 0 partition(s):
2021-02-10 08:59:48.264: LOG-7-DUMP_PND: [thrd:main]: List with 0 partition(s):
2021-02-10 08:59:48.264: LOG-7-DUMP_QRY: [thrd:main]: List with 0 partition(s):
2021-02-10 08:59:48.264: LOG-7-DUMP_REM: [thrd:main]: List with 1 partition(s):
2021-02-10 08:59:48.264: LOG-7-DUMP_REM: [thrd:main]:  fps.dhamodha.test_hello_9 [0] offset STORED
2021-02-10 08:59:48.264: LOG-7-BARRIER: [thrd:main]: fps.dhamodha.test_hello_9 [0]: rd_kafka_toppar_op_fetch_stop:2356: new version barrier v12
2021-02-10 08:59:48.264: LOG-7-CONSUMER: [thrd:main]: Stop consuming fps.dhamodha.test_hello_9 [0] (v12)
2021-02-10 08:59:48.264: LOG-7-BARRIER: [thrd:main]: fps.dhamodha.test_hello_9 [0]: rd_kafka_toppar_op_pause_resume:2415: new version barrier v13
2021-02-10 08:59:48.264: LOG-7-RESUME: [thrd:main]: Resume fps.dhamodha.test_hello_9 [0] (v13)
2021-02-10 08:59:48.264: LOG-7-DESP: [thrd:main]: Removing (un)desired topic fps.dhamodha.test_hello_9 [0]
2021-02-10 08:59:48.264: LOG-7-REMOVE: [thrd:main]: Removing fps.dhamodha.test_hello_9 [0] from assignment (started=true, pending=false, queried=false, stored offset=INVALID)
2021-02-10 08:59:48.264: LOG-7-REMOVE: [thrd:main]: Served 1 removed partition(s), with 0 offset(s) to commit
2021-02-10 08:59:48.264: LOG-7-ASSIGNMENT: [thrd:main]: Current assignment of 0 partition(s) with 0 pending adds, 0 offset queries, 1 partitions awaiting stop and 0 offset commits in progress
2021-02-10 08:59:48.264: LOG-7-CGRPTERM: [thrd:main]: Group "new_cons_gp": waiting for 1 toppar(s), assignment in progress, 0 commit(s) (state up, join-state wait-unassign-to-complete) before terminating
2021-02-10 08:59:48.264: LOG-7-OP: [thrd:main]: fps.dhamodha.test_hello_9 [0] received op FETCH_STOP (v12) in fetch-state active (opv11)
2021-02-10 08:59:48.264: LOG-7-FETCH: [thrd:main]: Stopping fetch for fps.dhamodha.test_hello_9 [0] in state active (v12)
2021-02-10 08:59:48.264: LOG-7-PARTSTATE: [thrd:main]: Partition fps.dhamodha.test_hello_9 [0] changed fetch state active -> stopping
2021-02-10 08:59:48.264: LOG-7-STORETERM: [thrd:main]: fps.dhamodha.test_hello_9 [0]: offset store terminating
2021-02-10 08:59:48.264: LOG-7-PARTSTATE: [thrd:main]: Partition fps.dhamodha.test_hello_9 [0] changed fetch state stopping -> stopped
2021-02-10 08:59:48.264: LOG-7-OP: [thrd:main]: fps.dhamodha.test_hello_9 [0] received op PAUSE (v13) in fetch-state stopped (opv12)
2021-02-10 08:59:48.264: LOG-7-RESUME: [thrd:main]: Not resuming stopped fps.dhamodha.test_hello_9 [0]: at offset 4 (state stopped, v13)
2021-02-10 08:59:48.264: LOG-7-CGRPTERM: [thrd:main]: Group "new_cons_gp": waiting for 1 toppar(s), assignment in progress, 0 commit(s) (state up, join-state wait-unassign-to-complete) before terminating
2021-02-10 08:59:48.264: LOG-7-CGRPOP: [thrd:main]: Group "new_cons_gp" received op PARTITION_LEAVE in state up (join-state wait-unassign-to-complete) for fps.dhamodha.test_hello_9 [0]
2021-02-10 08:59:48.264: LOG-7-PARTDEL: [thrd:main]: Group "new_cons_gp": delete fps.dhamodha.test_hello_9 [0]
2021-02-10 08:59:48.264: LOG-7-CGRPTERM: [thrd:main]: Group "new_cons_gp": waiting for 0 toppar(s), assignment in progress, 0 commit(s) (state up, join-state wait-unassign-to-complete) before terminating
2021-02-10 08:59:48.264: LOG-7-STOPSERVE: [thrd:main]: All partitions awaiting stop are now stopped: serving assignment
2021-02-10 08:59:48.264: LOG-7-DUMP: [thrd:main]: Assignment dump (started_cnt=0, wait_stop_cnt=0)
2021-02-10 08:59:48.264: LOG-7-DUMP_ALL: [thrd:main]: List with 0 partition(s):
2021-02-10 08:59:48.264: LOG-7-DUMP_PND: [thrd:main]: List with 0 partition(s):
2021-02-10 08:59:48.264: LOG-7-DUMP_QRY: [thrd:main]: List with 0 partition(s):
2021-02-10 08:59:48.264: LOG-7-DUMP_REM: [thrd:main]: List with 0 partition(s):
2021-02-10 08:59:48.264: LOG-7-ASSIGNDONE: [thrd:main]: Group "new_cons_gp": assignment operations done in join-state wait-unassign-to-complete (rebalance rejoin=false)
2021-02-10 08:59:48.264: LOG-7-UNASSIGN: [thrd:main]: Group "new_cons_gp": unassign done in state up (join-state wait-unassign-to-complete)
2021-02-10 08:59:48.264: LOG-7-MEMBERID: [thrd:main]: Group "new_cons_gp": updating member id "cppcona-cd562f47-8b63-41a6-b986-5d7546b682cf" -> ""
2021-02-10 08:59:48.264: LOG-7-LEAVE: [thrd:main]: Group "new_cons_gp": leave (in state up)
2021-02-10 08:59:48.264: LOG-7-NOREJOIN: [thrd:main]: Group "new_cons_gp": Not rejoining group without an assignment: Unassignment done: no subscribed topics
2021-02-10 08:59:48.264: LOG-7-CGRPJOINSTATE: [thrd:main]: Group "new_cons_gp" changed join state wait-unassign-to-complete -> init (state up)
2021-02-10 08:59:48.264: LOG-7-CGRPTERM: [thrd:main]: Group "new_cons_gp": waiting for 0 toppar(s), 0 commit(s), wait-leave, (state up, join-state init) before terminating
2021-02-10 08:59:48.264: LOG-7-CGRPTERM: [thrd:main]: Group "new_cons_gp": waiting for 0 toppar(s), 0 commit(s), wait-leave, (state up, join-state init) before terminating
2021-02-10 08:59:48.265: LOG-7-LEAVEGROUP: [thrd:main]: LeaveGroup response received in state up
2021-02-10 08:59:48.265: LOG-7-CGRPSTATE: [thrd:main]: Group "new_cons_gp" changed state up -> term (join-state init)
2021-02-10 08:59:48.265: LOG-7-ASSIGNMENT: [thrd:main]: Group "new_cons_gp": clearing group assignment
2021-02-10 08:59:48.265: LOG-7-COORDCLEAR: [thrd:main]: Group "new_cons_gp" broker sasl_plaintext://u-kafkatst-kafkadev-5.sd.firm.com:9092/5 is no longer coordinator
2021-02-10 08:59:48.265: LOG-7-DESTROY: [thrd:app]: Terminating instance (destroy flags NoConsumerClose (0x8))
2021-02-10 08:59:48.265: LOG-7-DESTROY: [thrd:main]: Destroy internal
2021-02-10 08:59:48.265: LOG-7-DESTROY: [thrd:main]: Removing all topics
2021-02-10 08:59:48.265: LOG-7-PARTCNT: [thrd:main]: Topic fps.dhamodha.test_hello_9 partition count changed from 1 to 0
2021-02-10 08:59:48.265: LOG-7-REMOVE: [thrd:main]: fps.dhamodha.test_hello_9 [0] no longer reported in metadata
2021-02-10 08:59:48.265: LOG-7-BRKMIGR: [thrd:main]: fps.dhamodha.test_hello_9 [0] 0x7f587c001c90 sending final LEAVE for removal by sasl_plaintext://u-kafkatst-kafkadev-5.sd.firm.com:9092/5
2021-02-10 08:59:48.265: LOG-7-TOPPARREMOVE: [thrd:main]: Removing toppar fps.dhamodha.test_hello_9 [-1] 0x7f587c0017f0
2021-02-10 08:59:48.265: LOG-7-DESTROY: [thrd:main]: fps.dhamodha.test_hello_9 [-1]: 0x7f587c0017f0 DESTROY_FINAL
2021-02-10 08:59:48.265: LOG-7-FETCHADD: [thrd:sasl_plaintext://u-kafkatst-kafkadev-5.sd.firm.com:9092/boots]: sasl_plaintext://u-kafkatst-kafkadev-5.sd.firm.com:9092/5: Removed fps.dhamodha.test_hello_9 [0] from fetch list (0 entries, opv 10): forced removal
2021-02-10 08:59:48.265: LOG-7-TOPBRK: [thrd:sasl_plaintext://u-kafkatst-kafkadev-5.sd.firm.com:9092/boots]: sasl_plaintext://u-kafkatst-kafkadev-5.sd.firm.com:9092/5: Topic fps.dhamodha.test_hello_9 [0]: leaving broker (0 messages in xmitq, next broker (none), rktp 0x7f587c001c90)
2021-02-10 08:59:48.265: LOG-7-TOPBRK: [thrd:sasl_plaintext://u-kafkatst-kafkadev-5.sd.firm.com:9092/boots]: sasl_plaintext://u-kafkatst-kafkadev-5.sd.firm.com:9092/5: Topic fps.dhamodha.test_hello_9 [0]: no next broker, failing 0 message(s) in partition queue
2021-02-10 08:59:48.265: LOG-7-METADATA: [thrd:GroupCoordinator]: Requesting metadata for 1/1 topics: broker down
2021-02-10 08:59:48.265: LOG-7-METADATA: [thrd:GroupCoordinator]: sasl_plaintext://u-kafkatst-kafkadev-5.sd.firm.com:9092/5: Request metadata for 1 topic(s): broker down
2021-02-10 08:59:48.265: LOG-7-TOPPARREMOVE: [thrd:sasl_plaintext://u-kafkatst-kafkadev-5.sd.firm.com:9092/boots]: Removing toppar fps.dhamodha.test_hello_9 [0] 0x7f587c001c90
2021-02-10 08:59:48.265: LOG-7-DESTROY: [thrd:sasl_plaintext://u-kafkatst-kafkadev-5.sd.firm.com:9092/boots]: fps.dhamodha.test_hello_9 [0]: 0x7f587c001c90 DESTROY_FINAL
2021-02-10 08:59:48.266: LOG-7-MEMBERID: [thrd:app]: Group "new_cons_gp": updating member id "" -> "(not-set)"
% Consumed 3 messages (201 bytes)

Feb 10 '21 14:02 dshivashankar1994

consumer 2.txt

Feb 10 '21 14:02 dshivashankar1994

Any updates here ?

Mar 20 '21 18:03 dshivashankar1994

Any updates here ?

Mar 31 '21 16:03 dshivashankar1994

Any updates here ?

Apr 07 '21 07:04 dshivashankar1994

Any updates here ?

Apr 15 '21 06:04 dshivashankar1994

Any updates here ?

Jun 06 '21 18:06 dshivashankar1994

Any updates here ?

Jun 07 '21 15:06 dshivashankar1994

update ?

Jun 15 '21 11:06 irfanbaigse

Any updates here ?

Aug 01 '21 14:08 dshivashankar1994

Any updates here ?

Sep 14 '21 13:09 dshivashankar1994

librdkafka librdkafka copied to clipboard

Multiple subscribers subscribing to single non-existing topic triggers multiple rebalance cbs

librdkafka
librdkafka copied to clipboard