Last active
April 6, 2022 15:06
-
-
Save deniskrumko/45c4cf57e2cee3b611bbf1c58bbd7ab6 to your computer and use it in GitHub Desktop.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| %7|1649256093.940|MEMBERID|rdkafka#consumer-1| [thrd:app]: Group "group_id_AAA": updating member id "(not-set)" -> "" | |
| %7|1649256093.940|INIT|rdkafka#consumer-1| [thrd:app]: librdkafka v1.8.2 (0x10802ff) rdkafka#consumer-1 initialized (builtin.features gzip,snappy,ssl,sasl,regex,lz4,sasl_gssapi,sasl_plain,sasl_scram,plugins,zstd,sasl_oauthbearer, CC CXX PKGCONFIG OSXLD LIBDL PLUGINS ZLIB SSL SASL_CYRUS ZSTD HDRHISTOGRAM LZ4_EXT SYSLOG SNAPPY SOCKEM SASL_SCRAM SASL_OAUTHBEARER CRC32C_HW, debug 0x500) | |
| %7|1649256093.940|CGRPSTATE|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA" changed state init -> query-coord (join-state init) | |
| %7|1649256093.940|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA": no broker available for coordinator query: intervaled in state query-coord | |
| %7|1649256093.940|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA" received op SUBSCRIBE in state query-coord (join-state init) | |
| %7|1649256093.940|SUBSCRIBE|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA": subscribe to new subscription of 1 topics (join-state init) | |
| %7|1649256093.940|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA": no broker available for coordinator query: intervaled in state query-coord | |
| %7|1649256093.940|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA" received op OFFSET_FETCH in state query-coord (join-state init) | |
| %7|1649256093.940|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA": no broker available for coordinator query: intervaled in state query-coord | |
| %7|1649256093.969|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA" received op OFFSET_FETCH in state query-coord (join-state init) | |
| %7|1649256093.969|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA": no broker available for coordinator query: intervaled in state query-coord | |
| %7|1649256093.993|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: 10.6.96.47:9092/bootstrap: Group "group_id_AAA": querying for coordinator: intervaled in state query-coord | |
| %7|1649256093.993|CGRPSTATE|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA" changed state query-coord -> wait-coord (join-state init) | |
| %7|1649256093.993|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA" received op OFFSET_FETCH in state wait-coord (join-state init) | |
| %7|1649256093.993|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA" received op OFFSET_FETCH in state wait-coord (join-state init) | |
| %7|1649256094.016|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA" received op OFFSET_FETCH in state wait-coord (join-state init) | |
| %7|1649256094.016|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA" received op OFFSET_FETCH in state wait-coord (join-state init) | |
| %7|1649256094.038|CGRPCOORD|rdkafka#consumer-1| [thrd:main]: 10.6.96.47:9092/0: Group "group_id_AAA" coordinator is 10.6.96.47:9092 id 0 | |
| %7|1649256094.039|CGRPCOORD|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA" changing coordinator -1 -> 0 | |
| %7|1649256094.039|COORDSET|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA" coordinator set to broker 10.6.96.47:9092/0 | |
| %7|1649256094.039|CGRPSTATE|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA" changed state wait-coord -> wait-broker-transport (join-state init) | |
| %7|1649256094.039|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: 10.6.96.47:9092/0: Group "group_id_AAA": querying for coordinator: intervaled in state wait-broker-transport | |
| %7|1649256094.039|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA" received op OFFSET_FETCH in state wait-broker-transport (join-state init) | |
| %7|1649256094.039|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA" received op OFFSET_FETCH in state wait-broker-transport (join-state init) | |
| %7|1649256094.063|CGRPCOORD|rdkafka#consumer-1| [thrd:main]: 10.6.96.47:9092/0: Group "group_id_AAA" coordinator is 10.6.96.47:9092 id 0 | |
| %7|1649256094.063|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA" received op OFFSET_FETCH in state wait-broker-transport (join-state init) | |
| %7|1649256094.087|CGRPSTATE|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA" changed state wait-broker-transport -> up (join-state init) | |
| %7|1649256094.087|JOIN|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA": join with 0 subscribed topic(s) | |
| %7|1649256094.087|CGRPMETADATA|rdkafka#consumer-1| [thrd:main]: consumer join: metadata for subscription only available for 0/1 topics (-1ms old) | |
| %7|1649256094.087|JOIN|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA": postponing join until up-to-date metadata is available | |
| %7|1649256094.087|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA" changed join state init -> wait-metadata (state up) | |
| %7|1649256094.087|DUMP|rdkafka#consumer-1| [thrd:main]: Assignment dump (started_cnt=0, wait_stop_cnt=0) | |
| %7|1649256094.087|DUMP_ALL|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649256094.087|DUMP_PND|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649256094.087|DUMP_QRY|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649256094.087|DUMP_REM|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649256094.087|ASSIGNDONE|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA": assignment operations done in join-state wait-metadata (rebalance rejoin=false) | |
| %7|1649256094.087|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA" received op OFFSET_FETCH in state up (join-state wait-metadata) | |
| %7|1649256094.087|OFFSET|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/0: Fetch committed offsets for 1/1 partition(s) | |
| %7|1649256094.110|SUBSCRIPTION|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA": effective subscription list changed from 0 to 1 topic(s): | |
| %7|1649256094.110|SUBSCRIPTION|rdkafka#consumer-1| [thrd:main]: Topic py_kafka_6 with 1 partition(s) | |
| %7|1649256094.110|REJOIN|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA": subscription updated from metadata change: rejoining group in state wait-metadata | |
| %7|1649256094.110|GRPLEADER|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA": resetting group leader info: group (re)join | |
| %7|1649256094.110|REJOIN|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA" (re)joining in join-state wait-metadata with 0 assigned partition(s): Metadata for subscribed topic(s) has changed | |
| %7|1649256094.110|REBALANCE|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA" initiating rebalance (NONE) in state up (join-state wait-metadata) with 0 assigned partition(s): Metadata for subscribed topic(s) has changed | |
| %7|1649256094.110|REJOIN|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA": Rejoining group without an assignment: Metadata for subscribed topic(s) has changed | |
| %7|1649256094.111|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA" changed join state wait-metadata -> init (state up) | |
| %7|1649256094.111|JOIN|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA": join with 1 subscribed topic(s) | |
| %7|1649256094.111|CGRPMETADATA|rdkafka#consumer-1| [thrd:main]: consumer join: metadata for subscription is up to date (0ms old) | |
| %7|1649256094.111|JOIN|rdkafka#consumer-1| [thrd:main]: 10.6.96.47:9092/0: Joining group "group_id_AAA" with 1 subscribed topic(s) and member id "" | |
| %7|1649256094.111|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA" changed join state init -> wait-join (state up) | |
| %7|1649256094.133|OFFSET|rdkafka#consumer-1| [thrd:main]: Topic py_kafka_6 [-1]: setting default offset INVALID | |
| %7|1649256094.134|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA" received op OFFSET_FETCH in state up (join-state wait-join) | |
| %7|1649256094.134|OFFSET|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/0: Fetch committed offsets for 1/1 partition(s) | |
| %7|1649256094.157|JOINGROUP|rdkafka#consumer-1| [thrd:main]: JoinGroup response: GenerationId -1, Protocol , LeaderId , my MemberId rdkafka-23f66be6-5732-490a-9a12-75239b2b02cc, member metadata count 0: Broker: Group member needs a valid member ID | |
| %7|1649256094.157|MEMBERID|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA": updating member id "" -> "rdkafka-23f66be6-5732-490a-9a12-75239b2b02cc" | |
| %7|1649256094.157|REJOIN|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA": Rejoining group without an assignment: JoinGroup error: Broker: Group member needs a valid member ID | |
| %7|1649256094.157|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA" changed join state wait-join -> init (state up) | |
| %7|1649256094.157|JOIN|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA": join with 1 subscribed topic(s) | |
| %7|1649256094.157|CGRPMETADATA|rdkafka#consumer-1| [thrd:main]: consumer join: metadata for subscription is up to date (46ms old) | |
| %7|1649256094.157|JOIN|rdkafka#consumer-1| [thrd:main]: 10.6.96.47:9092/0: Joining group "group_id_AAA" with 1 subscribed topic(s) and member id "rdkafka-23f66be6-5732-490a-9a12-75239b2b02cc" | |
| %7|1649256094.157|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA" changed join state init -> wait-join (state up) | |
| %7|1649256094.180|OFFSET|rdkafka#consumer-1| [thrd:main]: Topic py_kafka_6 [0]: setting default offset INVALID | |
| %7|1649256094.205|JOINGROUP|rdkafka#consumer-1| [thrd:main]: JoinGroup response: GenerationId 1, Protocol range, LeaderId rdkafka-23f66be6-5732-490a-9a12-75239b2b02cc (me), my MemberId rdkafka-23f66be6-5732-490a-9a12-75239b2b02cc, member metadata count 1: (no error) | |
| %7|1649256094.205|JOINGROUP|rdkafka#consumer-1| [thrd:main]: I am elected leader for group "group_id_AAA" with 1 member(s) | |
| %7|1649256094.205|GRPLEADER|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA": resetting group leader info: JoinGroup response clean-up | |
| %7|1649256094.205|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA" changed join state wait-join -> wait-metadata (state up) | |
| %7|1649256094.228|ASSIGN|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA" running range assignor for 1 member(s) and 1 eligible subscribed topic(s): | |
| %7|1649256094.228|ASSIGN|rdkafka#consumer-1| [thrd:main]: Member "rdkafka-23f66be6-5732-490a-9a12-75239b2b02cc" (me) with 0 owned partition(s) and 1 subscribed topic(s): | |
| %7|1649256094.228|ASSIGN|rdkafka#consumer-1| [thrd:main]: py_kafka_6 [-1] | |
| %7|1649256094.228|ASSIGN|rdkafka#consumer-1| [thrd:main]: range: Topic py_kafka_6 with 1 partition(s) and 1 subscribing member(s) | |
| %7|1649256094.228|ASSIGN|rdkafka#consumer-1| [thrd:main]: range: Member "rdkafka-23f66be6-5732-490a-9a12-75239b2b02cc": assigned topic py_kafka_6 partitions 0..0 | |
| %7|1649256094.228|ASSIGN|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA" range assignment for 1 member(s) finished in 0.051ms: | |
| %7|1649256094.228|ASSIGN|rdkafka#consumer-1| [thrd:main]: Member "rdkafka-23f66be6-5732-490a-9a12-75239b2b02cc" (me) assigned 1 partition(s): | |
| %7|1649256094.228|ASSIGN|rdkafka#consumer-1| [thrd:main]: py_kafka_6 [0] | |
| %7|1649256094.228|ASSIGNOR|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA": "range" assignor run for 1 member(s) | |
| %7|1649256094.228|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA" changed join state wait-metadata -> wait-sync (state up) | |
| %7|1649256094.253|SYNCGROUP|rdkafka#consumer-1| [thrd:main]: SyncGroup response: Success (30 bytes of MemberState data) | |
| %7|1649256094.253|ASSIGNMENT|rdkafka#consumer-1| [thrd:main]: List with 1 partition(s): | |
| %7|1649256094.253|ASSIGNMENT|rdkafka#consumer-1| [thrd:main]: py_kafka_6 [0] offset INVALID | |
| %7|1649256094.253|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA" changed join state wait-sync -> wait-assign-call (state up) | |
| %7|1649256094.253|ASSIGN|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA": delegating assign of 1 partition(s) to application on queue rd_kafka_cgrp_new: new assignment | |
| %7|1649256094.253|ASSIGNMENT|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA": setting group assignment to 1 partition(s) | |
| %7|1649256094.253|GRPASSIGNMENT|rdkafka#consumer-1| [thrd:main]: List with 1 partition(s): | |
| %7|1649256094.253|GRPASSIGNMENT|rdkafka#consumer-1| [thrd:main]: py_kafka_6 [0] offset INVALID | |
| %7|1649256094.253|HEARTBEAT|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/0: Heartbeat for group "group_id_AAA" generation id 1 | |
| %7|1649256094.253|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA" received op GET_REBALANCE_PROTOCOL in state up (join-state wait-assign-call) | |
| %7|1649256094.253|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA" received op ASSIGN in state up (join-state wait-assign-call) | |
| %7|1649256094.253|ASSIGN|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA": new assignment of 1 partition(s) in join-state wait-assign-call | |
| %7|1649256094.253|CLEARASSIGN|rdkafka#consumer-1| [thrd:main]: No current assignment to clear | |
| %7|1649256094.253|ASSIGNMENT|rdkafka#consumer-1| [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 | |
| %7|1649256094.253|PAUSE|rdkafka#consumer-1| [thrd:main]: Resuming fetchers for 1 assigned partition(s): assign called | |
| %7|1649256094.253|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA" changed join state wait-assign-call -> steady (state up) | |
| %7|1649256094.253|DUMP|rdkafka#consumer-1| [thrd:main]: Assignment dump (started_cnt=0, wait_stop_cnt=0) | |
| %7|1649256094.253|DUMP_ALL|rdkafka#consumer-1| [thrd:main]: List with 1 partition(s): | |
| %7|1649256094.253|DUMP_ALL|rdkafka#consumer-1| [thrd:main]: py_kafka_6 [0] offset STORED | |
| %7|1649256094.253|DUMP_PND|rdkafka#consumer-1| [thrd:main]: List with 1 partition(s): | |
| %7|1649256094.253|DUMP_PND|rdkafka#consumer-1| [thrd:main]: py_kafka_6 [0] offset STORED | |
| %7|1649256094.253|DUMP_QRY|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649256094.253|DUMP_REM|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649256094.253|SRVPEND|rdkafka#consumer-1| [thrd:main]: Querying committed offset for pending assigned partition py_kafka_6 [0] | |
| %7|1649256094.253|OFFSETFETCH|rdkafka#consumer-1| [thrd:main]: Fetching committed offsets for 1 pending partition(s) in assignment | |
| %7|1649256094.253|OFFSET|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/0: Fetch committed offsets for 1/1 partition(s) | |
| %7|1649256094.253|ASSIGNMENT|rdkafka#consumer-1| [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 | |
| %7|1649256094.302|OFFSETFETCH|rdkafka#consumer-1| [thrd:main]: Adding py_kafka_6 [0] back to pending list with offset INVALID | |
| %7|1649256094.302|DUMP|rdkafka#consumer-1| [thrd:main]: Assignment dump (started_cnt=0, wait_stop_cnt=0) | |
| %7|1649256094.302|DUMP_ALL|rdkafka#consumer-1| [thrd:main]: List with 1 partition(s): | |
| %7|1649256094.302|DUMP_ALL|rdkafka#consumer-1| [thrd:main]: py_kafka_6 [0] offset STORED | |
| %7|1649256094.302|DUMP_PND|rdkafka#consumer-1| [thrd:main]: List with 1 partition(s): | |
| %7|1649256094.302|DUMP_PND|rdkafka#consumer-1| [thrd:main]: py_kafka_6 [0] offset INVALID | |
| %7|1649256094.302|DUMP_QRY|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649256094.302|DUMP_REM|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649256094.302|SRVPEND|rdkafka#consumer-1| [thrd:main]: Starting pending assigned partition py_kafka_6 [0] at offset INVALID | |
| %7|1649256094.302|ASSIGNDONE|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA": assignment operations done in join-state steady (rebalance rejoin=false) | |
| %7|1649256094.302|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA" received op PARTITION_JOIN in state up (join-state steady) for py_kafka_6 [0] | |
| %7|1649256094.302|PARTADD|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA": add py_kafka_6 [0] | |
| %7|1649256094.429|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Topic py_kafka_6 [0] in state active at offset 0 (0/100000 msgs, 0/65536 kb queued, opv 4) is fetchable | |
| %7|1649256094.430|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch topic py_kafka_6 [0] at offset 0 (v4) | |
| %7|1649256094.430|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch 1/1/1 toppar(s) | |
| %7|1649256094.456|CONSUME|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Enqueue 10 message(s) (40 bytes, 10 ops) on py_kafka_6 [0] fetch queue (qlen 0, v4, last_offset 9, 0 ctrl msgs, uncompressed) | |
| %7|1649256094.456|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch topic py_kafka_6 [0] at offset 10 (v4) | |
| %7|1649256094.456|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch 1/1/1 toppar(s) | |
| %7|1649256094.456|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA" received op OFFSET_COMMIT in state up (join-state steady) | |
| %7|1649256094.456|OFFSET|rdkafka#consumer-1| [thrd:main]: Topic py_kafka_6 [0]: stored offset 10, committed offset -1001: setting stored offset 10 for commit | |
| %7|1649256094.456|COMMIT|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/0: Committing offsets for 1 partition(s) with generation-id 1 in join-state steady: manual | |
| %7|1649256094.481|COMMIT|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/0: OffsetCommit for 1 partition(s) in join-state steady: manual: returned: Success | |
| %7|1649256094.481|DUMP|rdkafka#consumer-1| [thrd:main]: Assignment dump (started_cnt=1, wait_stop_cnt=0) | |
| %7|1649256094.481|DUMP_ALL|rdkafka#consumer-1| [thrd:main]: List with 1 partition(s): | |
| %7|1649256094.481|DUMP_ALL|rdkafka#consumer-1| [thrd:main]: py_kafka_6 [0] offset STORED | |
| %7|1649256094.481|DUMP_PND|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649256094.481|DUMP_QRY|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649256094.481|DUMP_REM|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649256094.481|ASSIGNDONE|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA": assignment operations done in join-state steady (rebalance rejoin=false) | |
| %7|1649256094.481|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA" received op OFFSET_FETCH in state up (join-state steady) | |
| %7|1649256094.481|OFFSET|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/0: Fetch committed offsets for 1/1 partition(s) | |
| %7|1649256094.505|OFFSET|rdkafka#consumer-1| [thrd:main]: Topic py_kafka_6 [0]: setting default offset INVALID | |
| ========================================== | |
| NOTE: Here I got 10 messages from topic | |
| ========================================== | |
| %7|1649256094.505|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA" received op TERMINATE in state up (join-state steady) | |
| %7|1649256094.505|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Terminating group "group_id_AAA" in state up with 1 partition(s) | |
| %7|1649256094.506|UNSUBSCRIBE|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA": unsubscribe from current subscription of size 1 (leave group=true, has joined=true, rdkafka-23f66be6-5732-490a-9a12-75239b2b02cc, join-state steady) | |
| %7|1649256094.506|SUBSCRIPTION|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA": clearing subscribed topics list (1) | |
| %7|1649256094.506|SUBSCRIPTION|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA": effective subscription list changed from 1 to 0 topic(s): | |
| %7|1649256094.506|GRPLEADER|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA": resetting group leader info: unsubscribe | |
| %7|1649256094.506|REBALANCE|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA" initiating rebalance (EAGER) in state up (join-state steady) with 1 assigned partition(s): unsubscribe | |
| %7|1649256094.506|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA" changed join state steady -> wait-unassign-call (state up) | |
| %7|1649256094.506|ASSIGN|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA": delegating revoke of 1 partition(s) to application on queue rd_kafka_consumer_close: unsubscribe | |
| %7|1649256094.506|PAUSE|rdkafka#consumer-1| [thrd:main]: Pausing fetchers for 1 assigned partition(s): rebalance | |
| %7|1649256094.506|ASSIGNMENT|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA": clearing group assignment | |
| %7|1649256094.506|DUMP|rdkafka#consumer-1| [thrd:main]: Assignment dump (started_cnt=1, wait_stop_cnt=0) | |
| %7|1649256094.506|DUMP_ALL|rdkafka#consumer-1| [thrd:main]: List with 1 partition(s): | |
| %7|1649256094.506|DUMP_ALL|rdkafka#consumer-1| [thrd:main]: py_kafka_6 [0] offset STORED | |
| %7|1649256094.506|DUMP_PND|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649256094.506|DUMP_QRY|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649256094.506|DUMP_REM|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649256094.506|ASSIGNDONE|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA": assignment operations done in join-state wait-unassign-call (rebalance rejoin=false) | |
| %7|1649256094.506|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA": waiting for assign call, 1 toppar(s), 0 commit(s) (state up, join-state wait-unassign-call) before terminating | |
| %7|1649256094.506|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA": waiting for assign call, 1 toppar(s), 0 commit(s) (state up, join-state wait-unassign-call) before terminating | |
| %7|1649256094.506|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA" received op GET_REBALANCE_PROTOCOL in state up (join-state wait-unassign-call) | |
| %7|1649256094.506|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA": waiting for assign call, 1 toppar(s), 0 commit(s) (state up, join-state wait-unassign-call) before terminating | |
| %7|1649256094.506|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA" received op ASSIGN in state up (join-state wait-unassign-call) | |
| %7|1649256094.506|ASSIGN|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA": Consumer is terminating: treating assign as unassign | |
| %7|1649256094.506|CLEARASSIGN|rdkafka#consumer-1| [thrd:main]: Clearing current assignment of 1 partition(s) | |
| %7|1649256094.506|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA" changed join state wait-unassign-call -> wait-unassign-to-complete (state up) | |
| %7|1649256094.506|DUMP|rdkafka#consumer-1| [thrd:main]: Assignment dump (started_cnt=1, wait_stop_cnt=0) | |
| %7|1649256094.506|DUMP_ALL|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649256094.506|DUMP_PND|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649256094.506|DUMP_QRY|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649256094.506|DUMP_REM|rdkafka#consumer-1| [thrd:main]: List with 1 partition(s): | |
| %7|1649256094.506|DUMP_REM|rdkafka#consumer-1| [thrd:main]: py_kafka_6 [0] offset STORED | |
| %7|1649256094.506|REMOVE|rdkafka#consumer-1| [thrd:main]: Removing py_kafka_6 [0] from assignment (started=true, pending=false, queried=false, stored offset=10) | |
| %7|1649256094.506|REMOVE|rdkafka#consumer-1| [thrd:main]: Served 1 removed partition(s), with 1 offset(s) to commit | |
| %7|1649256094.506|ASSIGNMENT|rdkafka#consumer-1| [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 | |
| %7|1649256094.506|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA": waiting for 1 toppar(s), assignment in progress, 0 commit(s) (state up, join-state wait-unassign-to-complete) before terminating | |
| %7|1649256094.506|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA": waiting for 1 toppar(s), assignment in progress, 0 commit(s) (state up, join-state wait-unassign-to-complete) before terminating | |
| %7|1649256094.506|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA" received op PARTITION_LEAVE in state up (join-state wait-unassign-to-complete) for py_kafka_6 [0] | |
| %7|1649256094.506|PARTDEL|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA": delete py_kafka_6 [0] | |
| %7|1649256094.506|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA": waiting for 0 toppar(s), assignment in progress, 0 commit(s) (state up, join-state wait-unassign-to-complete) before terminating | |
| %7|1649256094.506|STOPSERVE|rdkafka#consumer-1| [thrd:main]: All partitions awaiting stop are now stopped: serving assignment | |
| %7|1649256094.506|DUMP|rdkafka#consumer-1| [thrd:main]: Assignment dump (started_cnt=0, wait_stop_cnt=0) | |
| %7|1649256094.506|DUMP_ALL|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649256094.506|DUMP_PND|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649256094.506|DUMP_QRY|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649256094.506|DUMP_REM|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649256094.506|ASSIGNDONE|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA": assignment operations done in join-state wait-unassign-to-complete (rebalance rejoin=false) | |
| %7|1649256094.506|UNASSIGN|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA": unassign done in state up (join-state wait-unassign-to-complete) | |
| %7|1649256094.506|MEMBERID|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA": updating member id "rdkafka-23f66be6-5732-490a-9a12-75239b2b02cc" -> "" | |
| %7|1649256094.506|LEAVE|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA": leave (in state up) | |
| %7|1649256094.506|NOREJOIN|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA": Not rejoining group without an assignment: Unassignment done: no subscribed topics | |
| %7|1649256094.506|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA" changed join state wait-unassign-to-complete -> init (state up) | |
| %7|1649256094.506|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA": waiting for 0 toppar(s), 0 commit(s), wait-leave, (state up, join-state init) before terminating | |
| %7|1649256094.529|LEAVEGROUP|rdkafka#consumer-1| [thrd:main]: LeaveGroup response received in state up | |
| %7|1649256094.529|CGRPSTATE|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA" changed state up -> term (join-state init) | |
| %7|1649256094.529|ASSIGNMENT|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA": clearing group assignment | |
| %7|1649256094.529|COORDCLEAR|rdkafka#consumer-1| [thrd:main]: Group "group_id_AAA" broker 10.6.96.47:9092/0 is no longer coordinator | |
| %7|1649256094.529|DESTROY|rdkafka#consumer-1| [thrd:app]: Terminating instance (destroy flags none (0x0)) | |
| %7|1649256094.529|DESTROY|rdkafka#consumer-1| [thrd:main]: Destroy internal | |
| %7|1649256094.529|DESTROY|rdkafka#consumer-1| [thrd:main]: Removing all topics | |
| %7|1649256094.529|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Topic py_kafka_6 [0] in state stopped at offset 10 (0/100000 msgs, 0/65536 kb queued, opv 4) is not fetchable: partition removed | |
| %7|1649256094.530|MEMBERID|rdkafka#consumer-1| [thrd:app]: Group "group_id_AAA": updating member id "" -> "(not-set)" | |
| ========================================== | |
| Program autoclosed on getting 10 messages | |
| ========================================== |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| %7|1649256150.205|MEMBERID|rdkafka#consumer-1| [thrd:app]: Group "group_id_BBB": updating member id "(not-set)" -> "" | |
| %7|1649256150.205|INIT|rdkafka#consumer-1| [thrd:app]: librdkafka v1.8.2 (0x10802ff) rdkafka#consumer-1 initialized (builtin.features gzip,snappy,ssl,sasl,regex,lz4,sasl_gssapi,sasl_plain,sasl_scram,plugins,zstd,sasl_oauthbearer, CC CXX PKGCONFIG OSXLD LIBDL PLUGINS ZLIB SSL SASL_CYRUS ZSTD HDRHISTOGRAM LZ4_EXT SYSLOG SNAPPY SOCKEM SASL_SCRAM SASL_OAUTHBEARER CRC32C_HW, debug 0x500) | |
| %7|1649256150.205|CGRPSTATE|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB" changed state init -> query-coord (join-state init) | |
| %7|1649256150.205|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": no broker available for coordinator query: intervaled in state query-coord | |
| %7|1649256150.205|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB" received op SUBSCRIBE in state query-coord (join-state init) | |
| %7|1649256150.205|SUBSCRIBE|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": subscribe to new subscription of 1 topics (join-state init) | |
| %7|1649256150.205|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": no broker available for coordinator query: intervaled in state query-coord | |
| %7|1649256150.205|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB" received op OFFSET_FETCH in state query-coord (join-state init) | |
| %7|1649256150.206|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": no broker available for coordinator query: intervaled in state query-coord | |
| %7|1649256150.232|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB" received op OFFSET_FETCH in state query-coord (join-state init) | |
| %7|1649256150.232|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": no broker available for coordinator query: intervaled in state query-coord | |
| %7|1649256150.256|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: 10.6.96.47:9092/bootstrap: Group "group_id_BBB": querying for coordinator: intervaled in state query-coord | |
| %7|1649256150.256|CGRPSTATE|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB" changed state query-coord -> wait-coord (join-state init) | |
| %7|1649256150.256|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB" received op OFFSET_FETCH in state wait-coord (join-state init) | |
| %7|1649256150.256|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB" received op OFFSET_FETCH in state wait-coord (join-state init) | |
| %7|1649256150.281|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB" received op OFFSET_FETCH in state wait-coord (join-state init) | |
| %7|1649256150.281|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB" received op OFFSET_FETCH in state wait-coord (join-state init) | |
| %7|1649256150.304|CGRPCOORD|rdkafka#consumer-1| [thrd:main]: 10.6.96.47:9092/0: Group "group_id_BBB" coordinator is 10.6.96.47:9092 id 0 | |
| %7|1649256150.304|CGRPCOORD|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB" changing coordinator -1 -> 0 | |
| %7|1649256150.304|COORDSET|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB" coordinator set to broker 10.6.96.47:9092/0 | |
| %7|1649256150.304|CGRPSTATE|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB" changed state wait-coord -> wait-broker-transport (join-state init) | |
| %7|1649256150.304|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: 10.6.96.47:9092/0: Group "group_id_BBB": querying for coordinator: intervaled in state wait-broker-transport | |
| %7|1649256150.304|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB" received op OFFSET_FETCH in state wait-broker-transport (join-state init) | |
| %7|1649256150.304|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB" received op OFFSET_FETCH in state wait-broker-transport (join-state init) | |
| %7|1649256150.327|CGRPCOORD|rdkafka#consumer-1| [thrd:main]: 10.6.96.47:9092/0: Group "group_id_BBB" coordinator is 10.6.96.47:9092 id 0 | |
| %7|1649256150.328|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB" received op OFFSET_FETCH in state wait-broker-transport (join-state init) | |
| %7|1649256150.356|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB" received op OFFSET_FETCH in state wait-broker-transport (join-state init) | |
| %7|1649256150.356|CGRPSTATE|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB" changed state wait-broker-transport -> up (join-state init) | |
| %7|1649256150.356|JOIN|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": join with 0 subscribed topic(s) | |
| %7|1649256150.356|CGRPMETADATA|rdkafka#consumer-1| [thrd:main]: consumer join: metadata for subscription only available for 0/1 topics (-1ms old) | |
| %7|1649256150.356|JOIN|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": postponing join until up-to-date metadata is available | |
| %7|1649256150.356|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB" changed join state init -> wait-metadata (state up) | |
| %7|1649256150.356|DUMP|rdkafka#consumer-1| [thrd:main]: Assignment dump (started_cnt=0, wait_stop_cnt=0) | |
| %7|1649256150.356|DUMP_ALL|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649256150.356|DUMP_PND|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649256150.356|DUMP_QRY|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649256150.356|DUMP_REM|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649256150.356|ASSIGNDONE|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": assignment operations done in join-state wait-metadata (rebalance rejoin=false) | |
| %7|1649256150.356|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB" received op OFFSET_FETCH in state up (join-state wait-metadata) | |
| %7|1649256150.356|OFFSET|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/0: Fetch committed offsets for 1/1 partition(s) | |
| %7|1649256150.380|SUBSCRIPTION|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": effective subscription list changed from 0 to 1 topic(s): | |
| %7|1649256150.380|SUBSCRIPTION|rdkafka#consumer-1| [thrd:main]: Topic py_kafka_6 with 1 partition(s) | |
| %7|1649256150.380|REJOIN|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": subscription updated from metadata change: rejoining group in state wait-metadata | |
| %7|1649256150.380|GRPLEADER|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": resetting group leader info: group (re)join | |
| %7|1649256150.380|REJOIN|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB" (re)joining in join-state wait-metadata with 0 assigned partition(s): Metadata for subscribed topic(s) has changed | |
| %7|1649256150.380|REBALANCE|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB" initiating rebalance (NONE) in state up (join-state wait-metadata) with 0 assigned partition(s): Metadata for subscribed topic(s) has changed | |
| %7|1649256150.380|REJOIN|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": Rejoining group without an assignment: Metadata for subscribed topic(s) has changed | |
| %7|1649256150.380|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB" changed join state wait-metadata -> init (state up) | |
| %7|1649256150.380|JOIN|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": join with 1 subscribed topic(s) | |
| %7|1649256150.380|CGRPMETADATA|rdkafka#consumer-1| [thrd:main]: consumer join: metadata for subscription is up to date (0ms old) | |
| %7|1649256150.380|JOIN|rdkafka#consumer-1| [thrd:main]: 10.6.96.47:9092/0: Joining group "group_id_BBB" with 1 subscribed topic(s) and member id "" | |
| %7|1649256150.380|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB" changed join state init -> wait-join (state up) | |
| %7|1649256150.403|OFFSET|rdkafka#consumer-1| [thrd:main]: Topic py_kafka_6 [-1]: setting default offset INVALID | |
| %7|1649256150.403|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB" received op OFFSET_FETCH in state up (join-state wait-join) | |
| %7|1649256150.403|OFFSET|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/0: Fetch committed offsets for 1/1 partition(s) | |
| %7|1649256150.426|JOINGROUP|rdkafka#consumer-1| [thrd:main]: JoinGroup response: GenerationId -1, Protocol , LeaderId , my MemberId rdkafka-86dcb9a9-939a-47aa-be0b-76f8e1fc1520, member metadata count 0: Broker: Group member needs a valid member ID | |
| %7|1649256150.426|MEMBERID|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": updating member id "" -> "rdkafka-86dcb9a9-939a-47aa-be0b-76f8e1fc1520" | |
| %7|1649256150.426|REJOIN|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": Rejoining group without an assignment: JoinGroup error: Broker: Group member needs a valid member ID | |
| %7|1649256150.426|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB" changed join state wait-join -> init (state up) | |
| %7|1649256150.426|JOIN|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": join with 1 subscribed topic(s) | |
| %7|1649256150.426|CGRPMETADATA|rdkafka#consumer-1| [thrd:main]: consumer join: metadata for subscription is up to date (45ms old) | |
| %7|1649256150.426|JOIN|rdkafka#consumer-1| [thrd:main]: 10.6.96.47:9092/0: Joining group "group_id_BBB" with 1 subscribed topic(s) and member id "rdkafka-86dcb9a9-939a-47aa-be0b-76f8e1fc1520" | |
| %7|1649256150.426|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB" changed join state init -> wait-join (state up) | |
| %7|1649256150.449|OFFSET|rdkafka#consumer-1| [thrd:main]: Topic py_kafka_6 [0]: setting default offset INVALID | |
| %7|1649256150.473|JOINGROUP|rdkafka#consumer-1| [thrd:main]: JoinGroup response: GenerationId 1, Protocol range, LeaderId rdkafka-86dcb9a9-939a-47aa-be0b-76f8e1fc1520 (me), my MemberId rdkafka-86dcb9a9-939a-47aa-be0b-76f8e1fc1520, member metadata count 1: (no error) | |
| %7|1649256150.473|JOINGROUP|rdkafka#consumer-1| [thrd:main]: I am elected leader for group "group_id_BBB" with 1 member(s) | |
| %7|1649256150.473|GRPLEADER|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": resetting group leader info: JoinGroup response clean-up | |
| %7|1649256150.473|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB" changed join state wait-join -> wait-metadata (state up) | |
| %7|1649256150.497|ASSIGN|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB" running range assignor for 1 member(s) and 1 eligible subscribed topic(s): | |
| %7|1649256150.497|ASSIGN|rdkafka#consumer-1| [thrd:main]: Member "rdkafka-86dcb9a9-939a-47aa-be0b-76f8e1fc1520" (me) with 0 owned partition(s) and 1 subscribed topic(s): | |
| %7|1649256150.497|ASSIGN|rdkafka#consumer-1| [thrd:main]: py_kafka_6 [-1] | |
| %7|1649256150.497|ASSIGN|rdkafka#consumer-1| [thrd:main]: range: Topic py_kafka_6 with 1 partition(s) and 1 subscribing member(s) | |
| %7|1649256150.497|ASSIGN|rdkafka#consumer-1| [thrd:main]: range: Member "rdkafka-86dcb9a9-939a-47aa-be0b-76f8e1fc1520": assigned topic py_kafka_6 partitions 0..0 | |
| %7|1649256150.497|ASSIGN|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB" range assignment for 1 member(s) finished in 0.025ms: | |
| %7|1649256150.497|ASSIGN|rdkafka#consumer-1| [thrd:main]: Member "rdkafka-86dcb9a9-939a-47aa-be0b-76f8e1fc1520" (me) assigned 1 partition(s): | |
| %7|1649256150.497|ASSIGN|rdkafka#consumer-1| [thrd:main]: py_kafka_6 [0] | |
| %7|1649256150.497|ASSIGNOR|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": "range" assignor run for 1 member(s) | |
| %7|1649256150.497|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB" changed join state wait-metadata -> wait-sync (state up) | |
| %7|1649256150.521|SYNCGROUP|rdkafka#consumer-1| [thrd:main]: SyncGroup response: Success (30 bytes of MemberState data) | |
| %7|1649256150.521|ASSIGNMENT|rdkafka#consumer-1| [thrd:main]: List with 1 partition(s): | |
| %7|1649256150.521|ASSIGNMENT|rdkafka#consumer-1| [thrd:main]: py_kafka_6 [0] offset INVALID | |
| %7|1649256150.521|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB" changed join state wait-sync -> wait-assign-call (state up) | |
| %7|1649256150.521|ASSIGN|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": delegating assign of 1 partition(s) to application on queue rd_kafka_cgrp_new: new assignment | |
| %7|1649256150.521|ASSIGNMENT|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": setting group assignment to 1 partition(s) | |
| %7|1649256150.521|GRPASSIGNMENT|rdkafka#consumer-1| [thrd:main]: List with 1 partition(s): | |
| %7|1649256150.521|GRPASSIGNMENT|rdkafka#consumer-1| [thrd:main]: py_kafka_6 [0] offset INVALID | |
| %7|1649256150.521|HEARTBEAT|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/0: Heartbeat for group "group_id_BBB" generation id 1 | |
| %7|1649256150.521|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB" received op GET_REBALANCE_PROTOCOL in state up (join-state wait-assign-call) | |
| %7|1649256150.521|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB" received op ASSIGN in state up (join-state wait-assign-call) | |
| %7|1649256150.521|ASSIGN|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": new assignment of 1 partition(s) in join-state wait-assign-call | |
| %7|1649256150.521|CLEARASSIGN|rdkafka#consumer-1| [thrd:main]: No current assignment to clear | |
| %7|1649256150.521|ASSIGNMENT|rdkafka#consumer-1| [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 | |
| %7|1649256150.521|PAUSE|rdkafka#consumer-1| [thrd:main]: Resuming fetchers for 1 assigned partition(s): assign called | |
| %7|1649256150.521|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB" changed join state wait-assign-call -> steady (state up) | |
| %7|1649256150.521|DUMP|rdkafka#consumer-1| [thrd:main]: Assignment dump (started_cnt=0, wait_stop_cnt=0) | |
| %7|1649256150.521|DUMP_ALL|rdkafka#consumer-1| [thrd:main]: List with 1 partition(s): | |
| %7|1649256150.521|DUMP_ALL|rdkafka#consumer-1| [thrd:main]: py_kafka_6 [0] offset STORED | |
| %7|1649256150.521|DUMP_PND|rdkafka#consumer-1| [thrd:main]: List with 1 partition(s): | |
| %7|1649256150.521|DUMP_PND|rdkafka#consumer-1| [thrd:main]: py_kafka_6 [0] offset STORED | |
| %7|1649256150.521|DUMP_QRY|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649256150.521|DUMP_REM|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649256150.521|SRVPEND|rdkafka#consumer-1| [thrd:main]: Querying committed offset for pending assigned partition py_kafka_6 [0] | |
| %7|1649256150.521|OFFSETFETCH|rdkafka#consumer-1| [thrd:main]: Fetching committed offsets for 1 pending partition(s) in assignment | |
| %7|1649256150.521|OFFSET|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/0: Fetch committed offsets for 1/1 partition(s) | |
| %7|1649256150.521|ASSIGNMENT|rdkafka#consumer-1| [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 | |
| %7|1649256150.568|OFFSETFETCH|rdkafka#consumer-1| [thrd:main]: Adding py_kafka_6 [0] back to pending list with offset INVALID | |
| %7|1649256150.568|DUMP|rdkafka#consumer-1| [thrd:main]: Assignment dump (started_cnt=0, wait_stop_cnt=0) | |
| %7|1649256150.568|DUMP_ALL|rdkafka#consumer-1| [thrd:main]: List with 1 partition(s): | |
| %7|1649256150.568|DUMP_ALL|rdkafka#consumer-1| [thrd:main]: py_kafka_6 [0] offset STORED | |
| %7|1649256150.568|DUMP_PND|rdkafka#consumer-1| [thrd:main]: List with 1 partition(s): | |
| %7|1649256150.568|DUMP_PND|rdkafka#consumer-1| [thrd:main]: py_kafka_6 [0] offset INVALID | |
| %7|1649256150.568|DUMP_QRY|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649256150.568|DUMP_REM|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649256150.568|SRVPEND|rdkafka#consumer-1| [thrd:main]: Starting pending assigned partition py_kafka_6 [0] at offset INVALID | |
| %7|1649256150.568|ASSIGNDONE|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": assignment operations done in join-state steady (rebalance rejoin=false) | |
| %7|1649256150.569|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB" received op PARTITION_JOIN in state up (join-state steady) for py_kafka_6 [0] | |
| %7|1649256150.569|PARTADD|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": add py_kafka_6 [0] | |
| %7|1649256150.693|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Topic py_kafka_6 [0] in state active at offset 10 (0/100000 msgs, 0/65536 kb queued, opv 4) is fetchable | |
| %7|1649256150.693|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch topic py_kafka_6 [0] at offset 10 (v4) | |
| %7|1649256150.693|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch 1/1/1 toppar(s) | |
| %7|1649256151.301|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch topic py_kafka_6 [0] at offset 10 (v4) | |
| %7|1649256151.301|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch 1/1/1 toppar(s) | |
| %7|1649256151.915|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch topic py_kafka_6 [0] at offset 10 (v4) | |
| %7|1649256151.915|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch 1/1/1 toppar(s) | |
| %7|1649256152.528|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch topic py_kafka_6 [0] at offset 10 (v4) | |
| %7|1649256152.528|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch 1/1/1 toppar(s) | |
| %7|1649256153.449|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch topic py_kafka_6 [0] at offset 10 (v4) | |
| %7|1649256153.449|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch 1/1/1 toppar(s) | |
| %7|1649256153.535|HEARTBEAT|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/0: Heartbeat for group "group_id_BBB" generation id 1 | |
| %7|1649256153.973|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch topic py_kafka_6 [0] at offset 10 (v4) | |
| %7|1649256153.973|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch 1/1/1 toppar(s) | |
| %7|1649256154.678|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch topic py_kafka_6 [0] at offset 10 (v4) | |
| %7|1649256154.678|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch 1/1/1 toppar(s) | |
| %7|1649256155.210|OFFSET|rdkafka#consumer-1| [thrd:main]: Topic py_kafka_6 [0]: stored offset -1001, committed offset -1001: not including in commit | |
| %7|1649256155.210|DUMP|rdkafka#consumer-1| [thrd:main]: Assignment dump (started_cnt=1, wait_stop_cnt=0) | |
| %7|1649256155.210|DUMP_ALL|rdkafka#consumer-1| [thrd:main]: List with 1 partition(s): | |
| %7|1649256155.210|DUMP_ALL|rdkafka#consumer-1| [thrd:main]: py_kafka_6 [0] offset STORED | |
| %7|1649256155.210|DUMP_PND|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649256155.210|DUMP_QRY|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649256155.210|DUMP_REM|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649256155.210|ASSIGNDONE|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": assignment operations done in join-state steady (rebalance rejoin=false) | |
| %7|1649256155.292|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch topic py_kafka_6 [0] at offset 10 (v4) | |
| %7|1649256155.292|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch 1/1/1 toppar(s) | |
| %7|1649256155.907|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch topic py_kafka_6 [0] at offset 10 (v4) | |
| %7|1649256155.907|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch 1/1/1 toppar(s) | |
| %7|1649256156.521|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch topic py_kafka_6 [0] at offset 10 (v4) | |
| %7|1649256156.521|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch 1/1/1 toppar(s) | |
| %7|1649256156.551|HEARTBEAT|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/0: Heartbeat for group "group_id_BBB" generation id 1 | |
| %7|1649256157.045|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch topic py_kafka_6 [0] at offset 10 (v4) | |
| %7|1649256157.045|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch 1/1/1 toppar(s) | |
| ^C%7|1649256157.094|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB" received op TERMINATE in state up (join-state steady) | |
| %7|1649256157.094|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Terminating group "group_id_BBB" in state up with 1 partition(s) | |
| %7|1649256157.094|UNSUBSCRIBE|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": unsubscribe from current subscription of size 1 (leave group=true, has joined=true, rdkafka-86dcb9a9-939a-47aa-be0b-76f8e1fc1520, join-state steady) | |
| %7|1649256157.094|SUBSCRIPTION|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": clearing subscribed topics list (1) | |
| %7|1649256157.095|SUBSCRIPTION|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": effective subscription list changed from 1 to 0 topic(s): | |
| %7|1649256157.095|GRPLEADER|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": resetting group leader info: unsubscribe | |
| %7|1649256157.095|REBALANCE|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB" initiating rebalance (EAGER) in state up (join-state steady) with 1 assigned partition(s): unsubscribe | |
| %7|1649256157.095|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB" changed join state steady -> wait-unassign-call (state up) | |
| %7|1649256157.095|ASSIGN|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": delegating revoke of 1 partition(s) to application on queue rd_kafka_consumer_close: unsubscribe | |
| %7|1649256157.095|PAUSE|rdkafka#consumer-1| [thrd:main]: Pausing fetchers for 1 assigned partition(s): rebalance | |
| %7|1649256157.095|ASSIGNMENT|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": clearing group assignment | |
| %7|1649256157.095|DUMP|rdkafka#consumer-1| [thrd:main]: Assignment dump (started_cnt=1, wait_stop_cnt=0) | |
| %7|1649256157.095|DUMP_ALL|rdkafka#consumer-1| [thrd:main]: List with 1 partition(s): | |
| %7|1649256157.095|DUMP_ALL|rdkafka#consumer-1| [thrd:main]: py_kafka_6 [0] offset STORED | |
| %7|1649256157.095|DUMP_PND|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649256157.095|DUMP_QRY|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649256157.095|DUMP_REM|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649256157.095|ASSIGNDONE|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": assignment operations done in join-state wait-unassign-call (rebalance rejoin=false) | |
| %7|1649256157.095|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": waiting for assign call, 1 toppar(s), 0 commit(s) (state up, join-state wait-unassign-call) before terminating | |
| %7|1649256157.095|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": waiting for assign call, 1 toppar(s), 0 commit(s) (state up, join-state wait-unassign-call) before terminating | |
| %7|1649256157.095|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB" received op GET_REBALANCE_PROTOCOL in state up (join-state wait-unassign-call) | |
| %7|1649256157.095|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": waiting for assign call, 1 toppar(s), 0 commit(s) (state up, join-state wait-unassign-call) before terminating | |
| %7|1649256157.095|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB" received op ASSIGN in state up (join-state wait-unassign-call) | |
| %7|1649256157.095|ASSIGN|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": Consumer is terminating: treating assign as unassign | |
| %7|1649256157.095|CLEARASSIGN|rdkafka#consumer-1| [thrd:main]: Clearing current assignment of 1 partition(s) | |
| %7|1649256157.095|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB" changed join state wait-unassign-call -> wait-unassign-to-complete (state up) | |
| %7|1649256157.095|DUMP|rdkafka#consumer-1| [thrd:main]: Assignment dump (started_cnt=1, wait_stop_cnt=0) | |
| %7|1649256157.095|DUMP_ALL|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649256157.095|DUMP_PND|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649256157.095|DUMP_QRY|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649256157.095|DUMP_REM|rdkafka#consumer-1| [thrd:main]: List with 1 partition(s): | |
| %7|1649256157.095|DUMP_REM|rdkafka#consumer-1| [thrd:main]: py_kafka_6 [0] offset STORED | |
| %7|1649256157.095|REMOVE|rdkafka#consumer-1| [thrd:main]: Removing py_kafka_6 [0] from assignment (started=true, pending=false, queried=false, stored offset=INVALID) | |
| %7|1649256157.095|REMOVE|rdkafka#consumer-1| [thrd:main]: Served 1 removed partition(s), with 0 offset(s) to commit | |
| %7|1649256157.095|ASSIGNMENT|rdkafka#consumer-1| [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 | |
| %7|1649256157.095|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": waiting for 1 toppar(s), assignment in progress, 0 commit(s) (state up, join-state wait-unassign-to-complete) before terminating | |
| %7|1649256157.095|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": waiting for 1 toppar(s), assignment in progress, 0 commit(s) (state up, join-state wait-unassign-to-complete) before terminating | |
| %7|1649256157.095|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB" received op PARTITION_LEAVE in state up (join-state wait-unassign-to-complete) for py_kafka_6 [0] | |
| %7|1649256157.095|PARTDEL|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": delete py_kafka_6 [0] | |
| %7|1649256157.095|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": waiting for 0 toppar(s), assignment in progress, 0 commit(s) (state up, join-state wait-unassign-to-complete) before terminating | |
| %7|1649256157.095|STOPSERVE|rdkafka#consumer-1| [thrd:main]: All partitions awaiting stop are now stopped: serving assignment | |
| %7|1649256157.095|DUMP|rdkafka#consumer-1| [thrd:main]: Assignment dump (started_cnt=0, wait_stop_cnt=0) | |
| %7|1649256157.095|DUMP_ALL|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649256157.095|DUMP_PND|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649256157.095|DUMP_QRY|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649256157.095|DUMP_REM|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649256157.095|ASSIGNDONE|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": assignment operations done in join-state wait-unassign-to-complete (rebalance rejoin=false) | |
| %7|1649256157.095|UNASSIGN|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": unassign done in state up (join-state wait-unassign-to-complete) | |
| %7|1649256157.095|MEMBERID|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": updating member id "rdkafka-86dcb9a9-939a-47aa-be0b-76f8e1fc1520" -> "" | |
| %7|1649256157.095|LEAVE|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": leave (in state up) | |
| %7|1649256157.095|NOREJOIN|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": Not rejoining group without an assignment: Unassignment done: no subscribed topics | |
| %7|1649256157.095|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB" changed join state wait-unassign-to-complete -> init (state up) | |
| %7|1649256157.095|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": waiting for 0 toppar(s), 0 commit(s), wait-leave, (state up, join-state init) before terminating | |
| %7|1649256157.119|LEAVEGROUP|rdkafka#consumer-1| [thrd:main]: LeaveGroup response received in state up | |
| %7|1649256157.119|CGRPSTATE|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB" changed state up -> term (join-state init) | |
| %7|1649256157.119|ASSIGNMENT|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": clearing group assignment | |
| %7|1649256157.119|COORDCLEAR|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB" broker 10.6.96.47:9092/0 is no longer coordinator | |
| %7|1649256157.119|DESTROY|rdkafka#consumer-1| [thrd:app]: Terminating instance (destroy flags none (0x0)) | |
| %7|1649256157.119|DESTROY|rdkafka#consumer-1| [thrd:main]: Destroy internal | |
| %7|1649256157.119|DESTROY|rdkafka#consumer-1| [thrd:main]: Removing all topics | |
| %7|1649256157.120|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Topic py_kafka_6 [0] in state stopped at offset 10 (0/100000 msgs, 0/65536 kb queued, opv 4) is not fetchable: partition removed | |
| %7|1649256157.120|MEMBERID|rdkafka#consumer-1| [thrd:app]: Group "group_id_BBB": updating member id "" -> "(not-set)" | |
| ======================== | |
| MANUALLY CTRL+C PROGRAM | |
| ======================== |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| ======================= | |
| FIXED CONFIG: | |
| config = { | |
| 'bootstrap.servers': my_broker, | |
| 'group.id': 'group_id_BBB', | |
| 'auto.offset.reset': 'earliest', | |
| 'enable.auto.commit': False, | |
| 'default.topic.config': { | |
| 'auto.offset.reset': 'earliest', | |
| 'enable.auto.commit': False, | |
| }, | |
| 'debug': 'cgrp,fetch', | |
| } | |
| ======================= | |
| %7|1649256452.269|MEMBERID|rdkafka#consumer-1| [thrd:app]: Group "group_id_BBB": updating member id "(not-set)" -> "" | |
| %7|1649256452.269|CGRPSTATE|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB" changed state init -> query-coord (join-state init) | |
| %7|1649256452.269|INIT|rdkafka#consumer-1| [thrd:app]: librdkafka v1.8.2 (0x10802ff) rdkafka#consumer-1 initialized (builtin.features gzip,snappy,ssl,sasl,regex,lz4,sasl_gssapi,sasl_plain,sasl_scram,plugins,zstd,sasl_oauthbearer, CC CXX PKGCONFIG OSXLD LIBDL PLUGINS ZLIB SSL SASL_CYRUS ZSTD HDRHISTOGRAM LZ4_EXT SYSLOG SNAPPY SOCKEM SASL_SCRAM SASL_OAUTHBEARER CRC32C_HW, debug 0x500) | |
| %7|1649256452.269|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": no broker available for coordinator query: intervaled in state query-coord | |
| %7|1649256452.269|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB" received op SUBSCRIBE in state query-coord (join-state init) | |
| %7|1649256452.269|SUBSCRIBE|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": subscribe to new subscription of 1 topics (join-state init) | |
| %7|1649256452.269|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": no broker available for coordinator query: intervaled in state query-coord | |
| %7|1649256452.319|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: 10.6.96.47:9092/bootstrap: Group "group_id_BBB": querying for coordinator: intervaled in state query-coord | |
| %7|1649256452.319|CGRPSTATE|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB" changed state query-coord -> wait-coord (join-state init) | |
| %7|1649256452.366|CGRPCOORD|rdkafka#consumer-1| [thrd:main]: 10.6.96.47:9092/0: Group "group_id_BBB" coordinator is 10.6.96.47:9092 id 0 | |
| %7|1649256452.366|CGRPCOORD|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB" changing coordinator -1 -> 0 | |
| %7|1649256452.366|COORDSET|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB" coordinator set to broker 10.6.96.47:9092/0 | |
| %7|1649256452.366|CGRPSTATE|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB" changed state wait-coord -> wait-broker-transport (join-state init) | |
| %7|1649256452.366|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: 10.6.96.47:9092/0: Group "group_id_BBB": querying for coordinator: intervaled in state wait-broker-transport | |
| %7|1649256452.390|CGRPCOORD|rdkafka#consumer-1| [thrd:main]: 10.6.96.47:9092/0: Group "group_id_BBB" coordinator is 10.6.96.47:9092 id 0 | |
| %7|1649256452.414|CGRPSTATE|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB" changed state wait-broker-transport -> up (join-state init) | |
| %7|1649256452.414|JOIN|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": join with 0 subscribed topic(s) | |
| %7|1649256452.414|CGRPMETADATA|rdkafka#consumer-1| [thrd:main]: consumer join: metadata for subscription only available for 0/1 topics (-1ms old) | |
| %7|1649256452.414|JOIN|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": postponing join until up-to-date metadata is available | |
| %7|1649256452.414|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB" changed join state init -> wait-metadata (state up) | |
| %7|1649256452.414|DUMP|rdkafka#consumer-1| [thrd:main]: Assignment dump (started_cnt=0, wait_stop_cnt=0) | |
| %7|1649256452.414|DUMP_ALL|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649256452.414|DUMP_PND|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649256452.414|DUMP_QRY|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649256452.414|DUMP_REM|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649256452.414|ASSIGNDONE|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": assignment operations done in join-state wait-metadata (rebalance rejoin=false) | |
| %7|1649256452.438|SUBSCRIPTION|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": effective subscription list changed from 0 to 1 topic(s): | |
| %7|1649256452.438|SUBSCRIPTION|rdkafka#consumer-1| [thrd:main]: Topic py_kafka_6 with 1 partition(s) | |
| %7|1649256452.438|REJOIN|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": subscription updated from metadata change: rejoining group in state wait-metadata | |
| %7|1649256452.438|GRPLEADER|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": resetting group leader info: group (re)join | |
| %7|1649256452.438|REJOIN|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB" (re)joining in join-state wait-metadata with 0 assigned partition(s): Metadata for subscribed topic(s) has changed | |
| %7|1649256452.438|REBALANCE|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB" initiating rebalance (NONE) in state up (join-state wait-metadata) with 0 assigned partition(s): Metadata for subscribed topic(s) has changed | |
| %7|1649256452.438|REJOIN|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": Rejoining group without an assignment: Metadata for subscribed topic(s) has changed | |
| %7|1649256452.438|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB" changed join state wait-metadata -> init (state up) | |
| %7|1649256452.438|JOIN|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": join with 1 subscribed topic(s) | |
| %7|1649256452.438|CGRPMETADATA|rdkafka#consumer-1| [thrd:main]: consumer join: metadata for subscription is up to date (0ms old) | |
| %7|1649256452.438|JOIN|rdkafka#consumer-1| [thrd:main]: 10.6.96.47:9092/0: Joining group "group_id_BBB" with 1 subscribed topic(s) and member id "" | |
| %7|1649256452.438|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB" changed join state init -> wait-join (state up) | |
| %7|1649256452.462|JOINGROUP|rdkafka#consumer-1| [thrd:main]: JoinGroup response: GenerationId -1, Protocol , LeaderId , my MemberId rdkafka-c7d97bd1-ed98-487b-b6dd-b6abf15f8e6a, member metadata count 0: Broker: Group member needs a valid member ID | |
| %7|1649256452.462|MEMBERID|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": updating member id "" -> "rdkafka-c7d97bd1-ed98-487b-b6dd-b6abf15f8e6a" | |
| %7|1649256452.462|REJOIN|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": Rejoining group without an assignment: JoinGroup error: Broker: Group member needs a valid member ID | |
| %7|1649256452.462|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB" changed join state wait-join -> init (state up) | |
| %7|1649256452.462|JOIN|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": join with 1 subscribed topic(s) | |
| %7|1649256452.462|CGRPMETADATA|rdkafka#consumer-1| [thrd:main]: consumer join: metadata for subscription is up to date (23ms old) | |
| %7|1649256452.462|JOIN|rdkafka#consumer-1| [thrd:main]: 10.6.96.47:9092/0: Joining group "group_id_BBB" with 1 subscribed topic(s) and member id "rdkafka-c7d97bd1-ed98-487b-b6dd-b6abf15f8e6a" | |
| %7|1649256452.462|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB" changed join state init -> wait-join (state up) | |
| %7|1649256452.487|JOINGROUP|rdkafka#consumer-1| [thrd:main]: JoinGroup response: GenerationId 3, Protocol range, LeaderId rdkafka-c7d97bd1-ed98-487b-b6dd-b6abf15f8e6a (me), my MemberId rdkafka-c7d97bd1-ed98-487b-b6dd-b6abf15f8e6a, member metadata count 1: (no error) | |
| %7|1649256452.487|JOINGROUP|rdkafka#consumer-1| [thrd:main]: I am elected leader for group "group_id_BBB" with 1 member(s) | |
| %7|1649256452.487|GRPLEADER|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": resetting group leader info: JoinGroup response clean-up | |
| %7|1649256452.487|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB" changed join state wait-join -> wait-metadata (state up) | |
| %7|1649256452.510|ASSIGN|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB" running range assignor for 1 member(s) and 1 eligible subscribed topic(s): | |
| %7|1649256452.510|ASSIGN|rdkafka#consumer-1| [thrd:main]: Member "rdkafka-c7d97bd1-ed98-487b-b6dd-b6abf15f8e6a" (me) with 0 owned partition(s) and 1 subscribed topic(s): | |
| %7|1649256452.510|ASSIGN|rdkafka#consumer-1| [thrd:main]: py_kafka_6 [-1] | |
| %7|1649256452.510|ASSIGN|rdkafka#consumer-1| [thrd:main]: range: Topic py_kafka_6 with 1 partition(s) and 1 subscribing member(s) | |
| %7|1649256452.510|ASSIGN|rdkafka#consumer-1| [thrd:main]: range: Member "rdkafka-c7d97bd1-ed98-487b-b6dd-b6abf15f8e6a": assigned topic py_kafka_6 partitions 0..0 | |
| %7|1649256452.510|ASSIGN|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB" range assignment for 1 member(s) finished in 0.044ms: | |
| %7|1649256452.510|ASSIGN|rdkafka#consumer-1| [thrd:main]: Member "rdkafka-c7d97bd1-ed98-487b-b6dd-b6abf15f8e6a" (me) assigned 1 partition(s): | |
| %7|1649256452.510|ASSIGN|rdkafka#consumer-1| [thrd:main]: py_kafka_6 [0] | |
| %7|1649256452.510|ASSIGNOR|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": "range" assignor run for 1 member(s) | |
| %7|1649256452.510|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB" changed join state wait-metadata -> wait-sync (state up) | |
| %7|1649256452.534|SYNCGROUP|rdkafka#consumer-1| [thrd:main]: SyncGroup response: Success (30 bytes of MemberState data) | |
| %7|1649256452.534|ASSIGNMENT|rdkafka#consumer-1| [thrd:main]: List with 1 partition(s): | |
| %7|1649256452.534|ASSIGNMENT|rdkafka#consumer-1| [thrd:main]: py_kafka_6 [0] offset INVALID | |
| %7|1649256452.534|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB" changed join state wait-sync -> wait-assign-call (state up) | |
| %7|1649256452.534|ASSIGN|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": delegating assign of 1 partition(s) to application on queue rd_kafka_cgrp_new: new assignment | |
| %7|1649256452.534|ASSIGNMENT|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": setting group assignment to 1 partition(s) | |
| %7|1649256452.534|GRPASSIGNMENT|rdkafka#consumer-1| [thrd:main]: List with 1 partition(s): | |
| %7|1649256452.534|GRPASSIGNMENT|rdkafka#consumer-1| [thrd:main]: py_kafka_6 [0] offset INVALID | |
| %7|1649256452.534|HEARTBEAT|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/0: Heartbeat for group "group_id_BBB" generation id 3 | |
| %7|1649256452.534|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB" received op GET_REBALANCE_PROTOCOL in state up (join-state wait-assign-call) | |
| %7|1649256452.534|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB" received op ASSIGN in state up (join-state wait-assign-call) | |
| %7|1649256452.534|ASSIGN|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": new assignment of 1 partition(s) in join-state wait-assign-call | |
| %7|1649256452.534|CLEARASSIGN|rdkafka#consumer-1| [thrd:main]: No current assignment to clear | |
| %7|1649256452.534|ASSIGNMENT|rdkafka#consumer-1| [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 | |
| %7|1649256452.534|PAUSE|rdkafka#consumer-1| [thrd:main]: Resuming fetchers for 1 assigned partition(s): assign called | |
| %7|1649256452.534|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB" changed join state wait-assign-call -> steady (state up) | |
| %7|1649256452.534|DUMP|rdkafka#consumer-1| [thrd:main]: Assignment dump (started_cnt=0, wait_stop_cnt=0) | |
| %7|1649256452.534|DUMP_ALL|rdkafka#consumer-1| [thrd:main]: List with 1 partition(s): | |
| %7|1649256452.534|DUMP_ALL|rdkafka#consumer-1| [thrd:main]: py_kafka_6 [0] offset STORED | |
| %7|1649256452.534|DUMP_PND|rdkafka#consumer-1| [thrd:main]: List with 1 partition(s): | |
| %7|1649256452.534|DUMP_PND|rdkafka#consumer-1| [thrd:main]: py_kafka_6 [0] offset STORED | |
| %7|1649256452.534|DUMP_QRY|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649256452.534|DUMP_REM|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649256452.534|SRVPEND|rdkafka#consumer-1| [thrd:main]: Querying committed offset for pending assigned partition py_kafka_6 [0] | |
| %7|1649256452.534|OFFSETFETCH|rdkafka#consumer-1| [thrd:main]: Fetching committed offsets for 1 pending partition(s) in assignment | |
| %7|1649256452.534|OFFSET|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/0: Fetch committed offsets for 1/1 partition(s) | |
| %7|1649256452.534|ASSIGNMENT|rdkafka#consumer-1| [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 | |
| %7|1649256452.580|OFFSETFETCH|rdkafka#consumer-1| [thrd:main]: Adding py_kafka_6 [0] back to pending list with offset INVALID | |
| %7|1649256452.580|DUMP|rdkafka#consumer-1| [thrd:main]: Assignment dump (started_cnt=0, wait_stop_cnt=0) | |
| %7|1649256452.580|DUMP_ALL|rdkafka#consumer-1| [thrd:main]: List with 1 partition(s): | |
| %7|1649256452.580|DUMP_ALL|rdkafka#consumer-1| [thrd:main]: py_kafka_6 [0] offset STORED | |
| %7|1649256452.580|DUMP_PND|rdkafka#consumer-1| [thrd:main]: List with 1 partition(s): | |
| %7|1649256452.580|DUMP_PND|rdkafka#consumer-1| [thrd:main]: py_kafka_6 [0] offset INVALID | |
| %7|1649256452.580|DUMP_QRY|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649256452.580|DUMP_REM|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649256452.580|SRVPEND|rdkafka#consumer-1| [thrd:main]: Starting pending assigned partition py_kafka_6 [0] at offset INVALID | |
| %7|1649256452.580|ASSIGNDONE|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": assignment operations done in join-state steady (rebalance rejoin=false) | |
| %7|1649256452.580|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB" received op PARTITION_JOIN in state up (join-state steady) for py_kafka_6 [0] | |
| %7|1649256452.580|PARTADD|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": add py_kafka_6 [0] | |
| %7|1649256452.704|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Topic py_kafka_6 [0] in state active at offset 0 (0/100000 msgs, 0/65536 kb queued, opv 4) is fetchable | |
| %7|1649256452.704|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch topic py_kafka_6 [0] at offset 0 (v4) | |
| %7|1649256452.704|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch 1/1/1 toppar(s) | |
| %7|1649256452.734|CONSUME|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Enqueue 10 message(s) (40 bytes, 10 ops) on py_kafka_6 [0] fetch queue (qlen 0, v4, last_offset 9, 0 ctrl msgs, uncompressed) | |
| %7|1649256452.734|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch topic py_kafka_6 [0] at offset 10 (v4) | |
| %7|1649256452.734|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch 1/1/1 toppar(s) | |
| %7|1649256452.734|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB" received op OFFSET_COMMIT in state up (join-state steady) | |
| %7|1649256452.734|OFFSET|rdkafka#consumer-1| [thrd:main]: Topic py_kafka_6 [0]: stored offset 10, committed offset -1001: setting stored offset 10 for commit | |
| %7|1649256452.734|COMMIT|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/0: Committing offsets for 1 partition(s) with generation-id 3 in join-state steady: manual | |
| %7|1649256452.759|COMMIT|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/0: OffsetCommit for 1 partition(s) in join-state steady: manual: returned: Success | |
| %7|1649256452.759|DUMP|rdkafka#consumer-1| [thrd:main]: Assignment dump (started_cnt=1, wait_stop_cnt=0) | |
| %7|1649256452.759|DUMP_ALL|rdkafka#consumer-1| [thrd:main]: List with 1 partition(s): | |
| %7|1649256452.759|DUMP_ALL|rdkafka#consumer-1| [thrd:main]: py_kafka_6 [0] offset STORED | |
| %7|1649256452.759|DUMP_PND|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649256452.759|DUMP_QRY|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649256452.759|DUMP_REM|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649256452.759|ASSIGNDONE|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": assignment operations done in join-state steady (rebalance rejoin=false) | |
| %7|1649256452.759|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB" received op OFFSET_FETCH in state up (join-state steady) | |
| %7|1649256452.759|OFFSET|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/0: Fetch committed offsets for 1/1 partition(s) | |
| %7|1649256452.783|OFFSET|rdkafka#consumer-1| [thrd:main]: Topic py_kafka_6 [0]: setting default offset INVALID | |
| ========================================== | |
| NOTE: Here I got 10 messages from topic | |
| ========================================== | |
| %7|1649256452.783|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB" received op TERMINATE in state up (join-state steady) | |
| %7|1649256452.783|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Terminating group "group_id_BBB" in state up with 1 partition(s) | |
| %7|1649256452.783|UNSUBSCRIBE|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": unsubscribe from current subscription of size 1 (leave group=true, has joined=true, rdkafka-c7d97bd1-ed98-487b-b6dd-b6abf15f8e6a, join-state steady) | |
| %7|1649256452.783|SUBSCRIPTION|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": clearing subscribed topics list (1) | |
| %7|1649256452.783|SUBSCRIPTION|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": effective subscription list changed from 1 to 0 topic(s): | |
| %7|1649256452.783|GRPLEADER|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": resetting group leader info: unsubscribe | |
| %7|1649256452.783|REBALANCE|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB" initiating rebalance (EAGER) in state up (join-state steady) with 1 assigned partition(s): unsubscribe | |
| %7|1649256452.783|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB" changed join state steady -> wait-unassign-call (state up) | |
| %7|1649256452.783|ASSIGN|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": delegating revoke of 1 partition(s) to application on queue rd_kafka_consumer_close: unsubscribe | |
| %7|1649256452.783|PAUSE|rdkafka#consumer-1| [thrd:main]: Pausing fetchers for 1 assigned partition(s): rebalance | |
| %7|1649256452.783|ASSIGNMENT|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": clearing group assignment | |
| %7|1649256452.783|DUMP|rdkafka#consumer-1| [thrd:main]: Assignment dump (started_cnt=1, wait_stop_cnt=0) | |
| %7|1649256452.783|DUMP_ALL|rdkafka#consumer-1| [thrd:main]: List with 1 partition(s): | |
| %7|1649256452.783|DUMP_ALL|rdkafka#consumer-1| [thrd:main]: py_kafka_6 [0] offset STORED | |
| %7|1649256452.783|DUMP_PND|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649256452.783|DUMP_QRY|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649256452.783|DUMP_REM|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649256452.783|ASSIGNDONE|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": assignment operations done in join-state wait-unassign-call (rebalance rejoin=false) | |
| %7|1649256452.783|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": waiting for assign call, 1 toppar(s), 0 commit(s) (state up, join-state wait-unassign-call) before terminating | |
| %7|1649256452.783|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": waiting for assign call, 1 toppar(s), 0 commit(s) (state up, join-state wait-unassign-call) before terminating | |
| %7|1649256452.783|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB" received op GET_REBALANCE_PROTOCOL in state up (join-state wait-unassign-call) | |
| %7|1649256452.783|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": waiting for assign call, 1 toppar(s), 0 commit(s) (state up, join-state wait-unassign-call) before terminating | |
| %7|1649256452.783|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB" received op ASSIGN in state up (join-state wait-unassign-call) | |
| %7|1649256452.783|ASSIGN|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": Consumer is terminating: treating assign as unassign | |
| %7|1649256452.783|CLEARASSIGN|rdkafka#consumer-1| [thrd:main]: Clearing current assignment of 1 partition(s) | |
| %7|1649256452.783|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB" changed join state wait-unassign-call -> wait-unassign-to-complete (state up) | |
| %7|1649256452.783|DUMP|rdkafka#consumer-1| [thrd:main]: Assignment dump (started_cnt=1, wait_stop_cnt=0) | |
| %7|1649256452.783|DUMP_ALL|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649256452.783|DUMP_PND|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649256452.783|DUMP_QRY|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649256452.783|DUMP_REM|rdkafka#consumer-1| [thrd:main]: List with 1 partition(s): | |
| %7|1649256452.783|DUMP_REM|rdkafka#consumer-1| [thrd:main]: py_kafka_6 [0] offset STORED | |
| %7|1649256452.783|REMOVE|rdkafka#consumer-1| [thrd:main]: Removing py_kafka_6 [0] from assignment (started=true, pending=false, queried=false, stored offset=10) | |
| %7|1649256452.783|REMOVE|rdkafka#consumer-1| [thrd:main]: Served 1 removed partition(s), with 1 offset(s) to commit | |
| %7|1649256452.783|ASSIGNMENT|rdkafka#consumer-1| [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 | |
| %7|1649256452.783|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": waiting for 1 toppar(s), assignment in progress, 0 commit(s) (state up, join-state wait-unassign-to-complete) before terminating | |
| %7|1649256452.783|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": waiting for 1 toppar(s), assignment in progress, 0 commit(s) (state up, join-state wait-unassign-to-complete) before terminating | |
| %7|1649256452.783|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB" received op PARTITION_LEAVE in state up (join-state wait-unassign-to-complete) for py_kafka_6 [0] | |
| %7|1649256452.783|PARTDEL|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": delete py_kafka_6 [0] | |
| %7|1649256452.783|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": waiting for 0 toppar(s), assignment in progress, 0 commit(s) (state up, join-state wait-unassign-to-complete) before terminating | |
| %7|1649256452.783|STOPSERVE|rdkafka#consumer-1| [thrd:main]: All partitions awaiting stop are now stopped: serving assignment | |
| %7|1649256452.783|DUMP|rdkafka#consumer-1| [thrd:main]: Assignment dump (started_cnt=0, wait_stop_cnt=0) | |
| %7|1649256452.783|DUMP_ALL|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649256452.784|DUMP_PND|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649256452.784|DUMP_QRY|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649256452.784|DUMP_REM|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649256452.784|ASSIGNDONE|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": assignment operations done in join-state wait-unassign-to-complete (rebalance rejoin=false) | |
| %7|1649256452.784|UNASSIGN|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": unassign done in state up (join-state wait-unassign-to-complete) | |
| %7|1649256452.784|MEMBERID|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": updating member id "rdkafka-c7d97bd1-ed98-487b-b6dd-b6abf15f8e6a" -> "" | |
| %7|1649256452.784|LEAVE|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": leave (in state up) | |
| %7|1649256452.784|NOREJOIN|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": Not rejoining group without an assignment: Unassignment done: no subscribed topics | |
| %7|1649256452.784|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB" changed join state wait-unassign-to-complete -> init (state up) | |
| %7|1649256452.784|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": waiting for 0 toppar(s), 0 commit(s), wait-leave, (state up, join-state init) before terminating | |
| %7|1649256452.807|LEAVEGROUP|rdkafka#consumer-1| [thrd:main]: LeaveGroup response received in state up | |
| %7|1649256452.807|CGRPSTATE|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB" changed state up -> term (join-state init) | |
| %7|1649256452.807|ASSIGNMENT|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB": clearing group assignment | |
| %7|1649256452.807|COORDCLEAR|rdkafka#consumer-1| [thrd:main]: Group "group_id_BBB" broker 10.6.96.47:9092/0 is no longer coordinator | |
| %7|1649256452.807|DESTROY|rdkafka#consumer-1| [thrd:app]: Terminating instance (destroy flags none (0x0)) | |
| %7|1649256452.807|DESTROY|rdkafka#consumer-1| [thrd:main]: Destroy internal | |
| %7|1649256452.807|DESTROY|rdkafka#consumer-1| [thrd:main]: Removing all topics | |
| %7|1649256452.807|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Topic py_kafka_6 [0] in state stopped at offset 10 (0/100000 msgs, 0/65536 kb queued, opv 4) is not fetchable: forced removal | |
| %7|1649256452.808|MEMBERID|rdkafka#consumer-1| [thrd:app]: Group "group_id_BBB": updating member id "" -> "(not-set)" | |
| ========================================== | |
| Program autoclosed on getting 10 messages | |
| ========================================== |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| ======================== | |
| CURRENT CONFIG: | |
| config = { | |
| 'bootstrap.servers': brokers[0], | |
| 'group.id': 'group_id_CCC', | |
| 'auto.offset.reset': 'earliest', | |
| 'enable.auto.commit': False, | |
| 'debug': 'all', | |
| } | |
| LOOP WORKED FOR LIKE 20 SEC AND I CLOSED PROGRAM | |
| ======================== | |
| %7|1649257442.631|MEMBERID|rdkafka#consumer-1| [thrd:app]: Group "group_id_CCC": updating member id "(not-set)" -> "" | |
| %7|1649257442.631|WAKEUPFD|rdkafka#consumer-1| [thrd:app]: GroupCoordinator: Enabled low-latency ops queue wake-ups | |
| %7|1649257442.631|BROKER|rdkafka#consumer-1| [thrd:app]: GroupCoordinator: Added new broker with NodeId -1 | |
| %7|1649257442.631|WAKEUPFD|rdkafka#consumer-1| [thrd:app]: 10.6.96.47:9092/bootstrap: Enabled low-latency ops queue wake-ups | |
| %7|1649257442.631|BRKMAIN|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Enter main broker thread | |
| %7|1649257442.631|BROKER|rdkafka#consumer-1| [thrd:app]: 10.6.96.47:9092/bootstrap: Added new broker with NodeId -1 | |
| %7|1649257442.631|CGRPSTATE|rdkafka#consumer-1| [thrd:main]: Group "group_id_CCC" changed state init -> query-coord (join-state init) | |
| %7|1649257442.631|INIT|rdkafka#consumer-1| [thrd:app]: librdkafka v1.8.2 (0x10802ff) rdkafka#consumer-1 initialized (builtin.features gzip,snappy,ssl,sasl,regex,lz4,sasl_gssapi,sasl_plain,sasl_scram,plugins,zstd,sasl_oauthbearer, CC CXX PKGCONFIG OSXLD LIBDL PLUGINS ZLIB SSL SASL_CYRUS ZSTD HDRHISTOGRAM LZ4_EXT SYSLOG SNAPPY SOCKEM SASL_SCRAM SASL_OAUTHBEARER CRC32C_HW, debug 0xfffff) | |
| %7|1649257442.631|BROADCAST|rdkafka#consumer-1| [thrd:main]: Broadcasting state change | |
| %7|1649257442.631|BRKMAIN|rdkafka#consumer-1| [thrd::0/internal]: :0/internal: Enter main broker thread | |
| %7|1649257442.631|CONNECT|rdkafka#consumer-1| [thrd:main]: 10.6.96.47:9092/bootstrap: Selected for cluster connection: coordinator query (broker has 0 connection attempt(s)) | |
| %7|1649257442.631|BRKMAIN|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: Enter main broker thread | |
| %7|1649257442.631|CONNECT|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: Received CONNECT op | |
| %7|1649257442.632|STATE|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: Broker changed state INIT -> TRY_CONNECT | |
| %7|1649257442.632|BROADCAST|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: Broadcasting state change | |
| %7|1649257442.632|CONNECT|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: broker in state TRY_CONNECT connecting | |
| %7|1649257442.632|STATE|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: Broker changed state TRY_CONNECT -> CONNECT | |
| %7|1649257442.632|BROADCAST|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: Broadcasting state change | |
| %7|1649257442.631|CONF|rdkafka#consumer-1| [thrd:app]: Client configuration: | |
| %7|1649257442.632|CONF|rdkafka#consumer-1| [thrd:app]: client.software.name = confluent-kafka-python | |
| %7|1649257442.632|CONF|rdkafka#consumer-1| [thrd:app]: client.software.version = 1.8.2-rdkafka-1.8.2 | |
| %7|1649257442.632|CONF|rdkafka#consumer-1| [thrd:app]: metadata.broker.list = 10.6.96.47:9092 | |
| %7|1649257442.631|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "group_id_CCC": no broker available for coordinator query: intervaled in state query-coord | |
| %7|1649257442.632|CONF|rdkafka#consumer-1| [thrd:app]: debug = generic,broker,topic,metadata,feature,queue,msg,protocol,cgrp,security,fetch,interceptor,plugin,consumer,admin,eos,mock,assignor,conf,all | |
| %7|1649257442.632|CONF|rdkafka#consumer-1| [thrd:app]: error_cb = 0x100b35810 | |
| %7|1649257442.632|CONF|rdkafka#consumer-1| [thrd:app]: opaque = 0x100fa2fb0 | |
| %7|1649257442.632|CONF|rdkafka#consumer-1| [thrd:app]: default_topic_conf = 0x7fabf820eb20 | |
| %7|1649257442.632|CONF|rdkafka#consumer-1| [thrd:app]: ssl.ca.location = probe | |
| %7|1649257442.632|CONF|rdkafka#consumer-1| [thrd:app]: group.id = group_id_CCC | |
| %7|1649257442.632|CONF|rdkafka#consumer-1| [thrd:app]: enable.auto.commit = true | |
| %7|1649257442.632|CONF|rdkafka#consumer-1| [thrd:app]: rebalance_cb = 0x100b31e90 | |
| %7|1649257442.632|CONF|rdkafka#consumer-1| [thrd:app]: offset_commit_cb = 0x100b31d20 | |
| %7|1649257442.632|CONF|rdkafka#consumer-1| [thrd:app]: Default topic configuration: | |
| %7|1649257442.632|CONF|rdkafka#consumer-1| [thrd:app]: auto.offset.reset = largest | |
| %7|1649257442.632|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "group_id_CCC" received op SUBSCRIBE in state query-coord (join-state init) | |
| %7|1649257442.632|SUBSCRIBE|rdkafka#consumer-1| [thrd:main]: Group "group_id_CCC": subscribe to new subscription of 1 topics (join-state init) | |
| %7|1649257442.632|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query | |
| %7|1649257442.632|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "group_id_CCC": no broker available for coordinator query: intervaled in state query-coord | |
| %7|1649257442.633|CONNECT|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: Connecting to ipv4#10.6.96.47:9092 (plaintext) with socket 9 | |
| %7|1649257442.658|CONNECT|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: Connected to ipv4#10.6.96.47:9092 | |
| %7|1649257442.658|CONNECTED|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: Connected (#1) | |
| %7|1649257442.658|FEATURE|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: Updated enabled protocol features +ApiVersion to ApiVersion | |
| %7|1649257442.658|STATE|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: Broker changed state CONNECT -> APIVERSION_QUERY | |
| %7|1649257442.658|BROADCAST|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: Broadcasting state change | |
| %7|1649257442.658|SEND|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: Sent ApiVersionRequest (v3, 66 bytes @ 0, CorrId 1) | |
| %7|1649257442.683|RECV|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: Received ApiVersionResponse (v3, 410 bytes, CorrId 1, rtt 25.27ms) | |
| %7|1649257442.684|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: Broker API support: | |
| %7|1649257442.684|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: ApiKey Produce (0) Versions 0..9 | |
| %7|1649257442.684|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: ApiKey Fetch (1) Versions 0..12 | |
| %7|1649257442.684|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: ApiKey ListOffsets (2) Versions 0..6 | |
| %7|1649257442.684|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: ApiKey Metadata (3) Versions 0..11 | |
| %7|1649257442.684|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: ApiKey LeaderAndIsr (4) Versions 0..5 | |
| %7|1649257442.684|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: ApiKey StopReplica (5) Versions 0..3 | |
| %7|1649257442.684|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: ApiKey UpdateMetadata (6) Versions 0..7 | |
| %7|1649257442.684|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: ApiKey ControlledShutdown (7) Versions 0..3 | |
| %7|1649257442.684|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: ApiKey OffsetCommit (8) Versions 0..8 | |
| %7|1649257442.684|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: ApiKey OffsetFetch (9) Versions 0..7 | |
| %7|1649257442.684|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: ApiKey FindCoordinator (10) Versions 0..3 | |
| %7|1649257442.684|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: ApiKey JoinGroup (11) Versions 0..7 | |
| %7|1649257442.684|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: ApiKey Heartbeat (12) Versions 0..4 | |
| %7|1649257442.685|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: ApiKey LeaveGroup (13) Versions 0..4 | |
| %7|1649257442.685|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: ApiKey SyncGroup (14) Versions 0..5 | |
| %7|1649257442.685|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: ApiKey DescribeGroups (15) Versions 0..5 | |
| %7|1649257442.685|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: ApiKey ListGroups (16) Versions 0..4 | |
| %7|1649257442.685|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: ApiKey SaslHandshake (17) Versions 0..1 | |
| %7|1649257442.685|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: ApiKey ApiVersion (18) Versions 0..3 | |
| %7|1649257442.685|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: ApiKey CreateTopics (19) Versions 0..7 | |
| %7|1649257442.685|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: ApiKey DeleteTopics (20) Versions 0..6 | |
| %7|1649257442.685|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: ApiKey DeleteRecords (21) Versions 0..2 | |
| %7|1649257442.685|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: ApiKey InitProducerId (22) Versions 0..4 | |
| %7|1649257442.685|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: ApiKey OffsetForLeaderEpoch (23) Versions 0..4 | |
| %7|1649257442.685|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: ApiKey AddPartitionsToTxn (24) Versions 0..3 | |
| %7|1649257442.685|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: ApiKey AddOffsetsToTxn (25) Versions 0..3 | |
| %7|1649257442.685|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: ApiKey EndTxn (26) Versions 0..3 | |
| %7|1649257442.685|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: ApiKey WriteTxnMarkers (27) Versions 0..1 | |
| %7|1649257442.685|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: ApiKey TxnOffsetCommit (28) Versions 0..3 | |
| %7|1649257442.685|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: ApiKey DescribeAcls (29) Versions 0..2 | |
| %7|1649257442.685|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: ApiKey CreateAcls (30) Versions 0..2 | |
| %7|1649257442.685|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: ApiKey DeleteAcls (31) Versions 0..2 | |
| %7|1649257442.685|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: ApiKey DescribeConfigs (32) Versions 0..4 | |
| %7|1649257442.685|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: ApiKey AlterConfigs (33) Versions 0..2 | |
| %7|1649257442.685|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: ApiKey AlterReplicaLogDirs (34) Versions 0..2 | |
| %7|1649257442.685|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: ApiKey DescribeLogDirs (35) Versions 0..2 | |
| %7|1649257442.685|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: ApiKey SaslAuthenticate (36) Versions 0..2 | |
| %7|1649257442.685|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: ApiKey CreatePartitions (37) Versions 0..3 | |
| %7|1649257442.685|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: ApiKey CreateDelegationToken (38) Versions 0..2 | |
| %7|1649257442.685|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: ApiKey RenewDelegationToken (39) Versions 0..2 | |
| %7|1649257442.685|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: ApiKey ExpireDelegationToken (40) Versions 0..2 | |
| %7|1649257442.685|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: ApiKey DescribeDelegationToken (41) Versions 0..2 | |
| %7|1649257442.685|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: ApiKey DeleteGroups (42) Versions 0..2 | |
| %7|1649257442.685|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: ApiKey ElectLeadersRequest (43) Versions 0..2 | |
| %7|1649257442.685|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: ApiKey IncrementalAlterConfigsRequest (44) Versions 0..1 | |
| %7|1649257442.685|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: ApiKey AlterPartitionReassignmentsRequest (45) Versions 0..0 | |
| %7|1649257442.685|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: ApiKey ListPartitionReassignmentsRequest (46) Versions 0..0 | |
| %7|1649257442.685|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: ApiKey OffsetDeleteRequest (47) Versions 0..0 | |
| %7|1649257442.685|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: ApiKey DescribeClientQuotasRequest (48) Versions 0..1 | |
| %7|1649257442.685|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: ApiKey AlterClientQuotasRequest (49) Versions 0..1 | |
| %7|1649257442.685|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: ApiKey DescribeUserScramCredentialsRequest (50) Versions 0..0 | |
| %7|1649257442.685|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: ApiKey AlterUserScramCredentialsRequest (51) Versions 0..0 | |
| %7|1649257442.685|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: ApiKey AlterIsrRequest (56) Versions 0..0 | |
| %7|1649257442.685|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: ApiKey UpdateFeaturesRequest (57) Versions 0..0 | |
| %7|1649257442.685|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: ApiKey Unknown-60? (60) Versions 0..0 | |
| %7|1649257442.685|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: ApiKey Unknown-61? (61) Versions 0..0 | |
| %7|1649257442.685|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: Feature MsgVer1: Produce (2..2) supported by broker | |
| %7|1649257442.685|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: Feature MsgVer1: Fetch (2..2) supported by broker | |
| %7|1649257442.685|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: Enabling feature MsgVer1 | |
| %7|1649257442.685|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: Feature MsgVer2: Produce (3..3) supported by broker | |
| %7|1649257442.685|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: Feature MsgVer2: Fetch (4..4) supported by broker | |
| %7|1649257442.685|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: Enabling feature MsgVer2 | |
| %7|1649257442.685|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: Feature ApiVersion: ApiVersion (0..0) supported by broker | |
| %7|1649257442.685|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: Enabling feature ApiVersion | |
| %7|1649257442.685|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: Feature BrokerGroupCoordinator: FindCoordinator (0..0) supported by broker | |
| %7|1649257442.685|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: Enabling feature BrokerGroupCoordinator | |
| %7|1649257442.685|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: Feature BrokerBalancedConsumer: FindCoordinator (0..0) supported by broker | |
| %7|1649257442.685|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: Feature BrokerBalancedConsumer: OffsetCommit (1..2) supported by broker | |
| %7|1649257442.685|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: Feature BrokerBalancedConsumer: OffsetFetch (1..1) supported by broker | |
| %7|1649257442.685|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: Feature BrokerBalancedConsumer: JoinGroup (0..0) supported by broker | |
| %7|1649257442.685|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: Feature BrokerBalancedConsumer: SyncGroup (0..0) supported by broker | |
| %7|1649257442.685|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: Feature BrokerBalancedConsumer: Heartbeat (0..0) supported by broker | |
| %7|1649257442.685|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: Feature BrokerBalancedConsumer: LeaveGroup (0..0) supported by broker | |
| %7|1649257442.685|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: Enabling feature BrokerBalancedConsumer | |
| %7|1649257442.685|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: Feature ThrottleTime: Produce (1..2) supported by broker | |
| %7|1649257442.685|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: Feature ThrottleTime: Fetch (1..2) supported by broker | |
| %7|1649257442.685|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: Enabling feature ThrottleTime | |
| %7|1649257442.685|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: Feature Sasl: JoinGroup (0..0) supported by broker | |
| %7|1649257442.685|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: Enabling feature Sasl | |
| %7|1649257442.685|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: Feature SaslHandshake: SaslHandshake (0..0) supported by broker | |
| %7|1649257442.685|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: Enabling feature SaslHandshake | |
| %7|1649257442.685|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: Feature LZ4: FindCoordinator (0..0) supported by broker | |
| %7|1649257442.685|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: Enabling feature LZ4 | |
| %7|1649257442.685|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: Feature OffsetTime: ListOffsets (1..1) supported by broker | |
| %7|1649257442.685|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: Enabling feature OffsetTime | |
| %7|1649257442.685|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: Feature IdempotentProducer: InitProducerId (0..0) supported by broker | |
| %7|1649257442.685|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: Enabling feature IdempotentProducer | |
| %7|1649257442.685|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: Feature ZSTD: Produce (7..7) supported by broker | |
| %7|1649257442.685|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: Feature ZSTD: Fetch (10..10) supported by broker | |
| %7|1649257442.685|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: Enabling feature ZSTD | |
| %7|1649257442.685|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: Feature SaslAuthReq: SaslHandshake (1..1) supported by broker | |
| %7|1649257442.685|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: Feature SaslAuthReq: SaslAuthenticate (0..0) supported by broker | |
| %7|1649257442.685|APIVERSION|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: Enabling feature SaslAuthReq | |
| %7|1649257442.685|FEATURE|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: Updated enabled protocol features to MsgVer1,ApiVersion,BrokerBalancedConsumer,ThrottleTime,Sasl,SaslHandshake,BrokerGroupCoordinator,LZ4,OffsetTime,MsgVer2,IdempotentProducer,ZSTD,SaslAuthReq | |
| %7|1649257442.685|STATE|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: Broker changed state APIVERSION_QUERY -> UP | |
| %7|1649257442.685|BROADCAST|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: Broadcasting state change | |
| %7|1649257442.685|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: 10.6.96.47:9092/bootstrap: Group "group_id_CCC": querying for coordinator: intervaled in state query-coord | |
| %7|1649257442.685|METADATA|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: Request metadata for brokers only: connected | |
| %7|1649257442.685|CGRPSTATE|rdkafka#consumer-1| [thrd:main]: Group "group_id_CCC" changed state query-coord -> wait-coord (join-state init) | |
| %7|1649257442.685|BROADCAST|rdkafka#consumer-1| [thrd:main]: Broadcasting state change | |
| %7|1649257442.686|SEND|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: Sent MetadataRequest (v4, 26 bytes @ 0, CorrId 2) | |
| %7|1649257442.686|SEND|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: Sent FindCoordinatorRequest (v2, 36 bytes @ 0, CorrId 3) | |
| %7|1649257442.709|RECV|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: Received MetadataResponse (v4, 62 bytes, CorrId 2, rtt 23.49ms) | |
| %7|1649257442.709|METADATA|rdkafka#consumer-1| [thrd:main]: 10.6.96.47:9092/bootstrap: ===== Received metadata: connected ===== | |
| %7|1649257442.709|METADATA|rdkafka#consumer-1| [thrd:main]: 10.6.96.47:9092/bootstrap: ClusterId: lUrBz8BNRMie_7FYhW4aXQ, ControllerId: 0 | |
| %7|1649257442.709|METADATA|rdkafka#consumer-1| [thrd:main]: 10.6.96.47:9092/bootstrap: 1 brokers, 0 topics | |
| %7|1649257442.709|METADATA|rdkafka#consumer-1| [thrd:main]: 10.6.96.47:9092/bootstrap: Broker #0/1: 10.6.96.47:9092 NodeId 0 | |
| %7|1649257442.709|UPDATE|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/bootstrap: NodeId changed from -1 to 0 | |
| %7|1649257442.709|UPDATE|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Name changed from 10.6.96.47:9092/bootstrap to 10.6.96.47:9092/0 | |
| %7|1649257442.709|LEADER|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Mapped 0 partition(s) to broker | |
| %7|1649257442.709|STATE|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Broker changed state UP -> UPDATE | |
| %7|1649257442.709|BROADCAST|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: Broadcasting state change | |
| %7|1649257442.709|BROADCAST|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: Broadcasting state change | |
| %7|1649257442.709|STATE|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Broker changed state UPDATE -> UP | |
| %7|1649257442.709|BROADCAST|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: Broadcasting state change | |
| %7|1649257442.709|CLUSTERID|rdkafka#consumer-1| [thrd:main]: 10.6.96.47:9092/0: ClusterId update "" -> "lUrBz8BNRMie_7FYhW4aXQ" | |
| %7|1649257442.709|CONTROLLERID|rdkafka#consumer-1| [thrd:main]: 10.6.96.47:9092/0: ControllerId update -1 -> 0 | |
| %7|1649257442.709|BROADCAST|rdkafka#consumer-1| [thrd:main]: Broadcasting state change | |
| %7|1649257442.734|RECV|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Received FindCoordinatorResponse (v2, 32 bytes, CorrId 3, rtt 48.25ms) | |
| %7|1649257442.734|CGRPCOORD|rdkafka#consumer-1| [thrd:main]: 10.6.96.47:9092/0: Group "group_id_CCC" coordinator is 10.6.96.47:9092 id 0 | |
| %7|1649257442.734|CGRPCOORD|rdkafka#consumer-1| [thrd:main]: Group "group_id_CCC" changing coordinator -1 -> 0 | |
| %7|1649257442.734|COORDSET|rdkafka#consumer-1| [thrd:main]: Group "group_id_CCC" coordinator set to broker 10.6.96.47:9092/0 | |
| %7|1649257442.734|CGRPSTATE|rdkafka#consumer-1| [thrd:main]: Group "group_id_CCC" changed state wait-coord -> wait-broker-transport (join-state init) | |
| %7|1649257442.734|BROADCAST|rdkafka#consumer-1| [thrd:main]: Broadcasting state change | |
| %7|1649257442.734|NODENAME|rdkafka#consumer-1| [thrd:main]: GroupCoordinator: Broker nodename changed from "" to "10.6.96.47:9092" | |
| %7|1649257442.734|NODEID|rdkafka#consumer-1| [thrd:main]: GroupCoordinator: Broker nodeid changed from -1 to 0 | |
| %7|1649257442.734|CONNECT|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Received CONNECT op | |
| %7|1649257442.734|STATE|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Broker changed state INIT -> TRY_CONNECT | |
| %7|1649257442.734|BROADCAST|rdkafka#consumer-1| [thrd:GroupCoordinator]: Broadcasting state change | |
| %7|1649257442.734|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: 10.6.96.47:9092/0: Group "group_id_CCC": querying for coordinator: intervaled in state wait-broker-transport | |
| %7|1649257442.734|CONNECT|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: broker in state TRY_CONNECT connecting | |
| %7|1649257442.734|STATE|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Broker changed state TRY_CONNECT -> CONNECT | |
| %7|1649257442.734|BROADCAST|rdkafka#consumer-1| [thrd:GroupCoordinator]: Broadcasting state change | |
| %7|1649257442.734|SEND|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Sent FindCoordinatorRequest (v2, 36 bytes @ 0, CorrId 4) | |
| %7|1649257442.734|CONNECT|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Connecting to ipv4#10.6.96.47:9092 (plaintext) with socket 10 | |
| %7|1649257442.758|CONNECT|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Connected to ipv4#10.6.96.47:9092 | |
| %7|1649257442.758|CONNECTED|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Connected (#1) | |
| %7|1649257442.758|FEATURE|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Updated enabled protocol features +ApiVersion to ApiVersion | |
| %7|1649257442.758|STATE|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Broker changed state CONNECT -> APIVERSION_QUERY | |
| %7|1649257442.758|BROADCAST|rdkafka#consumer-1| [thrd:GroupCoordinator]: Broadcasting state change | |
| %7|1649257442.758|RECV|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Received FindCoordinatorResponse (v2, 32 bytes, CorrId 4, rtt 23.65ms) | |
| %7|1649257442.758|CGRPCOORD|rdkafka#consumer-1| [thrd:main]: 10.6.96.47:9092/0: Group "group_id_CCC" coordinator is 10.6.96.47:9092 id 0 | |
| %7|1649257442.758|SEND|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Sent ApiVersionRequest (v3, 66 bytes @ 0, CorrId 1) | |
| %7|1649257442.783|RECV|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Received ApiVersionResponse (v3, 410 bytes, CorrId 1, rtt 25.50ms) | |
| %7|1649257442.783|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Broker API support: | |
| %7|1649257442.783|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey Produce (0) Versions 0..9 | |
| %7|1649257442.783|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey Fetch (1) Versions 0..12 | |
| %7|1649257442.783|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey ListOffsets (2) Versions 0..6 | |
| %7|1649257442.783|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey Metadata (3) Versions 0..11 | |
| %7|1649257442.783|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey LeaderAndIsr (4) Versions 0..5 | |
| %7|1649257442.783|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey StopReplica (5) Versions 0..3 | |
| %7|1649257442.783|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey UpdateMetadata (6) Versions 0..7 | |
| %7|1649257442.783|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey ControlledShutdown (7) Versions 0..3 | |
| %7|1649257442.783|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey OffsetCommit (8) Versions 0..8 | |
| %7|1649257442.783|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey OffsetFetch (9) Versions 0..7 | |
| %7|1649257442.783|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey FindCoordinator (10) Versions 0..3 | |
| %7|1649257442.783|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey JoinGroup (11) Versions 0..7 | |
| %7|1649257442.783|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey Heartbeat (12) Versions 0..4 | |
| %7|1649257442.783|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey LeaveGroup (13) Versions 0..4 | |
| %7|1649257442.783|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey SyncGroup (14) Versions 0..5 | |
| %7|1649257442.783|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey DescribeGroups (15) Versions 0..5 | |
| %7|1649257442.783|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey ListGroups (16) Versions 0..4 | |
| %7|1649257442.783|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey SaslHandshake (17) Versions 0..1 | |
| %7|1649257442.783|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey ApiVersion (18) Versions 0..3 | |
| %7|1649257442.783|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey CreateTopics (19) Versions 0..7 | |
| %7|1649257442.783|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey DeleteTopics (20) Versions 0..6 | |
| %7|1649257442.783|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey DeleteRecords (21) Versions 0..2 | |
| %7|1649257442.783|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey InitProducerId (22) Versions 0..4 | |
| %7|1649257442.783|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey OffsetForLeaderEpoch (23) Versions 0..4 | |
| %7|1649257442.784|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey AddPartitionsToTxn (24) Versions 0..3 | |
| %7|1649257442.784|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey AddOffsetsToTxn (25) Versions 0..3 | |
| %7|1649257442.784|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey EndTxn (26) Versions 0..3 | |
| %7|1649257442.784|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey WriteTxnMarkers (27) Versions 0..1 | |
| %7|1649257442.784|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey TxnOffsetCommit (28) Versions 0..3 | |
| %7|1649257442.784|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey DescribeAcls (29) Versions 0..2 | |
| %7|1649257442.784|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey CreateAcls (30) Versions 0..2 | |
| %7|1649257442.784|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey DeleteAcls (31) Versions 0..2 | |
| %7|1649257442.784|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey DescribeConfigs (32) Versions 0..4 | |
| %7|1649257442.784|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey AlterConfigs (33) Versions 0..2 | |
| %7|1649257442.784|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey AlterReplicaLogDirs (34) Versions 0..2 | |
| %7|1649257442.784|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey DescribeLogDirs (35) Versions 0..2 | |
| %7|1649257442.784|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey SaslAuthenticate (36) Versions 0..2 | |
| %7|1649257442.784|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey CreatePartitions (37) Versions 0..3 | |
| %7|1649257442.784|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey CreateDelegationToken (38) Versions 0..2 | |
| %7|1649257442.784|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey RenewDelegationToken (39) Versions 0..2 | |
| %7|1649257442.784|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey ExpireDelegationToken (40) Versions 0..2 | |
| %7|1649257442.784|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey DescribeDelegationToken (41) Versions 0..2 | |
| %7|1649257442.784|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey DeleteGroups (42) Versions 0..2 | |
| %7|1649257442.784|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey ElectLeadersRequest (43) Versions 0..2 | |
| %7|1649257442.784|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey IncrementalAlterConfigsRequest (44) Versions 0..1 | |
| %7|1649257442.784|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey AlterPartitionReassignmentsRequest (45) Versions 0..0 | |
| %7|1649257442.784|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey ListPartitionReassignmentsRequest (46) Versions 0..0 | |
| %7|1649257442.784|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey OffsetDeleteRequest (47) Versions 0..0 | |
| %7|1649257442.784|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey DescribeClientQuotasRequest (48) Versions 0..1 | |
| %7|1649257442.784|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey AlterClientQuotasRequest (49) Versions 0..1 | |
| %7|1649257442.784|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey DescribeUserScramCredentialsRequest (50) Versions 0..0 | |
| %7|1649257442.784|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey AlterUserScramCredentialsRequest (51) Versions 0..0 | |
| %7|1649257442.784|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey AlterIsrRequest (56) Versions 0..0 | |
| %7|1649257442.784|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey UpdateFeaturesRequest (57) Versions 0..0 | |
| %7|1649257442.784|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey Unknown-60? (60) Versions 0..0 | |
| %7|1649257442.784|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey Unknown-61? (61) Versions 0..0 | |
| %7|1649257442.784|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Feature MsgVer1: Produce (2..2) supported by broker | |
| %7|1649257442.784|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Feature MsgVer1: Fetch (2..2) supported by broker | |
| %7|1649257442.784|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Enabling feature MsgVer1 | |
| %7|1649257442.784|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Feature MsgVer2: Produce (3..3) supported by broker | |
| %7|1649257442.784|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Feature MsgVer2: Fetch (4..4) supported by broker | |
| %7|1649257442.784|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Enabling feature MsgVer2 | |
| %7|1649257442.784|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Feature ApiVersion: ApiVersion (0..0) supported by broker | |
| %7|1649257442.784|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Enabling feature ApiVersion | |
| %7|1649257442.784|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Feature BrokerGroupCoordinator: FindCoordinator (0..0) supported by broker | |
| %7|1649257442.784|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Enabling feature BrokerGroupCoordinator | |
| %7|1649257442.784|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Feature BrokerBalancedConsumer: FindCoordinator (0..0) supported by broker | |
| %7|1649257442.784|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Feature BrokerBalancedConsumer: OffsetCommit (1..2) supported by broker | |
| %7|1649257442.784|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Feature BrokerBalancedConsumer: OffsetFetch (1..1) supported by broker | |
| %7|1649257442.784|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Feature BrokerBalancedConsumer: JoinGroup (0..0) supported by broker | |
| %7|1649257442.784|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Feature BrokerBalancedConsumer: SyncGroup (0..0) supported by broker | |
| %7|1649257442.784|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Feature BrokerBalancedConsumer: Heartbeat (0..0) supported by broker | |
| %7|1649257442.784|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Feature BrokerBalancedConsumer: LeaveGroup (0..0) supported by broker | |
| %7|1649257442.784|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Enabling feature BrokerBalancedConsumer | |
| %7|1649257442.784|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Feature ThrottleTime: Produce (1..2) supported by broker | |
| %7|1649257442.784|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Feature ThrottleTime: Fetch (1..2) supported by broker | |
| %7|1649257442.784|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Enabling feature ThrottleTime | |
| %7|1649257442.784|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Feature Sasl: JoinGroup (0..0) supported by broker | |
| %7|1649257442.784|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Enabling feature Sasl | |
| %7|1649257442.784|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Feature SaslHandshake: SaslHandshake (0..0) supported by broker | |
| %7|1649257442.784|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Enabling feature SaslHandshake | |
| %7|1649257442.784|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Feature LZ4: FindCoordinator (0..0) supported by broker | |
| %7|1649257442.784|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Enabling feature LZ4 | |
| %7|1649257442.784|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Feature OffsetTime: ListOffsets (1..1) supported by broker | |
| %7|1649257442.784|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Enabling feature OffsetTime | |
| %7|1649257442.784|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Feature IdempotentProducer: InitProducerId (0..0) supported by broker | |
| %7|1649257442.784|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Enabling feature IdempotentProducer | |
| %7|1649257442.784|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Feature ZSTD: Produce (7..7) supported by broker | |
| %7|1649257442.784|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Feature ZSTD: Fetch (10..10) supported by broker | |
| %7|1649257442.784|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Enabling feature ZSTD | |
| %7|1649257442.784|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Feature SaslAuthReq: SaslHandshake (1..1) supported by broker | |
| %7|1649257442.784|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Feature SaslAuthReq: SaslAuthenticate (0..0) supported by broker | |
| %7|1649257442.784|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Enabling feature SaslAuthReq | |
| %7|1649257442.784|FEATURE|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Updated enabled protocol features to MsgVer1,ApiVersion,BrokerBalancedConsumer,ThrottleTime,Sasl,SaslHandshake,BrokerGroupCoordinator,LZ4,OffsetTime,MsgVer2,IdempotentProducer,ZSTD,SaslAuthReq | |
| %7|1649257442.784|STATE|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Broker changed state APIVERSION_QUERY -> UP | |
| %7|1649257442.784|BROADCAST|rdkafka#consumer-1| [thrd:GroupCoordinator]: Broadcasting state change | |
| %7|1649257442.784|METADATA|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Request metadata for brokers only: connected | |
| %7|1649257442.784|CGRPSTATE|rdkafka#consumer-1| [thrd:main]: Group "group_id_CCC" changed state wait-broker-transport -> up (join-state init) | |
| %7|1649257442.784|BROADCAST|rdkafka#consumer-1| [thrd:main]: Broadcasting state change | |
| %7|1649257442.784|JOIN|rdkafka#consumer-1| [thrd:main]: Group "group_id_CCC": join with 0 subscribed topic(s) | |
| %7|1649257442.784|METADATA|rdkafka#consumer-1| [thrd:main]: Hinted cache of 1/1 topic(s) being queried | |
| %7|1649257442.784|CGRPMETADATA|rdkafka#consumer-1| [thrd:main]: consumer join: metadata for subscription only available for 0/1 topics (-1ms old) | |
| %7|1649257442.784|SEND|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Sent MetadataRequest (v4, 26 bytes @ 0, CorrId 2) | |
| %7|1649257442.784|METADATA|rdkafka#consumer-1| [thrd:main]: 10.6.96.47:9092/0: Request metadata for 1 topic(s): consumer join | |
| %7|1649257442.784|JOIN|rdkafka#consumer-1| [thrd:main]: Group "group_id_CCC": postponing join until up-to-date metadata is available | |
| %7|1649257442.785|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "group_id_CCC" changed join state init -> wait-metadata (state up) | |
| %7|1649257442.785|DUMP|rdkafka#consumer-1| [thrd:main]: Assignment dump (started_cnt=0, wait_stop_cnt=0) | |
| %7|1649257442.785|DUMP_ALL|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649257442.785|DUMP_PND|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649257442.785|DUMP_QRY|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649257442.785|DUMP_REM|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649257442.785|SEND|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Sent MetadataRequest (v4, 38 bytes @ 0, CorrId 5) | |
| %7|1649257442.785|ASSIGNDONE|rdkafka#consumer-1| [thrd:main]: Group "group_id_CCC": assignment operations done in join-state wait-metadata (rebalance rejoin=false) | |
| %7|1649257442.807|RECV|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Received MetadataResponse (v4, 107 bytes, CorrId 5, rtt 22.73ms) | |
| %7|1649257442.807|RECV|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Received MetadataResponse (v4, 62 bytes, CorrId 2, rtt 22.92ms) | |
| %7|1649257442.807|METADATA|rdkafka#consumer-1| [thrd:main]: 10.6.96.47:9092/0: ===== Received metadata (for 1 requested topics): consumer join ===== | |
| %7|1649257442.807|METADATA|rdkafka#consumer-1| [thrd:main]: 10.6.96.47:9092/0: ClusterId: lUrBz8BNRMie_7FYhW4aXQ, ControllerId: 0 | |
| %7|1649257442.807|METADATA|rdkafka#consumer-1| [thrd:main]: 10.6.96.47:9092/0: 1 brokers, 1 topics | |
| %7|1649257442.807|METADATA|rdkafka#consumer-1| [thrd:main]: 10.6.96.47:9092/0: Broker #0/1: 10.6.96.47:9092 NodeId 0 | |
| %7|1649257442.807|METADATA|rdkafka#consumer-1| [thrd:main]: 10.6.96.47:9092/0: Topic #0/1: py_kafka_6 with 1 partitions | |
| %7|1649257442.807|METADATA|rdkafka#consumer-1| [thrd:main]: 10.6.96.47:9092/0: 1/1 requested topic(s) seen in metadata | |
| %7|1649257442.807|SUBSCRIPTION|rdkafka#consumer-1| [thrd:main]: Group "group_id_CCC": effective subscription list changed from 0 to 1 topic(s): | |
| %7|1649257442.807|SUBSCRIPTION|rdkafka#consumer-1| [thrd:main]: Topic py_kafka_6 with 1 partition(s) | |
| %7|1649257442.807|REJOIN|rdkafka#consumer-1| [thrd:main]: Group "group_id_CCC": subscription updated from metadata change: rejoining group in state wait-metadata | |
| %7|1649257442.807|GRPLEADER|rdkafka#consumer-1| [thrd:main]: Group "group_id_CCC": resetting group leader info: group (re)join | |
| %7|1649257442.807|REJOIN|rdkafka#consumer-1| [thrd:main]: Group "group_id_CCC" (re)joining in join-state wait-metadata with 0 assigned partition(s): Metadata for subscribed topic(s) has changed | |
| %7|1649257442.807|REBALANCE|rdkafka#consumer-1| [thrd:main]: Group "group_id_CCC" initiating rebalance (NONE) in state up (join-state wait-metadata) with 0 assigned partition(s): Metadata for subscribed topic(s) has changed | |
| %7|1649257442.807|REJOIN|rdkafka#consumer-1| [thrd:main]: Group "group_id_CCC": Rejoining group without an assignment: Metadata for subscribed topic(s) has changed | |
| %7|1649257442.807|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "group_id_CCC" changed join state wait-metadata -> init (state up) | |
| %7|1649257442.808|JOIN|rdkafka#consumer-1| [thrd:main]: Group "group_id_CCC": join with 1 subscribed topic(s) | |
| %7|1649257442.808|CGRPMETADATA|rdkafka#consumer-1| [thrd:main]: consumer join: metadata for subscription is up to date (0ms old) | |
| %7|1649257442.808|JOIN|rdkafka#consumer-1| [thrd:main]: 10.6.96.47:9092/0: Joining group "group_id_CCC" with 1 subscribed topic(s) and member id "" | |
| %7|1649257442.808|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "group_id_CCC" changed join state init -> wait-join (state up) | |
| %7|1649257442.808|METADATA|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/0: ===== Received metadata: connected ===== | |
| %7|1649257442.808|METADATA|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/0: ClusterId: lUrBz8BNRMie_7FYhW4aXQ, ControllerId: 0 | |
| %7|1649257442.808|METADATA|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/0: 1 brokers, 0 topics | |
| %7|1649257442.808|METADATA|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/0: Broker #0/1: 10.6.96.47:9092 NodeId 0 | |
| %7|1649257442.808|SEND|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Sent JoinGroupRequest (v5, 140 bytes @ 0, CorrId 3) | |
| %7|1649257442.808|BROADCAST|rdkafka#consumer-1| [thrd:GroupCoordinator]: Broadcasting state change | |
| %7|1649257442.831|RECV|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Received JoinGroupResponse (v5, 64 bytes, CorrId 3, rtt 23.83ms) | |
| %7|1649257442.831|JOINGROUP|rdkafka#consumer-1| [thrd:main]: JoinGroup response: GenerationId -1, Protocol , LeaderId , my MemberId rdkafka-a930626e-1767-49e8-9aa7-0bc1d2a5701a, member metadata count 0: Broker: Group member needs a valid member ID | |
| %7|1649257442.832|REQERR|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/0: JoinGroupRequest failed: Broker: Group member needs a valid member ID: explicit actions Ignore | |
| %7|1649257442.832|MEMBERID|rdkafka#consumer-1| [thrd:main]: Group "group_id_CCC": updating member id "" -> "rdkafka-a930626e-1767-49e8-9aa7-0bc1d2a5701a" | |
| %7|1649257442.832|REJOIN|rdkafka#consumer-1| [thrd:main]: Group "group_id_CCC": Rejoining group without an assignment: JoinGroup error: Broker: Group member needs a valid member ID | |
| %7|1649257442.832|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "group_id_CCC" changed join state wait-join -> init (state up) | |
| %7|1649257442.832|JOIN|rdkafka#consumer-1| [thrd:main]: Group "group_id_CCC": join with 1 subscribed topic(s) | |
| %7|1649257442.832|CGRPMETADATA|rdkafka#consumer-1| [thrd:main]: consumer join: metadata for subscription is up to date (24ms old) | |
| %7|1649257442.832|JOIN|rdkafka#consumer-1| [thrd:main]: 10.6.96.47:9092/0: Joining group "group_id_CCC" with 1 subscribed topic(s) and member id "rdkafka-a930626e-1767-49e8-9aa7-0bc1d2a5701a" | |
| %7|1649257442.832|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "group_id_CCC" changed join state init -> wait-join (state up) | |
| %7|1649257442.832|SEND|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Sent JoinGroupRequest (v5, 184 bytes @ 0, CorrId 4) | |
| %7|1649257442.832|BROADCAST|rdkafka#consumer-1| [thrd:GroupCoordinator]: Broadcasting state change | |
| %7|1649257442.856|RECV|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Received JoinGroupResponse (v5, 191 bytes, CorrId 4, rtt 24.69ms) | |
| %7|1649257442.856|JOINGROUP|rdkafka#consumer-1| [thrd:main]: JoinGroup response: GenerationId 1, Protocol range, LeaderId rdkafka-a930626e-1767-49e8-9aa7-0bc1d2a5701a (me), my MemberId rdkafka-a930626e-1767-49e8-9aa7-0bc1d2a5701a, member metadata count 1: (no error) | |
| %7|1649257442.856|JOINGROUP|rdkafka#consumer-1| [thrd:main]: I am elected leader for group "group_id_CCC" with 1 member(s) | |
| %7|1649257442.856|GRPLEADER|rdkafka#consumer-1| [thrd:main]: Group "group_id_CCC": resetting group leader info: JoinGroup response clean-up | |
| %7|1649257442.856|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "group_id_CCC" changed join state wait-join -> wait-metadata (state up) | |
| %7|1649257442.856|METADATA|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/0: Request metadata for 1 topic(s): partition assignor | |
| %7|1649257442.857|SEND|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Sent MetadataRequest (v4, 38 bytes @ 0, CorrId 5) | |
| %7|1649257442.879|RECV|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Received MetadataResponse (v4, 107 bytes, CorrId 5, rtt 22.82ms) | |
| %7|1649257442.879|METADATA|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/0: ===== Received metadata (for 1 requested topics): partition assignor ===== | |
| %7|1649257442.879|METADATA|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/0: ClusterId: lUrBz8BNRMie_7FYhW4aXQ, ControllerId: 0 | |
| %7|1649257442.879|METADATA|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/0: 1 brokers, 1 topics | |
| %7|1649257442.879|METADATA|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/0: Broker #0/1: 10.6.96.47:9092 NodeId 0 | |
| %7|1649257442.879|METADATA|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/0: Topic #0/1: py_kafka_6 with 1 partitions | |
| %7|1649257442.879|METADATA|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/0: 1/1 requested topic(s) seen in metadata | |
| %7|1649257442.879|ASSIGN|rdkafka#consumer-1| [thrd:main]: Group "group_id_CCC" running range assignor for 1 member(s) and 1 eligible subscribed topic(s): | |
| %7|1649257442.879|ASSIGN|rdkafka#consumer-1| [thrd:main]: Member "rdkafka-a930626e-1767-49e8-9aa7-0bc1d2a5701a" (me) with 0 owned partition(s) and 1 subscribed topic(s): | |
| %7|1649257442.879|ASSIGN|rdkafka#consumer-1| [thrd:main]: py_kafka_6 [-1] | |
| %7|1649257442.879|ASSIGN|rdkafka#consumer-1| [thrd:main]: range: Topic py_kafka_6 with 1 partition(s) and 1 subscribing member(s) | |
| %7|1649257442.879|ASSIGN|rdkafka#consumer-1| [thrd:main]: range: Member "rdkafka-a930626e-1767-49e8-9aa7-0bc1d2a5701a": assigned topic py_kafka_6 partitions 0..0 | |
| %7|1649257442.879|ASSIGN|rdkafka#consumer-1| [thrd:main]: Group "group_id_CCC" range assignment for 1 member(s) finished in 0.015ms: | |
| %7|1649257442.879|ASSIGN|rdkafka#consumer-1| [thrd:main]: Member "rdkafka-a930626e-1767-49e8-9aa7-0bc1d2a5701a" (me) assigned 1 partition(s): | |
| %7|1649257442.879|ASSIGN|rdkafka#consumer-1| [thrd:main]: py_kafka_6 [0] | |
| %7|1649257442.879|ASSIGNOR|rdkafka#consumer-1| [thrd:main]: Group "group_id_CCC": "range" assignor run for 1 member(s) | |
| %7|1649257442.879|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "group_id_CCC" changed join state wait-metadata -> wait-sync (state up) | |
| %7|1649257442.880|SEND|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Sent SyncGroupRequest (v3, 171 bytes @ 0, CorrId 6) | |
| %7|1649257442.880|BROADCAST|rdkafka#consumer-1| [thrd:GroupCoordinator]: Broadcasting state change | |
| %7|1649257442.903|RECV|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Received SyncGroupResponse (v3, 40 bytes, CorrId 6, rtt 23.80ms) | |
| %7|1649257442.903|SYNCGROUP|rdkafka#consumer-1| [thrd:main]: SyncGroup response: Success (30 bytes of MemberState data) | |
| %7|1649257442.903|ASSIGNMENT|rdkafka#consumer-1| [thrd:main]: List with 1 partition(s): | |
| %7|1649257442.903|ASSIGNMENT|rdkafka#consumer-1| [thrd:main]: py_kafka_6 [0] offset INVALID | |
| %7|1649257442.903|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "group_id_CCC" changed join state wait-sync -> wait-assign-call (state up) | |
| %7|1649257442.903|ASSIGN|rdkafka#consumer-1| [thrd:main]: Group "group_id_CCC": delegating assign of 1 partition(s) to application on queue rd_kafka_cgrp_new: new assignment | |
| %7|1649257442.903|ASSIGNMENT|rdkafka#consumer-1| [thrd:main]: Group "group_id_CCC": setting group assignment to 1 partition(s) | |
| %7|1649257442.903|GRPASSIGNMENT|rdkafka#consumer-1| [thrd:main]: List with 1 partition(s): | |
| %7|1649257442.904|GRPASSIGNMENT|rdkafka#consumer-1| [thrd:main]: py_kafka_6 [0] offset INVALID | |
| %7|1649257442.904|HEARTBEAT|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/0: Heartbeat for group "group_id_CCC" generation id 1 | |
| %7|1649257442.904|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "group_id_CCC" received op GET_REBALANCE_PROTOCOL in state up (join-state wait-assign-call) | |
| %7|1649257442.904|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "group_id_CCC" received op ASSIGN in state up (join-state wait-assign-call) | |
| %7|1649257442.904|ASSIGN|rdkafka#consumer-1| [thrd:main]: Group "group_id_CCC": new assignment of 1 partition(s) in join-state wait-assign-call | |
| %7|1649257442.904|SEND|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Sent HeartbeatRequest (v3, 87 bytes @ 0, CorrId 7) | |
| %7|1649257442.904|CLEARASSIGN|rdkafka#consumer-1| [thrd:main]: No current assignment to clear | |
| %7|1649257442.904|TOPIC|rdkafka#consumer-1| [thrd:main]: New local topic: py_kafka_6 | |
| %7|1649257442.904|TOPPARNEW|rdkafka#consumer-1| [thrd:main]: NEW py_kafka_6 [-1] 0x7fabf82560d0 refcnt 0x7fabf8256160 (at rd_kafka_topic_new0:465) | |
| %7|1649257442.904|STATE|rdkafka#consumer-1| [thrd:main]: Topic py_kafka_6 changed state unknown -> exists | |
| %7|1649257442.904|PARTCNT|rdkafka#consumer-1| [thrd:main]: Topic py_kafka_6 partition count changed from 0 to 1 | |
| %7|1649257442.904|TOPPARNEW|rdkafka#consumer-1| [thrd:main]: NEW py_kafka_6 [0] 0x7fabf82564c0 refcnt 0x7fabf8256550 (at rd_kafka_topic_partition_cnt_update:798) | |
| %7|1649257442.904|METADATA|rdkafka#consumer-1| [thrd:main]: Topic py_kafka_6 partition 0 Leader 0 | |
| %7|1649257442.904|BRKDELGT|rdkafka#consumer-1| [thrd:main]: py_kafka_6 [0]: delegate to broker 10.6.96.47:9092/0 (rktp 0x7fabf82564c0, term 0, ref 2) | |
| %7|1649257442.904|BRKDELGT|rdkafka#consumer-1| [thrd:main]: py_kafka_6 [0]: delegating to broker 10.6.96.47:9092/0 for partition with 0 messages (0 bytes) queued | |
| %7|1649257442.904|BRKMIGR|rdkafka#consumer-1| [thrd:main]: Migrating topic py_kafka_6 [0] 0x7fabf82564c0 from (none) to 10.6.96.47:9092/0 (sending PARTITION_JOIN to 10.6.96.47:9092/0) | |
| %7|1649257442.904|CONF|rdkafka#consumer-1| [thrd:main]: Topic "py_kafka_6" configuration (default_topic_conf): | |
| %7|1649257442.904|CONF|rdkafka#consumer-1| [thrd:main]: auto.offset.reset = largest | |
| %7|1649257442.904|DESIRED|rdkafka#consumer-1| [thrd:main]: py_kafka_6 [0]: marking as DESIRED | |
| %7|1649257442.904|ASSIGNMENT|rdkafka#consumer-1| [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 | |
| %7|1649257442.904|PAUSE|rdkafka#consumer-1| [thrd:main]: Resuming fetchers for 1 assigned partition(s): assign called | |
| %7|1649257442.904|TOPBRK|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Topic py_kafka_6 [0]: joining broker (rktp 0x7fabf82564c0, 0 message(s) queued) | |
| %7|1649257442.904|BROADCAST|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: Broadcasting state change | |
| %7|1649257442.904|RESUME|rdkafka#consumer-1| [thrd:main]: Library resuming 1 partition(s) | |
| %7|1649257442.904|BARRIER|rdkafka#consumer-1| [thrd:main]: py_kafka_6 [0]: rd_kafka_toppar_op_pause_resume:2449: new version barrier v2 | |
| %7|1649257442.904|RESUME|rdkafka#consumer-1| [thrd:main]: Resume py_kafka_6 [0] (v2) | |
| %7|1649257442.904|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "group_id_CCC" changed join state wait-assign-call -> steady (state up) | |
| %7|1649257442.910|DUMP|rdkafka#consumer-1| [thrd:main]: Assignment dump (started_cnt=0, wait_stop_cnt=0) | |
| %7|1649257442.910|DUMP_ALL|rdkafka#consumer-1| [thrd:main]: List with 1 partition(s): | |
| %7|1649257442.910|DUMP_ALL|rdkafka#consumer-1| [thrd:main]: py_kafka_6 [0] offset STORED | |
| %7|1649257442.910|DUMP_PND|rdkafka#consumer-1| [thrd:main]: List with 1 partition(s): | |
| %7|1649257442.910|DUMP_PND|rdkafka#consumer-1| [thrd:main]: py_kafka_6 [0] offset STORED | |
| %7|1649257442.910|DUMP_QRY|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649257442.910|DUMP_REM|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649257442.910|SRVPEND|rdkafka#consumer-1| [thrd:main]: Querying committed offset for pending assigned partition py_kafka_6 [0] | |
| %7|1649257442.910|OFFSETFETCH|rdkafka#consumer-1| [thrd:main]: Fetching committed offsets for 1 pending partition(s) in assignment | |
| %7|1649257442.910|OFFSET|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/0: OffsetFetchRequest(v7) for 1/1 partition(s) | |
| %7|1649257442.910|OFFSET|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/0: Fetch committed offsets for 1/1 partition(s) | |
| %7|1649257442.910|ASSIGNMENT|rdkafka#consumer-1| [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 | |
| %7|1649257442.910|OP|rdkafka#consumer-1| [thrd:main]: py_kafka_6 [0] received op PAUSE (v2) in fetch-state none (opv1) | |
| %7|1649257442.910|RESUME|rdkafka#consumer-1| [thrd:main]: Not resuming py_kafka_6 [0]: partition is not paused by library | |
| %7|1649257442.910|SEND|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Sent OffsetFetchRequest (v7, 55 bytes @ 0, CorrId 8) | |
| %7|1649257442.927|RECV|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Received HeartbeatResponse (v3, 6 bytes, CorrId 7, rtt 23.70ms) | |
| %7|1649257442.950|RECV|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Received OffsetFetchResponse (v7, 42 bytes, CorrId 8, rtt 39.89ms) | |
| %7|1649257442.950|OFFSETFETCH|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/0: OffsetFetchResponse: py_kafka_6 [0] offset -1, metadata 0 byte(s): NO_ERROR | |
| %7|1649257442.950|OFFFETCH|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/0: OffsetFetch for 1/1 partition(s) (0 unstable partition(s)) returned Success | |
| %7|1649257442.950|OFFSETFETCH|rdkafka#consumer-1| [thrd:main]: Adding py_kafka_6 [0] back to pending list with offset INVALID | |
| %7|1649257442.950|DUMP|rdkafka#consumer-1| [thrd:main]: Assignment dump (started_cnt=0, wait_stop_cnt=0) | |
| %7|1649257442.950|DUMP_ALL|rdkafka#consumer-1| [thrd:main]: List with 1 partition(s): | |
| %7|1649257442.950|DUMP_ALL|rdkafka#consumer-1| [thrd:main]: py_kafka_6 [0] offset STORED | |
| %7|1649257442.950|DUMP_PND|rdkafka#consumer-1| [thrd:main]: List with 1 partition(s): | |
| %7|1649257442.950|DUMP_PND|rdkafka#consumer-1| [thrd:main]: py_kafka_6 [0] offset INVALID | |
| %7|1649257442.950|DUMP_QRY|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649257442.950|DUMP_REM|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649257442.950|SRVPEND|rdkafka#consumer-1| [thrd:main]: Starting pending assigned partition py_kafka_6 [0] at offset INVALID | |
| %7|1649257442.950|BARRIER|rdkafka#consumer-1| [thrd:main]: py_kafka_6 [0]: rd_kafka_toppar_op_pause_resume:2449: new version barrier v3 | |
| %7|1649257442.950|RESUME|rdkafka#consumer-1| [thrd:main]: Resume py_kafka_6 [0] (v3) | |
| %7|1649257442.950|BARRIER|rdkafka#consumer-1| [thrd:main]: py_kafka_6 [0]: rd_kafka_toppar_op_fetch_start:2363: new version barrier v4 | |
| %7|1649257442.950|CONSUMER|rdkafka#consumer-1| [thrd:main]: Start consuming py_kafka_6 [0] at offset INVALID (v4) | |
| %7|1649257442.950|ASSIGNDONE|rdkafka#consumer-1| [thrd:main]: Group "group_id_CCC": assignment operations done in join-state steady (rebalance rejoin=false) | |
| %7|1649257442.950|OP|rdkafka#consumer-1| [thrd:main]: py_kafka_6 [0] received op PAUSE (v3) in fetch-state none (opv2) | |
| %7|1649257442.950|RESUME|rdkafka#consumer-1| [thrd:main]: Not resuming py_kafka_6 [0]: partition is not paused by library | |
| %7|1649257442.950|OP|rdkafka#consumer-1| [thrd:main]: py_kafka_6 [0] received op FETCH_START (v4) in fetch-state none (opv3) | |
| %7|1649257442.950|FETCH|rdkafka#consumer-1| [thrd:main]: Start fetch for py_kafka_6 [0] in state none at offset INVALID (v4) | |
| %7|1649257442.950|PARTSTATE|rdkafka#consumer-1| [thrd:main]: Partition py_kafka_6 [0] changed fetch state none -> offset-query | |
| %7|1649257442.950|OFFSET|rdkafka#consumer-1| [thrd:main]: py_kafka_6 [0]: offset reset (at offset INVALID) to END: no previously committed offset available: Local: No offset stored | |
| %7|1649257442.950|OFFSET|rdkafka#consumer-1| [thrd:main]: py_kafka_6 [0]: backoff: (re)starting offset query timer for offset END | |
| %7|1649257442.950|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "group_id_CCC" received op PARTITION_JOIN in state up (join-state steady) for py_kafka_6 [0] | |
| %7|1649257442.950|PARTADD|rdkafka#consumer-1| [thrd:main]: Group "group_id_CCC": add py_kafka_6 [0] | |
| %7|1649257443.053|OFFSET|rdkafka#consumer-1| [thrd:main]: Topic py_kafka_6 [0]: timed offset query for END in state offset-query | |
| %7|1649257443.053|OFFREQ|rdkafka#consumer-1| [thrd:main]: 10.6.96.47:9092/0: Partition py_kafka_6 [0]: querying for logical offset END (opv 4) | |
| %7|1649257443.053|PARTSTATE|rdkafka#consumer-1| [thrd:main]: Partition py_kafka_6 [0] changed fetch state offset-query -> offset-wait | |
| %7|1649257443.053|OFFSET|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: ListOffsetsRequest (v2, opv 4) for 1 topic(s) and 1 partition(s) | |
| %7|1649257443.053|SEND|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Sent ListOffsetsRequest (v2, 58 bytes @ 0, CorrId 6) | |
| %7|1649257443.076|RECV|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Received ListOffsetsResponse (v2, 46 bytes, CorrId 6, rtt 22.89ms) | |
| %7|1649257443.076|OFFSET|rdkafka#consumer-1| [thrd:main]: 10.6.96.47:9092/0: Offset reply for topic py_kafka_6 [0] (v4 vs v4) | |
| %7|1649257443.076|OFFSET|rdkafka#consumer-1| [thrd:main]: Offset END request for py_kafka_6 [0] returned offset 10 (10) | |
| %7|1649257443.076|PARTSTATE|rdkafka#consumer-1| [thrd:main]: Partition py_kafka_6 [0] changed fetch state offset-wait -> active | |
| %7|1649257443.076|FETCH|rdkafka#consumer-1| [thrd:main]: Partition py_kafka_6 [0] start fetching at offset 10 | |
| %7|1649257443.076|WAKEUP|rdkafka#consumer-1| [thrd:main]: 10.6.96.47:9092/0: Wake-up | |
| %7|1649257443.076|FETCHDEC|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: Topic py_kafka_6 [0]: fetch decide: updating to version 4 (was 0) at offset 10 (was 0) | |
| %7|1649257443.076|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Topic py_kafka_6 [0] in state active at offset 10 (0/100000 msgs, 0/65536 kb queued, opv 4) is fetchable | |
| %7|1649257443.076|FETCHADD|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Added py_kafka_6 [0] to fetch list (1 entries, opv 4, 0 messages queued): fetchable | |
| %7|1649257443.077|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch topic py_kafka_6 [0] at offset 10 (v4) | |
| %7|1649257443.077|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch 1/1/1 toppar(s) | |
| %7|1649257443.077|SEND|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Sent FetchRequest (v11, 100 bytes @ 0, CorrId 7) | |
| %7|1649257443.642|RECV|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Received FetchResponse (v11, 72 bytes, CorrId 7, rtt 565.76ms) | |
| %7|1649257443.642|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Topic py_kafka_6 [0] MessageSet size 0, error "Success", MaxOffset 10, LSO 10, Ver 4/4 | |
| %7|1649257443.642|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch topic py_kafka_6 [0] at offset 10 (v4) | |
| %7|1649257443.642|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch 1/1/1 toppar(s) | |
| %7|1649257443.642|SEND|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Sent FetchRequest (v11, 100 bytes @ 0, CorrId 8) | |
| %7|1649257444.166|RECV|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Received FetchResponse (v11, 72 bytes, CorrId 8, rtt 523.17ms) | |
| %7|1649257444.166|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Topic py_kafka_6 [0] MessageSet size 0, error "Success", MaxOffset 10, LSO 10, Ver 4/4 | |
| %7|1649257444.166|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch topic py_kafka_6 [0] at offset 10 (v4) | |
| %7|1649257444.166|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch 1/1/1 toppar(s) | |
| %7|1649257444.166|SEND|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Sent FetchRequest (v11, 100 bytes @ 0, CorrId 9) | |
| %7|1649257444.739|RECV|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Received FetchResponse (v11, 72 bytes, CorrId 9, rtt 573.35ms) | |
| %7|1649257444.739|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Topic py_kafka_6 [0] MessageSet size 0, error "Success", MaxOffset 10, LSO 10, Ver 4/4 | |
| %7|1649257444.739|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch topic py_kafka_6 [0] at offset 10 (v4) | |
| %7|1649257444.739|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch 1/1/1 toppar(s) | |
| %7|1649257444.739|SEND|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Sent FetchRequest (v11, 100 bytes @ 0, CorrId 10) | |
| %7|1649257445.484|RECV|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Received FetchResponse (v11, 72 bytes, CorrId 10, rtt 745.02ms) | |
| %7|1649257445.484|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Topic py_kafka_6 [0] MessageSet size 0, error "Success", MaxOffset 10, LSO 10, Ver 4/4 | |
| %7|1649257445.484|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch topic py_kafka_6 [0] at offset 10 (v4) | |
| %7|1649257445.484|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch 1/1/1 toppar(s) | |
| %7|1649257445.484|SEND|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Sent FetchRequest (v11, 100 bytes @ 0, CorrId 11) | |
| %7|1649257445.932|HEARTBEAT|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/0: Heartbeat for group "group_id_CCC" generation id 1 | |
| %7|1649257445.932|SEND|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Sent HeartbeatRequest (v3, 87 bytes @ 0, CorrId 9) | |
| %7|1649257445.956|RECV|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Received HeartbeatResponse (v3, 6 bytes, CorrId 9, rtt 23.92ms) | |
| %7|1649257446.007|RECV|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Received FetchResponse (v11, 72 bytes, CorrId 11, rtt 523.23ms) | |
| %7|1649257446.007|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Topic py_kafka_6 [0] MessageSet size 0, error "Success", MaxOffset 10, LSO 10, Ver 4/4 | |
| %7|1649257446.007|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch topic py_kafka_6 [0] at offset 10 (v4) | |
| %7|1649257446.007|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch 1/1/1 toppar(s) | |
| %7|1649257446.008|SEND|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Sent FetchRequest (v11, 100 bytes @ 0, CorrId 12) | |
| %7|1649257446.531|RECV|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Received FetchResponse (v11, 72 bytes, CorrId 12, rtt 523.10ms) | |
| %7|1649257446.531|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Topic py_kafka_6 [0] MessageSet size 0, error "Success", MaxOffset 10, LSO 10, Ver 4/4 | |
| %7|1649257446.531|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch topic py_kafka_6 [0] at offset 10 (v4) | |
| %7|1649257446.531|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch 1/1/1 toppar(s) | |
| %7|1649257446.531|SEND|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Sent FetchRequest (v11, 100 bytes @ 0, CorrId 13) | |
| %7|1649257447.327|RECV|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Received FetchResponse (v11, 72 bytes, CorrId 13, rtt 796.61ms) | |
| %7|1649257447.327|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Topic py_kafka_6 [0] MessageSet size 0, error "Success", MaxOffset 10, LSO 10, Ver 4/4 | |
| %7|1649257447.327|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch topic py_kafka_6 [0] at offset 10 (v4) | |
| %7|1649257447.327|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch 1/1/1 toppar(s) | |
| %7|1649257447.327|SEND|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Sent FetchRequest (v11, 100 bytes @ 0, CorrId 14) | |
| %7|1649257447.632|OFFSET|rdkafka#consumer-1| [thrd:main]: Topic py_kafka_6 [0]: stored offset -1001, committed offset -1001: not including in commit | |
| %7|1649257447.632|DUMP|rdkafka#consumer-1| [thrd:main]: Assignment dump (started_cnt=1, wait_stop_cnt=0) | |
| %7|1649257447.632|DUMP_ALL|rdkafka#consumer-1| [thrd:main]: List with 1 partition(s): | |
| %7|1649257447.632|DUMP_ALL|rdkafka#consumer-1| [thrd:main]: py_kafka_6 [0] offset STORED | |
| %7|1649257447.632|DUMP_PND|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649257447.632|DUMP_QRY|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649257447.632|DUMP_REM|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649257447.632|ASSIGNDONE|rdkafka#consumer-1| [thrd:main]: Group "group_id_CCC": assignment operations done in join-state steady (rebalance rejoin=false) | |
| %7|1649257447.942|RECV|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Received FetchResponse (v11, 72 bytes, CorrId 14, rtt 614.38ms) | |
| %7|1649257447.942|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Topic py_kafka_6 [0] MessageSet size 0, error "Success", MaxOffset 10, LSO 10, Ver 4/4 | |
| %7|1649257447.942|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch topic py_kafka_6 [0] at offset 10 (v4) | |
| %7|1649257447.942|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch 1/1/1 toppar(s) | |
| %7|1649257447.942|SEND|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Sent FetchRequest (v11, 100 bytes @ 0, CorrId 15) | |
| %7|1649257448.562|RECV|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Received FetchResponse (v11, 72 bytes, CorrId 15, rtt 620.35ms) | |
| %7|1649257448.562|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Topic py_kafka_6 [0] MessageSet size 0, error "Success", MaxOffset 10, LSO 10, Ver 4/4 | |
| %7|1649257448.562|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch topic py_kafka_6 [0] at offset 10 (v4) | |
| %7|1649257448.562|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch 1/1/1 toppar(s) | |
| %7|1649257448.562|SEND|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Sent FetchRequest (v11, 100 bytes @ 0, CorrId 16) | |
| %7|1649257448.947|HEARTBEAT|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/0: Heartbeat for group "group_id_CCC" generation id 1 | |
| %7|1649257448.947|SEND|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Sent HeartbeatRequest (v3, 87 bytes @ 0, CorrId 10) | |
| %7|1649257448.971|RECV|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Received HeartbeatResponse (v3, 6 bytes, CorrId 10, rtt 24.02ms) | |
| %7|1649257449.087|RECV|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Received FetchResponse (v11, 72 bytes, CorrId 16, rtt 524.92ms) | |
| %7|1649257449.087|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Topic py_kafka_6 [0] MessageSet size 0, error "Success", MaxOffset 10, LSO 10, Ver 4/4 | |
| %7|1649257449.087|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch topic py_kafka_6 [0] at offset 10 (v4) | |
| %7|1649257449.087|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch 1/1/1 toppar(s) | |
| %7|1649257449.087|SEND|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Sent FetchRequest (v11, 100 bytes @ 0, CorrId 17) | |
| %7|1649257449.611|RECV|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Received FetchResponse (v11, 72 bytes, CorrId 17, rtt 523.50ms) | |
| %7|1649257449.611|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Topic py_kafka_6 [0] MessageSet size 0, error "Success", MaxOffset 10, LSO 10, Ver 4/4 | |
| %7|1649257449.611|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch topic py_kafka_6 [0] at offset 10 (v4) | |
| %7|1649257449.611|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch 1/1/1 toppar(s) | |
| %7|1649257449.611|SEND|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Sent FetchRequest (v11, 100 bytes @ 0, CorrId 18) | |
| %7|1649257450.241|RECV|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Received FetchResponse (v11, 72 bytes, CorrId 18, rtt 630.53ms) | |
| %7|1649257450.241|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Topic py_kafka_6 [0] MessageSet size 0, error "Success", MaxOffset 10, LSO 10, Ver 4/4 | |
| %7|1649257450.241|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch topic py_kafka_6 [0] at offset 10 (v4) | |
| %7|1649257450.241|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch 1/1/1 toppar(s) | |
| %7|1649257450.241|SEND|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Sent FetchRequest (v11, 100 bytes @ 0, CorrId 19) | |
| %7|1649257450.765|RECV|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Received FetchResponse (v11, 72 bytes, CorrId 19, rtt 523.19ms) | |
| %7|1649257450.765|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Topic py_kafka_6 [0] MessageSet size 0, error "Success", MaxOffset 10, LSO 10, Ver 4/4 | |
| %7|1649257450.765|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch topic py_kafka_6 [0] at offset 10 (v4) | |
| %7|1649257450.765|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch 1/1/1 toppar(s) | |
| %7|1649257450.765|SEND|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Sent FetchRequest (v11, 100 bytes @ 0, CorrId 20) | |
| %7|1649257451.321|RECV|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Received FetchResponse (v11, 72 bytes, CorrId 20, rtt 556.26ms) | |
| %7|1649257451.321|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Topic py_kafka_6 [0] MessageSet size 0, error "Success", MaxOffset 10, LSO 10, Ver 4/4 | |
| %7|1649257451.321|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch topic py_kafka_6 [0] at offset 10 (v4) | |
| %7|1649257451.321|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch 1/1/1 toppar(s) | |
| %7|1649257451.321|SEND|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Sent FetchRequest (v11, 100 bytes @ 0, CorrId 21) | |
| %7|1649257451.935|RECV|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Received FetchResponse (v11, 72 bytes, CorrId 21, rtt 614.21ms) | |
| %7|1649257451.935|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Topic py_kafka_6 [0] MessageSet size 0, error "Success", MaxOffset 10, LSO 10, Ver 4/4 | |
| %7|1649257451.935|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch topic py_kafka_6 [0] at offset 10 (v4) | |
| %7|1649257451.935|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch 1/1/1 toppar(s) | |
| %7|1649257451.935|SEND|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Sent FetchRequest (v11, 100 bytes @ 0, CorrId 22) | |
| %7|1649257451.961|HEARTBEAT|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/0: Heartbeat for group "group_id_CCC" generation id 1 | |
| %7|1649257451.961|SEND|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Sent HeartbeatRequest (v3, 87 bytes @ 0, CorrId 11) | |
| %7|1649257451.984|RECV|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Received HeartbeatResponse (v3, 6 bytes, CorrId 11, rtt 23.04ms) | |
| %7|1649257452.550|RECV|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Received FetchResponse (v11, 72 bytes, CorrId 22, rtt 614.25ms) | |
| %7|1649257452.550|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Topic py_kafka_6 [0] MessageSet size 0, error "Success", MaxOffset 10, LSO 10, Ver 4/4 | |
| %7|1649257452.550|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch topic py_kafka_6 [0] at offset 10 (v4) | |
| %7|1649257452.550|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch 1/1/1 toppar(s) | |
| %7|1649257452.550|SEND|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Sent FetchRequest (v11, 100 bytes @ 0, CorrId 23) | |
| %7|1649257452.632|OFFSET|rdkafka#consumer-1| [thrd:main]: Topic py_kafka_6 [0]: stored offset -1001, committed offset -1001: not including in commit | |
| %7|1649257452.632|DUMP|rdkafka#consumer-1| [thrd:main]: Assignment dump (started_cnt=1, wait_stop_cnt=0) | |
| %7|1649257452.632|DUMP_ALL|rdkafka#consumer-1| [thrd:main]: List with 1 partition(s): | |
| %7|1649257452.632|DUMP_ALL|rdkafka#consumer-1| [thrd:main]: py_kafka_6 [0] offset STORED | |
| %7|1649257452.632|DUMP_PND|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649257452.632|DUMP_QRY|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649257452.632|DUMP_REM|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649257452.632|ASSIGNDONE|rdkafka#consumer-1| [thrd:main]: Group "group_id_CCC": assignment operations done in join-state steady (rebalance rejoin=false) | |
| %7|1649257453.072|RECV|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Received FetchResponse (v11, 72 bytes, CorrId 23, rtt 522.75ms) | |
| %7|1649257453.072|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Topic py_kafka_6 [0] MessageSet size 0, error "Success", MaxOffset 10, LSO 10, Ver 4/4 | |
| %7|1649257453.072|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch topic py_kafka_6 [0] at offset 10 (v4) | |
| %7|1649257453.072|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch 1/1/1 toppar(s) | |
| %7|1649257453.072|SEND|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Sent FetchRequest (v11, 100 bytes @ 0, CorrId 24) | |
| %7|1649257453.779|RECV|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Received FetchResponse (v11, 72 bytes, CorrId 24, rtt 706.30ms) | |
| %7|1649257453.779|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Topic py_kafka_6 [0] MessageSet size 0, error "Success", MaxOffset 10, LSO 10, Ver 4/4 | |
| %7|1649257453.779|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch topic py_kafka_6 [0] at offset 10 (v4) | |
| %7|1649257453.779|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch 1/1/1 toppar(s) | |
| %7|1649257453.779|SEND|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Sent FetchRequest (v11, 100 bytes @ 0, CorrId 25) | |
| %7|1649257454.394|RECV|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Received FetchResponse (v11, 72 bytes, CorrId 25, rtt 614.66ms) | |
| %7|1649257454.394|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Topic py_kafka_6 [0] MessageSet size 0, error "Success", MaxOffset 10, LSO 10, Ver 4/4 | |
| %7|1649257454.394|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch topic py_kafka_6 [0] at offset 10 (v4) | |
| %7|1649257454.394|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch 1/1/1 toppar(s) | |
| %7|1649257454.394|SEND|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Sent FetchRequest (v11, 100 bytes @ 0, CorrId 26) | |
| %7|1649257454.977|HEARTBEAT|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/0: Heartbeat for group "group_id_CCC" generation id 1 | |
| %7|1649257454.977|SEND|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Sent HeartbeatRequest (v3, 87 bytes @ 0, CorrId 12) | |
| %7|1649257454.979|RECV|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Received FetchResponse (v11, 72 bytes, CorrId 26, rtt 585.09ms) | |
| %7|1649257454.979|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Topic py_kafka_6 [0] MessageSet size 0, error "Success", MaxOffset 10, LSO 10, Ver 4/4 | |
| %7|1649257454.979|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch topic py_kafka_6 [0] at offset 10 (v4) | |
| %7|1649257454.979|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch 1/1/1 toppar(s) | |
| %7|1649257454.979|SEND|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Sent FetchRequest (v11, 100 bytes @ 0, CorrId 27) | |
| %7|1649257455.001|RECV|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Received HeartbeatResponse (v3, 6 bytes, CorrId 12, rtt 24.02ms) | |
| %7|1649257455.502|RECV|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Received FetchResponse (v11, 72 bytes, CorrId 27, rtt 523.32ms) | |
| %7|1649257455.502|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Topic py_kafka_6 [0] MessageSet size 0, error "Success", MaxOffset 10, LSO 10, Ver 4/4 | |
| %7|1649257455.502|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch topic py_kafka_6 [0] at offset 10 (v4) | |
| %7|1649257455.502|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch 1/1/1 toppar(s) | |
| %7|1649257455.502|SEND|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Sent FetchRequest (v11, 100 bytes @ 0, CorrId 28) | |
| %7|1649257456.237|RECV|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Received FetchResponse (v11, 72 bytes, CorrId 28, rtt 734.83ms) | |
| %7|1649257456.237|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Topic py_kafka_6 [0] MessageSet size 0, error "Success", MaxOffset 10, LSO 10, Ver 4/4 | |
| %7|1649257456.237|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch topic py_kafka_6 [0] at offset 10 (v4) | |
| %7|1649257456.237|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch 1/1/1 toppar(s) | |
| %7|1649257456.237|SEND|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Sent FetchRequest (v11, 100 bytes @ 0, CorrId 29) | |
| %7|1649257456.763|RECV|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Received FetchResponse (v11, 72 bytes, CorrId 29, rtt 525.96ms) | |
| %7|1649257456.763|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Topic py_kafka_6 [0] MessageSet size 0, error "Success", MaxOffset 10, LSO 10, Ver 4/4 | |
| %7|1649257456.763|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch topic py_kafka_6 [0] at offset 10 (v4) | |
| %7|1649257456.763|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch 1/1/1 toppar(s) | |
| %7|1649257456.763|SEND|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Sent FetchRequest (v11, 100 bytes @ 0, CorrId 30) | |
| %7|1649257457.439|RECV|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Received FetchResponse (v11, 72 bytes, CorrId 30, rtt 676.09ms) | |
| %7|1649257457.439|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Topic py_kafka_6 [0] MessageSet size 0, error "Success", MaxOffset 10, LSO 10, Ver 4/4 | |
| %7|1649257457.439|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch topic py_kafka_6 [0] at offset 10 (v4) | |
| %7|1649257457.439|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch 1/1/1 toppar(s) | |
| %7|1649257457.439|SEND|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Sent FetchRequest (v11, 100 bytes @ 0, CorrId 31) | |
| %7|1649257457.634|OFFSET|rdkafka#consumer-1| [thrd:main]: Topic py_kafka_6 [0]: stored offset -1001, committed offset -1001: not including in commit | |
| %7|1649257457.634|DUMP|rdkafka#consumer-1| [thrd:main]: Assignment dump (started_cnt=1, wait_stop_cnt=0) | |
| %7|1649257457.634|DUMP_ALL|rdkafka#consumer-1| [thrd:main]: List with 1 partition(s): | |
| %7|1649257457.634|DUMP_ALL|rdkafka#consumer-1| [thrd:main]: py_kafka_6 [0] offset STORED | |
| %7|1649257457.634|DUMP_PND|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649257457.634|DUMP_QRY|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649257457.634|DUMP_REM|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649257457.634|ASSIGNDONE|rdkafka#consumer-1| [thrd:main]: Group "group_id_CCC": assignment operations done in join-state steady (rebalance rejoin=false) | |
| %7|1649257457.990|HEARTBEAT|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/0: Heartbeat for group "group_id_CCC" generation id 1 | |
| %7|1649257457.990|SEND|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Sent HeartbeatRequest (v3, 87 bytes @ 0, CorrId 13) | |
| %7|1649257457.992|RECV|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Received FetchResponse (v11, 72 bytes, CorrId 31, rtt 553.05ms) | |
| %7|1649257457.992|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Topic py_kafka_6 [0] MessageSet size 0, error "Success", MaxOffset 10, LSO 10, Ver 4/4 | |
| %7|1649257457.992|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch topic py_kafka_6 [0] at offset 10 (v4) | |
| %7|1649257457.992|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch 1/1/1 toppar(s) | |
| %7|1649257457.993|SEND|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Sent FetchRequest (v11, 100 bytes @ 0, CorrId 32) | |
| %7|1649257458.014|RECV|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Received HeartbeatResponse (v3, 6 bytes, CorrId 13, rtt 23.83ms) | |
| %7|1649257458.640|RECV|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Received FetchResponse (v11, 72 bytes, CorrId 32, rtt 647.89ms) | |
| %7|1649257458.640|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Topic py_kafka_6 [0] MessageSet size 0, error "Success", MaxOffset 10, LSO 10, Ver 4/4 | |
| %7|1649257458.641|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch topic py_kafka_6 [0] at offset 10 (v4) | |
| %7|1649257458.641|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch 1/1/1 toppar(s) | |
| %7|1649257458.641|SEND|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Sent FetchRequest (v11, 100 bytes @ 0, CorrId 33) | |
| %7|1649257459.167|RECV|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Received FetchResponse (v11, 72 bytes, CorrId 33, rtt 526.35ms) | |
| %7|1649257459.167|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Topic py_kafka_6 [0] MessageSet size 0, error "Success", MaxOffset 10, LSO 10, Ver 4/4 | |
| %7|1649257459.167|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch topic py_kafka_6 [0] at offset 10 (v4) | |
| %7|1649257459.167|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch 1/1/1 toppar(s) | |
| %7|1649257459.167|SEND|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Sent FetchRequest (v11, 100 bytes @ 0, CorrId 34) | |
| %7|1649257459.923|RECV|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Received FetchResponse (v11, 72 bytes, CorrId 34, rtt 755.64ms) | |
| %7|1649257459.923|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Topic py_kafka_6 [0] MessageSet size 0, error "Success", MaxOffset 10, LSO 10, Ver 4/4 | |
| %7|1649257459.923|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch topic py_kafka_6 [0] at offset 10 (v4) | |
| %7|1649257459.923|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch 1/1/1 toppar(s) | |
| %7|1649257459.923|SEND|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Sent FetchRequest (v11, 100 bytes @ 0, CorrId 35) | |
| %7|1649257460.538|RECV|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Received FetchResponse (v11, 72 bytes, CorrId 35, rtt 615.59ms) | |
| %7|1649257460.538|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Topic py_kafka_6 [0] MessageSet size 0, error "Success", MaxOffset 10, LSO 10, Ver 4/4 | |
| %7|1649257460.538|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch topic py_kafka_6 [0] at offset 10 (v4) | |
| %7|1649257460.538|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch 1/1/1 toppar(s) | |
| %7|1649257460.538|SEND|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Sent FetchRequest (v11, 100 bytes @ 0, CorrId 36) | |
| %7|1649257461.005|HEARTBEAT|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/0: Heartbeat for group "group_id_CCC" generation id 1 | |
| %7|1649257461.006|SEND|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Sent HeartbeatRequest (v3, 87 bytes @ 0, CorrId 14) | |
| %7|1649257461.031|RECV|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Received HeartbeatResponse (v3, 6 bytes, CorrId 14, rtt 24.89ms) | |
| %7|1649257461.062|RECV|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Received FetchResponse (v11, 72 bytes, CorrId 36, rtt 523.51ms) | |
| %7|1649257461.062|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Topic py_kafka_6 [0] MessageSet size 0, error "Success", MaxOffset 10, LSO 10, Ver 4/4 | |
| %7|1649257461.062|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch topic py_kafka_6 [0] at offset 10 (v4) | |
| %7|1649257461.062|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch 1/1/1 toppar(s) | |
| %7|1649257461.062|SEND|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Sent FetchRequest (v11, 100 bytes @ 0, CorrId 37) | |
| %7|1649257461.586|RECV|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Received FetchResponse (v11, 72 bytes, CorrId 37, rtt 523.76ms) | |
| %7|1649257461.586|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Topic py_kafka_6 [0] MessageSet size 0, error "Success", MaxOffset 10, LSO 10, Ver 4/4 | |
| %7|1649257461.586|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch topic py_kafka_6 [0] at offset 10 (v4) | |
| %7|1649257461.586|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch 1/1/1 toppar(s) | |
| %7|1649257461.586|SEND|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Sent FetchRequest (v11, 100 bytes @ 0, CorrId 38) | |
| %7|1649257462.301|RECV|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Received FetchResponse (v11, 72 bytes, CorrId 38, rtt 714.66ms) | |
| %7|1649257462.301|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Topic py_kafka_6 [0] MessageSet size 0, error "Success", MaxOffset 10, LSO 10, Ver 4/4 | |
| %7|1649257462.301|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch topic py_kafka_6 [0] at offset 10 (v4) | |
| %7|1649257462.301|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch 1/1/1 toppar(s) | |
| %7|1649257462.301|SEND|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Sent FetchRequest (v11, 100 bytes @ 0, CorrId 39) | |
| %7|1649257462.634|OFFSET|rdkafka#consumer-1| [thrd:main]: Topic py_kafka_6 [0]: stored offset -1001, committed offset -1001: not including in commit | |
| %7|1649257462.634|DUMP|rdkafka#consumer-1| [thrd:main]: Assignment dump (started_cnt=1, wait_stop_cnt=0) | |
| %7|1649257462.634|DUMP_ALL|rdkafka#consumer-1| [thrd:main]: List with 1 partition(s): | |
| %7|1649257462.634|DUMP_ALL|rdkafka#consumer-1| [thrd:main]: py_kafka_6 [0] offset STORED | |
| %7|1649257462.634|DUMP_PND|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649257462.634|DUMP_QRY|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649257462.634|DUMP_REM|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649257462.634|ASSIGNDONE|rdkafka#consumer-1| [thrd:main]: Group "group_id_CCC": assignment operations done in join-state steady (rebalance rejoin=false) | |
| %7|1649257462.824|RECV|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Received FetchResponse (v11, 72 bytes, CorrId 39, rtt 522.94ms) | |
| %7|1649257462.824|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Topic py_kafka_6 [0] MessageSet size 0, error "Success", MaxOffset 10, LSO 10, Ver 4/4 | |
| %7|1649257462.824|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch topic py_kafka_6 [0] at offset 10 (v4) | |
| %7|1649257462.824|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch 1/1/1 toppar(s) | |
| %7|1649257462.824|SEND|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Sent FetchRequest (v11, 100 bytes @ 0, CorrId 40) | |
| %7|1649257463.425|RECV|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Received FetchResponse (v11, 72 bytes, CorrId 40, rtt 601.32ms) | |
| %7|1649257463.425|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Topic py_kafka_6 [0] MessageSet size 0, error "Success", MaxOffset 10, LSO 10, Ver 4/4 | |
| %7|1649257463.425|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch topic py_kafka_6 [0] at offset 10 (v4) | |
| %7|1649257463.425|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch 1/1/1 toppar(s) | |
| %7|1649257463.425|SEND|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Sent FetchRequest (v11, 100 bytes @ 0, CorrId 41) | |
| %7|1649257464.013|HEARTBEAT|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/0: Heartbeat for group "group_id_CCC" generation id 1 | |
| %7|1649257464.013|SEND|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Sent HeartbeatRequest (v3, 87 bytes @ 0, CorrId 15) | |
| %7|1649257464.037|RECV|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Received HeartbeatResponse (v3, 6 bytes, CorrId 15, rtt 23.93ms) | |
| %7|1649257464.531|RECV|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Received FetchResponse (v11, 72 bytes, CorrId 41, rtt 1105.40ms) | |
| %7|1649257464.531|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Topic py_kafka_6 [0] MessageSet size 0, error "Success", MaxOffset 10, LSO 10, Ver 4/4 | |
| %7|1649257464.531|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch topic py_kafka_6 [0] at offset 10 (v4) | |
| %7|1649257464.531|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch 1/1/1 toppar(s) | |
| %7|1649257464.531|SEND|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Sent FetchRequest (v11, 100 bytes @ 0, CorrId 42) | |
| %7|1649257465.145|RECV|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Received FetchResponse (v11, 72 bytes, CorrId 42, rtt 614.30ms) | |
| %7|1649257465.145|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Topic py_kafka_6 [0] MessageSet size 0, error "Success", MaxOffset 10, LSO 10, Ver 4/4 | |
| %7|1649257465.145|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch topic py_kafka_6 [0] at offset 10 (v4) | |
| %7|1649257465.145|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch 1/1/1 toppar(s) | |
| %7|1649257465.145|SEND|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Sent FetchRequest (v11, 100 bytes @ 0, CorrId 43) | |
| %7|1649257465.760|RECV|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Received FetchResponse (v11, 72 bytes, CorrId 43, rtt 614.80ms) | |
| %7|1649257465.760|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Topic py_kafka_6 [0] MessageSet size 0, error "Success", MaxOffset 10, LSO 10, Ver 4/4 | |
| %7|1649257465.760|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch topic py_kafka_6 [0] at offset 10 (v4) | |
| %7|1649257465.760|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch 1/1/1 toppar(s) | |
| %7|1649257465.760|SEND|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Sent FetchRequest (v11, 100 bytes @ 0, CorrId 44) | |
| %7|1649257466.374|RECV|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Received FetchResponse (v11, 72 bytes, CorrId 44, rtt 613.92ms) | |
| %7|1649257466.374|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Topic py_kafka_6 [0] MessageSet size 0, error "Success", MaxOffset 10, LSO 10, Ver 4/4 | |
| %7|1649257466.374|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch topic py_kafka_6 [0] at offset 10 (v4) | |
| %7|1649257466.374|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch 1/1/1 toppar(s) | |
| %7|1649257466.374|SEND|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Sent FetchRequest (v11, 100 bytes @ 0, CorrId 45) | |
| %7|1649257466.988|RECV|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Received FetchResponse (v11, 72 bytes, CorrId 45, rtt 614.32ms) | |
| %7|1649257466.988|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Topic py_kafka_6 [0] MessageSet size 0, error "Success", MaxOffset 10, LSO 10, Ver 4/4 | |
| %7|1649257466.988|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch topic py_kafka_6 [0] at offset 10 (v4) | |
| %7|1649257466.988|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch 1/1/1 toppar(s) | |
| %7|1649257466.988|SEND|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Sent FetchRequest (v11, 100 bytes @ 0, CorrId 46) | |
| %7|1649257467.027|HEARTBEAT|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/0: Heartbeat for group "group_id_CCC" generation id 1 | |
| %7|1649257467.027|SEND|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Sent HeartbeatRequest (v3, 87 bytes @ 0, CorrId 16) | |
| %7|1649257467.050|RECV|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Received HeartbeatResponse (v3, 6 bytes, CorrId 16, rtt 22.94ms) | |
| %7|1649257467.512|RECV|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Received FetchResponse (v11, 72 bytes, CorrId 46, rtt 524.22ms) | |
| %7|1649257467.513|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Topic py_kafka_6 [0] MessageSet size 0, error "Success", MaxOffset 10, LSO 10, Ver 4/4 | |
| %7|1649257467.513|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch topic py_kafka_6 [0] at offset 10 (v4) | |
| %7|1649257467.513|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Fetch 1/1/1 toppar(s) | |
| %7|1649257467.513|SEND|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Sent FetchRequest (v11, 100 bytes @ 0, CorrId 47) | |
| ^C%7|1649257467.579|CLOSE|rdkafka#consumer-1| [thrd:app]: Closing consumer | |
| %7|1649257467.579|CLOSE|rdkafka#consumer-1| [thrd:app]: Waiting for close events | |
| %7|1649257467.579|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "group_id_CCC" received op TERMINATE in state up (join-state steady) | |
| %7|1649257467.579|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Terminating group "group_id_CCC" in state up with 1 partition(s) | |
| %7|1649257467.579|UNSUBSCRIBE|rdkafka#consumer-1| [thrd:main]: Group "group_id_CCC": unsubscribe from current subscription of size 1 (leave group=true, has joined=true, rdkafka-a930626e-1767-49e8-9aa7-0bc1d2a5701a, join-state steady) | |
| %7|1649257467.579|SUBSCRIPTION|rdkafka#consumer-1| [thrd:main]: Group "group_id_CCC": clearing subscribed topics list (1) | |
| %7|1649257467.579|SUBSCRIPTION|rdkafka#consumer-1| [thrd:main]: Group "group_id_CCC": effective subscription list changed from 1 to 0 topic(s): | |
| %7|1649257467.579|GRPLEADER|rdkafka#consumer-1| [thrd:main]: Group "group_id_CCC": resetting group leader info: unsubscribe | |
| %7|1649257467.579|REBALANCE|rdkafka#consumer-1| [thrd:main]: Group "group_id_CCC" initiating rebalance (EAGER) in state up (join-state steady) with 1 assigned partition(s): unsubscribe | |
| %7|1649257467.579|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "group_id_CCC" changed join state steady -> wait-unassign-call (state up) | |
| %7|1649257467.579|ASSIGN|rdkafka#consumer-1| [thrd:main]: Group "group_id_CCC": delegating revoke of 1 partition(s) to application on queue rd_kafka_consumer_close: unsubscribe | |
| %7|1649257467.579|PAUSE|rdkafka#consumer-1| [thrd:main]: Pausing fetchers for 1 assigned partition(s): rebalance | |
| %7|1649257467.579|PAUSE|rdkafka#consumer-1| [thrd:main]: Library pausing 1 partition(s) | |
| %7|1649257467.579|BARRIER|rdkafka#consumer-1| [thrd:main]: py_kafka_6 [0]: rd_kafka_toppar_op_pause_resume:2449: new version barrier v5 | |
| %7|1649257467.579|PAUSE|rdkafka#consumer-1| [thrd:main]: Pause py_kafka_6 [0] (v5) | |
| %7|1649257467.579|ASSIGNMENT|rdkafka#consumer-1| [thrd:main]: Group "group_id_CCC": clearing group assignment | |
| %7|1649257467.579|DUMP|rdkafka#consumer-1| [thrd:main]: Assignment dump (started_cnt=1, wait_stop_cnt=0) | |
| %7|1649257467.579|DUMP_ALL|rdkafka#consumer-1| [thrd:main]: List with 1 partition(s): | |
| %7|1649257467.579|DUMP_ALL|rdkafka#consumer-1| [thrd:main]: py_kafka_6 [0] offset STORED | |
| %7|1649257467.579|DUMP_PND|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649257467.579|DUMP_QRY|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649257467.579|DUMP_REM|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649257467.579|ASSIGNDONE|rdkafka#consumer-1| [thrd:main]: Group "group_id_CCC": assignment operations done in join-state wait-unassign-call (rebalance rejoin=false) | |
| %7|1649257467.579|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "group_id_CCC": waiting for assign call, 1 toppar(s), 0 commit(s) (state up, join-state wait-unassign-call) before terminating | |
| %7|1649257467.579|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "group_id_CCC": waiting for assign call, 1 toppar(s), 0 commit(s) (state up, join-state wait-unassign-call) before terminating | |
| %7|1649257467.579|OP|rdkafka#consumer-1| [thrd:main]: py_kafka_6 [0] received op PAUSE (v5) in fetch-state active (opv4) | |
| %7|1649257467.579|PAUSE|rdkafka#consumer-1| [thrd:main]: Pause py_kafka_6 [0]: at offset 10 (state active, v5) | |
| %7|1649257467.579|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "group_id_CCC" received op GET_REBALANCE_PROTOCOL in state up (join-state wait-unassign-call) | |
| %7|1649257467.579|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "group_id_CCC": waiting for assign call, 1 toppar(s), 0 commit(s) (state up, join-state wait-unassign-call) before terminating | |
| %7|1649257467.579|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "group_id_CCC" received op ASSIGN in state up (join-state wait-unassign-call) | |
| %7|1649257467.579|ASSIGN|rdkafka#consumer-1| [thrd:main]: Group "group_id_CCC": Consumer is terminating: treating assign as unassign | |
| %7|1649257467.579|CLEARASSIGN|rdkafka#consumer-1| [thrd:main]: Clearing current assignment of 1 partition(s) | |
| %7|1649257467.579|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "group_id_CCC" changed join state wait-unassign-call -> wait-unassign-to-complete (state up) | |
| %7|1649257467.579|DUMP|rdkafka#consumer-1| [thrd:main]: Assignment dump (started_cnt=1, wait_stop_cnt=0) | |
| %7|1649257467.579|DUMP_ALL|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649257467.579|DUMP_PND|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649257467.579|DUMP_QRY|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649257467.579|DUMP_REM|rdkafka#consumer-1| [thrd:main]: List with 1 partition(s): | |
| %7|1649257467.579|DUMP_REM|rdkafka#consumer-1| [thrd:main]: py_kafka_6 [0] offset STORED | |
| %7|1649257467.579|BARRIER|rdkafka#consumer-1| [thrd:main]: py_kafka_6 [0]: rd_kafka_toppar_op_fetch_stop:2390: new version barrier v6 | |
| %7|1649257467.579|CONSUMER|rdkafka#consumer-1| [thrd:main]: Stop consuming py_kafka_6 [0] (v6) | |
| %7|1649257467.579|BARRIER|rdkafka#consumer-1| [thrd:main]: py_kafka_6 [0]: rd_kafka_toppar_op_pause_resume:2449: new version barrier v7 | |
| %7|1649257467.579|RESUME|rdkafka#consumer-1| [thrd:main]: Resume py_kafka_6 [0] (v7) | |
| %7|1649257467.579|DESP|rdkafka#consumer-1| [thrd:main]: Removing (un)desired topic py_kafka_6 [0] | |
| %7|1649257467.579|REMOVE|rdkafka#consumer-1| [thrd:main]: Removing py_kafka_6 [0] from assignment (started=true, pending=false, queried=false, stored offset=INVALID) | |
| %7|1649257467.579|REMOVE|rdkafka#consumer-1| [thrd:main]: Served 1 removed partition(s), with 0 offset(s) to commit | |
| %7|1649257467.579|ASSIGNMENT|rdkafka#consumer-1| [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 | |
| %7|1649257467.579|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "group_id_CCC": waiting for 1 toppar(s), assignment in progress, 0 commit(s) (state up, join-state wait-unassign-to-complete) before terminating | |
| %7|1649257467.579|OP|rdkafka#consumer-1| [thrd:main]: py_kafka_6 [0] received op FETCH_STOP (v6) in fetch-state active (opv5) | |
| %7|1649257467.579|FETCH|rdkafka#consumer-1| [thrd:main]: Stopping fetch for py_kafka_6 [0] in state active (v6) | |
| %7|1649257467.579|PARTSTATE|rdkafka#consumer-1| [thrd:main]: Partition py_kafka_6 [0] changed fetch state active -> stopping | |
| %7|1649257467.579|STORETERM|rdkafka#consumer-1| [thrd:main]: py_kafka_6 [0]: offset store terminating | |
| %7|1649257467.579|PARTSTATE|rdkafka#consumer-1| [thrd:main]: Partition py_kafka_6 [0] changed fetch state stopping -> stopped | |
| %7|1649257467.579|OP|rdkafka#consumer-1| [thrd:main]: py_kafka_6 [0] received op PAUSE (v7) in fetch-state stopped (opv6) | |
| %7|1649257467.579|RESUME|rdkafka#consumer-1| [thrd:main]: Not resuming stopped py_kafka_6 [0]: at offset 10 (state stopped, v7) | |
| %7|1649257467.579|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "group_id_CCC": waiting for 1 toppar(s), assignment in progress, 0 commit(s) (state up, join-state wait-unassign-to-complete) before terminating | |
| %7|1649257467.580|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "group_id_CCC" received op PARTITION_LEAVE in state up (join-state wait-unassign-to-complete) for py_kafka_6 [0] | |
| %7|1649257467.580|PARTDEL|rdkafka#consumer-1| [thrd:main]: Group "group_id_CCC": delete py_kafka_6 [0] | |
| %7|1649257467.580|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "group_id_CCC": waiting for 0 toppar(s), assignment in progress, 0 commit(s) (state up, join-state wait-unassign-to-complete) before terminating | |
| %7|1649257467.580|STOPSERVE|rdkafka#consumer-1| [thrd:main]: All partitions awaiting stop are now stopped: serving assignment | |
| %7|1649257467.580|DUMP|rdkafka#consumer-1| [thrd:main]: Assignment dump (started_cnt=0, wait_stop_cnt=0) | |
| %7|1649257467.580|DUMP_ALL|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649257467.580|DUMP_PND|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649257467.580|DUMP_QRY|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649257467.580|DUMP_REM|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s): | |
| %7|1649257467.580|ASSIGNDONE|rdkafka#consumer-1| [thrd:main]: Group "group_id_CCC": assignment operations done in join-state wait-unassign-to-complete (rebalance rejoin=false) | |
| %7|1649257467.580|UNASSIGN|rdkafka#consumer-1| [thrd:main]: Group "group_id_CCC": unassign done in state up (join-state wait-unassign-to-complete) | |
| %7|1649257467.580|MEMBERID|rdkafka#consumer-1| [thrd:main]: Group "group_id_CCC": updating member id "rdkafka-a930626e-1767-49e8-9aa7-0bc1d2a5701a" -> "" | |
| %7|1649257467.580|LEAVE|rdkafka#consumer-1| [thrd:main]: Group "group_id_CCC": leave (in state up) | |
| %7|1649257467.580|LEAVE|rdkafka#consumer-1| [thrd:main]: 10.6.96.47:9092/0: Leaving group | |
| %7|1649257467.580|NOREJOIN|rdkafka#consumer-1| [thrd:main]: Group "group_id_CCC": Not rejoining group without an assignment: Unassignment done: no subscribed topics | |
| %7|1649257467.580|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "group_id_CCC" changed join state wait-unassign-to-complete -> init (state up) | |
| %7|1649257467.580|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "group_id_CCC": waiting for 0 toppar(s), 0 commit(s), wait-leave, (state up, join-state init) before terminating | |
| %7|1649257467.580|SEND|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Sent LeaveGroupRequest (v1, 81 bytes @ 0, CorrId 17) | |
| %7|1649257467.604|RECV|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Received LeaveGroupResponse (v1, 6 bytes, CorrId 17, rtt 24.55ms) | |
| %7|1649257467.604|LEAVEGROUP|rdkafka#consumer-1| [thrd:main]: LeaveGroup response received in state up | |
| %7|1649257467.604|CGRPSTATE|rdkafka#consumer-1| [thrd:main]: Group "group_id_CCC" changed state up -> term (join-state init) | |
| %7|1649257467.604|BROADCAST|rdkafka#consumer-1| [thrd:main]: Broadcasting state change | |
| %7|1649257467.604|ASSIGNMENT|rdkafka#consumer-1| [thrd:main]: Group "group_id_CCC": clearing group assignment | |
| %7|1649257467.604|COORDCLEAR|rdkafka#consumer-1| [thrd:main]: Group "group_id_CCC" broker 10.6.96.47:9092/0 is no longer coordinator | |
| %7|1649257467.604|NODENAME|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/0: Broker nodename changed from "10.6.96.47:9092" to "" | |
| %7|1649257467.604|NODEID|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/0: Broker nodeid changed from 0 to -1 | |
| %7|1649257467.604|CLOSE|rdkafka#consumer-1| [thrd:app]: Consumer closed | |
| %7|1649257467.604|DESTROY|rdkafka#consumer-1| [thrd:app]: Terminating instance (destroy flags none (0x0)) | |
| %7|1649257467.604|TERMINATE|rdkafka#consumer-1| [thrd:app]: Terminating consumer group handler | |
| %7|1649257467.604|CLOSE|rdkafka#consumer-1| [thrd:app]: Closing consumer | |
| %7|1649257467.605|CLOSE|rdkafka#consumer-1| [thrd:app]: Waiting for close events | |
| %7|1649257467.605|CLOSE|rdkafka#consumer-1| [thrd:app]: Consumer closed | |
| %7|1649257467.605|TERMINATE|rdkafka#consumer-1| [thrd:app]: Interrupting timers | |
| %7|1649257467.605|TERMINATE|rdkafka#consumer-1| [thrd:app]: Sending TERMINATE to internal main thread | |
| %7|1649257467.605|FAIL|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Closing connection due to nodename change (after 24820ms in state UP) (_TRANSPORT) | |
| %7|1649257467.605|STATE|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Broker changed state UP -> DOWN | |
| %7|1649257467.605|BROADCAST|rdkafka#consumer-1| [thrd:GroupCoordinator]: Broadcasting state change | |
| %7|1649257467.605|TERMINATE|rdkafka#consumer-1| [thrd:main]: Internal main thread terminating | |
| %7|1649257467.605|TERMINATE|rdkafka#consumer-1| [thrd:app]: Joining internal main thread | |
| %7|1649257467.605|DESTROY|rdkafka#consumer-1| [thrd:main]: Destroy internal | |
| %7|1649257467.605|BROADCAST|rdkafka#consumer-1| [thrd:main]: Broadcasting state change | |
| %7|1649257467.605|DESTROY|rdkafka#consumer-1| [thrd:main]: Removing all topics | |
| %7|1649257467.605|PARTCNT|rdkafka#consumer-1| [thrd:main]: Topic py_kafka_6 partition count changed from 1 to 0 | |
| %7|1649257467.605|REMOVE|rdkafka#consumer-1| [thrd:main]: py_kafka_6 [0] no longer reported in metadata | |
| %7|1649257467.605|BUFQ|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Purging bufq with 0 buffers | |
| %7|1649257467.605|BUFQ|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Purging bufq with 0 buffers | |
| %7|1649257467.605|BUFQ|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Updating 0 buffers on connection reset | |
| %7|1649257467.605|BRKTERM|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: terminating: broker still has 3 refcnt(s), 0 buffer(s), 0 partition(s) | |
| %7|1649257467.605|METADATA|rdkafka#consumer-1| [thrd:GroupCoordinator]: Requesting metadata for 1/1 topics: broker down | |
| %7|1649257467.605|BRKMIGR|rdkafka#consumer-1| [thrd:main]: py_kafka_6 [0] 0x7fabf82564c0 sending final LEAVE for removal by 10.6.96.47:9092/0 | |
| %7|1649257467.605|METADATA|rdkafka#consumer-1| [thrd:GroupCoordinator]: 10.6.96.47:9092/0: Request metadata for 1 topic(s): broker down | |
| %7|1649257467.605|TOPPARREMOVE|rdkafka#consumer-1| [thrd:main]: Removing toppar py_kafka_6 [-1] 0x7fabf82560d0 | |
| %7|1649257467.605|DESTROY|rdkafka#consumer-1| [thrd:main]: py_kafka_6 [-1]: 0x7fabf82560d0 DESTROY_FINAL | |
| %7|1649257467.605|TERMINATE|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Handle is terminating in state DOWN: 3 refcnts (0x7fabf98251a0), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf | |
| %7|1649257467.605|STATE|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Broker changed state DOWN -> INIT | |
| %7|1649257467.605|BROADCAST|rdkafka#consumer-1| [thrd:GroupCoordinator]: Broadcasting state change | |
| %7|1649257467.605|DESTROY|rdkafka#consumer-1| [thrd:main]: Sending TERMINATE to 10.6.96.47:9092/0 | |
| %7|1649257467.605|FETCH|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Topic py_kafka_6 [0] in state stopped at offset 10 (0/100000 msgs, 0/65536 kb queued, opv 4) is not fetchable: forced removal | |
| %7|1649257467.605|DESTROY|rdkafka#consumer-1| [thrd:main]: Sending TERMINATE to GroupCoordinator | |
| %7|1649257467.605|FETCHADD|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Removed py_kafka_6 [0] from fetch list (0 entries, opv 4): forced removal | |
| %7|1649257467.605|TOPBRK|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Topic py_kafka_6 [0]: leaving broker (0 messages in xmitq, next broker (none), rktp 0x7fabf82564c0) | |
| %7|1649257467.605|TOPBRK|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Topic py_kafka_6 [0]: no next broker, failing 0 message(s) in partition queue | |
| %7|1649257467.605|BROADCAST|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: Broadcasting state change | |
| %7|1649257467.605|TERMINATE|rdkafka#consumer-1| [thrd:main]: Purging reply queue | |
| %7|1649257467.605|TERMINATE|rdkafka#consumer-1| [thrd:main]: Decommissioning internal broker | |
| %7|1649257467.605|TERM|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Received TERMINATE op in state UP: 5 refcnts, 0 toppar(s), 0 active toppar(s), 1 outbufs, 1 waitresps, 0 retrybufs | |
| %7|1649257467.605|TERM|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Received TERMINATE op in state INIT: 2 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs | |
| %7|1649257467.605|FAIL|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Client is terminating (after 0ms in state INIT) (_DESTROY) | |
| %7|1649257467.605|TERMINATE|rdkafka#consumer-1| [thrd:main]: Join 3 broker thread(s) | |
| %7|1649257467.605|TERM|rdkafka#consumer-1| [thrd::0/internal]: :0/internal: Received TERMINATE op in state INIT: 2 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs | |
| %7|1649257467.605|FAIL|rdkafka#consumer-1| [thrd::0/internal]: :0/internal: Client is terminating (after 24973ms in state INIT) (_DESTROY) | |
| %7|1649257467.605|STATE|rdkafka#consumer-1| [thrd::0/internal]: :0/internal: Broker changed state INIT -> DOWN | |
| %7|1649257467.605|STATE|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Broker changed state INIT -> DOWN | |
| %7|1649257467.605|FAIL|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Client is terminating (after 24895ms in state UP) (_DESTROY) | |
| %7|1649257467.605|STATE|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Broker changed state UP -> DOWN | |
| %7|1649257467.605|BROADCAST|rdkafka#consumer-1| [thrd:GroupCoordinator]: Broadcasting state change | |
| %7|1649257467.605|BUFQ|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Purging bufq with 0 buffers | |
| %7|1649257467.605|BUFQ|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Purging bufq with 0 buffers | |
| %7|1649257467.605|BUFQ|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Updating 0 buffers on connection reset | |
| %7|1649257467.605|BRKTERM|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: terminating: broker still has 2 refcnt(s), 0 buffer(s), 0 partition(s) | |
| %7|1649257467.605|TERMINATE|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Handle is terminating in state DOWN: 1 refcnts (0x7fabf98251a0), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf | |
| %7|1649257467.605|FAIL|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Broker handle is terminating (after 0ms in state DOWN) (_DESTROY) | |
| %7|1649257467.605|BUFQ|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Purging bufq with 0 buffers | |
| %7|1649257467.605|BROADCAST|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: Broadcasting state change | |
| %7|1649257467.605|BUFQ|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Purging bufq with 1 buffers | |
| %7|1649257467.605|BROADCAST|rdkafka#consumer-1| [thrd::0/internal]: Broadcasting state change | |
| %7|1649257467.605|BUFQ|rdkafka#consumer-1| [thrd::0/internal]: :0/internal: Purging bufq with 0 buffers | |
| %7|1649257467.605|BUFQ|rdkafka#consumer-1| [thrd::0/internal]: :0/internal: Purging bufq with 0 buffers | |
| %7|1649257467.605|TOPPARREMOVE|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: Removing toppar py_kafka_6 [0] 0x7fabf82564c0 | |
| %7|1649257467.605|BUFQ|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Purging bufq with 0 buffers | |
| %7|1649257467.605|BUFQ|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Updating 0 buffers on connection reset | |
| %7|1649257467.605|DESTROY|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: py_kafka_6 [0]: 0x7fabf82564c0 DESTROY_FINAL | |
| %7|1649257467.605|BUFQ|rdkafka#consumer-1| [thrd::0/internal]: :0/internal: Updating 0 buffers on connection reset | |
| %7|1649257467.606|BRKTERM|rdkafka#consumer-1| [thrd::0/internal]: :0/internal: terminating: broker still has 2 refcnt(s), 0 buffer(s), 0 partition(s) | |
| %7|1649257467.606|BUFQ|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Purging bufq with 1 buffers | |
| %7|1649257467.606|BUFQ|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Updating 0 buffers on connection reset | |
| %7|1649257467.606|BRKTERM|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: terminating: broker still has 2 refcnt(s), 0 buffer(s), 0 partition(s) | |
| %7|1649257467.606|TERMINATE|rdkafka#consumer-1| [thrd::0/internal]: :0/internal: Handle is terminating in state DOWN: 1 refcnts (0x7fabf98137a0), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf | |
| %7|1649257467.606|FAIL|rdkafka#consumer-1| [thrd::0/internal]: :0/internal: Broker handle is terminating (after 0ms in state DOWN) (_DESTROY) | |
| %7|1649257467.606|BUFQ|rdkafka#consumer-1| [thrd::0/internal]: :0/internal: Purging bufq with 0 buffers | |
| %7|1649257467.606|BUFQ|rdkafka#consumer-1| [thrd::0/internal]: :0/internal: Purging bufq with 0 buffers | |
| %7|1649257467.606|BUFQ|rdkafka#consumer-1| [thrd::0/internal]: :0/internal: Updating 0 buffers on connection reset | |
| %7|1649257467.606|TERMINATE|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Handle is terminating in state DOWN: 1 refcnts (0x7fabf98145a0), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf | |
| %7|1649257467.606|FAIL|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Broker handle is terminating (after 0ms in state DOWN) (_DESTROY) | |
| %7|1649257467.606|BUFQ|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Purging bufq with 0 buffers | |
| %7|1649257467.606|BUFQ|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Purging bufq with 0 buffers | |
| %7|1649257467.606|BUFQ|rdkafka#consumer-1| [thrd:10.6.96.47:9092/bootstrap]: 10.6.96.47:9092/0: Updating 0 buffers on connection reset | |
| %7|1649257467.606|TERMINATE|rdkafka#consumer-1| [thrd:main]: Internal main thread termination done | |
| %7|1649257467.606|TERMINATE|rdkafka#consumer-1| [thrd:app]: Destroying op queues | |
| %7|1649257467.606|TERMINATE|rdkafka#consumer-1| [thrd:app]: Destroying cgrp | |
| %7|1649257467.606|MEMBERID|rdkafka#consumer-1| [thrd:app]: Group "group_id_CCC": updating member id "" -> "(not-set)" | |
| %7|1649257467.606|TERMINATE|rdkafka#consumer-1| [thrd:app]: Termination done: freeing resources | |
| ======================== | |
| MANUALLY CTRL+C PROGRAM | |
| ======================== |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment