Created
May 3, 2020 06:05
-
-
Save benesch/787791fa96cc75660ecb29cd37d49ddc to your computer and use it in GitHub Desktop.
This file contains hidden or 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
| May 03 00:40:46.542 DEBUG librdkafka: librdkafka: MEMBERID [thrd:app]: Group "materialize-kafka-u1/u2": updating member id "(not-set)" -> "" | |
| May 03 00:40:46.542 DEBUG librdkafka: librdkafka: WAKEUPFD [thrd:app]: GroupCoordinator: Enabled low-latency ops queue wake-ups | |
| May 03 00:40:46.542 DEBUG librdkafka: librdkafka: BROKER [thrd:app]: GroupCoordinator: Added new broker with NodeId -1 | |
| May 03 00:40:46.542 DEBUG librdkafka: librdkafka: WAKEUPFD [thrd:app]: localhost:9092/bootstrap: Enabled low-latency ops queue wake-ups | |
| May 03 00:40:46.542 DEBUG librdkafka: librdkafka: BROKER [thrd:app]: localhost:9092/bootstrap: Added new broker with NodeId -1 | |
| May 03 00:40:46.542 DEBUG librdkafka: librdkafka: INIT [thrd:app]: librdkafka v1.4.2 (0x10402ff) materialized#consumer-3 initialized (builtin.features gzip,snappy,ssl,sasl,regex,lz4,sasl_gssapi,sasl_plain,sasl_scram,plugins,sasl_oauthbearer, CMAKE GNU GNU PKGCONFIG HDRHISTOGRAM ZLIB LIBDL PLUGINS SSL SASL_SCRAM SASL_OAUTHBEARER SASL_CYRUS C11THREADS CRC32C_HW SNAPPY SOCKEM, debug 0xfffff) | |
| May 03 00:40:46.542 DEBUG librdkafka: librdkafka: BRKMAIN [thrd:GroupCoordinator]: GroupCoordinator: Enter main broker thread | |
| May 03 00:40:46.543 DEBUG librdkafka: librdkafka: BRKMAIN [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enter main broker thread | |
| May 03 00:40:46.543 DEBUG librdkafka: librdkafka: BRKMAIN [thrd::0/internal]: :0/internal: Enter main broker thread | |
| May 03 00:40:46.543 DEBUG librdkafka: librdkafka: BRKMAIN [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: rkb_state: INIT | |
| May 03 00:40:46.543 DEBUG librdkafka: librdkafka: BRKMAIN [thrd:GroupCoordinator]: GroupCoordinator: rkb_state: INIT | |
| May 03 00:40:46.543 DEBUG librdkafka: librdkafka: BRKMAIN [thrd::0/internal]: :0/internal: rkb_state: INIT | |
| May 03 00:40:46.543 DEBUG librdkafka: librdkafka: CGRPOP [thrd:main]: Group "materialize-kafka-u1/u2" received op SUBSCRIBE (v0) in state init (join state init, v1 vs 0) | |
| May 03 00:40:46.543 DEBUG librdkafka: librdkafka: SUBSCRIBE [thrd:main]: Group "materialize-kafka-u1/u2": subscribe to new subscription of 1 topics (join state init) | |
| May 03 00:40:46.543 DEBUG librdkafka: librdkafka: UNSUBSCRIBE [thrd:main]: Group "materialize-kafka-u1/u2": unsubscribe from current unset subscription of 0 topics (leave group=no, join state init, v1) | |
| May 03 00:40:46.543 DEBUG librdkafka: librdkafka: GRPLEADER [thrd:main]: Group "materialize-kafka-u1/u2": resetting group leader info: unsubscribe | |
| May 03 00:40:46.543 DEBUG librdkafka: librdkafka: REBALANCE [thrd:main]: Group "materialize-kafka-u1/u2" is rebalancing in state init (join-state init) without assignment: unsubscribe | |
| May 03 00:40:46.543 DEBUG librdkafka: librdkafka: CGRPJOINSTATE [thrd:main]: Group "materialize-kafka-u1/u2" changed join state init -> wait-unassign (v1, state init) | |
| May 03 00:40:46.543 DEBUG librdkafka: librdkafka: UNASSIGN [thrd:main]: Group "materialize-kafka-u1/u2": unassign done in state init (join state wait-unassign): without new assignment: unassign (no previous assignment) | |
| May 03 00:40:46.544 DEBUG librdkafka: librdkafka: CGRPJOINSTATE [thrd:main]: Group "materialize-kafka-u1/u2" changed join state wait-unassign -> init (v1, state init) | |
| May 03 00:40:46.544 DEBUG librdkafka: librdkafka: CGRPLOG [thrd:main]: serving state init | |
| May 03 00:40:46.544 DEBUG librdkafka: librdkafka: CGRPSTATE [thrd:main]: Group "materialize-kafka-u1/u2" changed state init -> query-coord (v1, join-state init) | |
| May 03 00:40:46.544 DEBUG librdkafka: librdkafka: BROADCAST [thrd:main]: Broadcasting state change | |
| May 03 00:40:46.544 DEBUG librdkafka: librdkafka: CONNECT [thrd:main]: localhost:9092/bootstrap: Selected for cluster connection: coordinator query (broker has 0 connection attempt(s)) | |
| May 03 00:40:46.544 DEBUG librdkafka: librdkafka: CGRPQUERY [thrd:main]: Group "materialize-kafka-u1/u2": no broker available for coordinator query: intervaled in state query-coord | |
| May 03 00:40:46.544 DEBUG librdkafka: librdkafka: CONNECT [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received CONNECT op | |
| May 03 00:40:46.544 DEBUG librdkafka: librdkafka: STATE [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state INIT -> TRY_CONNECT | |
| May 03 00:40:46.544 DEBUG librdkafka: librdkafka: BROADCAST [thrd:localhost:9092/bootstrap]: Broadcasting state change | |
| May 03 00:40:46.544 DEBUG librdkafka: librdkafka: BRKMAIN [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: rkb_state: TRY_CONNECT | |
| May 03 00:40:46.544 DEBUG librdkafka: librdkafka: CONNECT [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: broker in state TRY_CONNECT connecting | |
| May 03 00:40:46.544 DEBUG librdkafka: librdkafka: STATE [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state TRY_CONNECT -> CONNECT | |
| May 03 00:40:46.544 DEBUG librdkafka: librdkafka: BROADCAST [thrd:localhost:9092/bootstrap]: Broadcasting state change | |
| May 03 00:40:46.545 DEBUG librdkafka: librdkafka: CONNECT [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connecting to ipv4#127.0.0.1:9092 (plaintext) with socket 19 | |
| May 03 00:40:46.545 DEBUG librdkafka: librdkafka: CONNECT [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connected to ipv4#127.0.0.1:9092 | |
| May 03 00:40:46.545 DEBUG librdkafka: librdkafka: CONNECTED [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connected (#1) | |
| May 03 00:40:46.545 DEBUG librdkafka: librdkafka: FEATURE [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Updated enabled protocol features +ApiVersion to ApiVersion | |
| May 03 00:40:46.545 DEBUG librdkafka: librdkafka: STATE [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state CONNECT -> APIVERSION_QUERY | |
| May 03 00:40:46.545 DEBUG librdkafka: librdkafka: BROADCAST [thrd:localhost:9092/bootstrap]: Broadcasting state change | |
| May 03 00:40:46.545 DEBUG librdkafka: librdkafka: BRKMAIN [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: rkb_state: APIVERSION_QUERY | |
| May 03 00:40:46.545 DEBUG librdkafka: librdkafka: SEND [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Sent ApiVersionRequest (v3, 45 bytes @ 0, CorrId 1) | |
| May 03 00:40:46.545 DEBUG librdkafka: librdkafka: RECV [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received ApiVersionResponse (v3, 344 bytes, CorrId 1, rtt 0.23ms) | |
| May 03 00:40:46.545 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker API support: | |
| May 03 00:40:46.546 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey Produce (0) Versions 0..8 | |
| May 03 00:40:46.546 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey Fetch (1) Versions 0..11 | |
| May 03 00:40:46.546 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey Offset (2) Versions 0..5 | |
| May 03 00:40:46.546 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey Metadata (3) Versions 0..9 | |
| May 03 00:40:46.546 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey LeaderAndIsr (4) Versions 0..4 | |
| May 03 00:40:46.546 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey StopReplica (5) Versions 0..2 | |
| May 03 00:40:46.546 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey UpdateMetadata (6) Versions 0..6 | |
| May 03 00:40:46.546 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey ControlledShutdown (7) Versions 0..3 | |
| May 03 00:40:46.546 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey OffsetCommit (8) Versions 0..8 | |
| May 03 00:40:46.546 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey OffsetFetch (9) Versions 0..7 | |
| May 03 00:40:46.546 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey FindCoordinator (10) Versions 0..3 | |
| May 03 00:40:46.546 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey JoinGroup (11) Versions 0..7 | |
| May 03 00:40:46.546 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey Heartbeat (12) Versions 0..4 | |
| May 03 00:40:46.546 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey LeaveGroup (13) Versions 0..4 | |
| May 03 00:40:46.546 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey SyncGroup (14) Versions 0..5 | |
| May 03 00:40:46.546 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey DescribeGroups (15) Versions 0..5 | |
| May 03 00:40:46.547 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey ListGroups (16) Versions 0..3 | |
| May 03 00:40:46.547 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey SaslHandshake (17) Versions 0..1 | |
| May 03 00:40:46.547 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey ApiVersion (18) Versions 0..3 | |
| May 03 00:40:46.547 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey CreateTopics (19) Versions 0..5 | |
| May 03 00:40:46.547 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey DeleteTopics (20) Versions 0..4 | |
| May 03 00:40:46.547 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey DeleteRecords (21) Versions 0..1 | |
| May 03 00:40:46.547 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey InitProducerId (22) Versions 0..3 | |
| May 03 00:40:46.547 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey OffsetForLeaderEpoch (23) Versions 0..3 | |
| May 03 00:40:46.547 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey AddPartitionsToTxn (24) Versions 0..1 | |
| May 03 00:40:46.547 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey AddOffsetsToTxn (25) Versions 0..1 | |
| May 03 00:40:46.547 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey EndTxn (26) Versions 0..1 | |
| May 03 00:40:46.547 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey WriteTxnMarkers (27) Versions 0..0 | |
| May 03 00:40:46.547 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey TxnOffsetCommit (28) Versions 0..3 | |
| May 03 00:40:46.547 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey DescribeAcls (29) Versions 0..2 | |
| May 03 00:40:46.547 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey CreateAcls (30) Versions 0..2 | |
| May 03 00:40:46.548 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey DeleteAcls (31) Versions 0..2 | |
| May 03 00:40:46.548 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey DescribeConfigs (32) Versions 0..2 | |
| May 03 00:40:46.548 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey AlterConfigs (33) Versions 0..1 | |
| May 03 00:40:46.548 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey AlterReplicaLogDirs (34) Versions 0..1 | |
| May 03 00:40:46.548 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey DescribeLogDirs (35) Versions 0..1 | |
| May 03 00:40:46.548 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey SaslAuthenticate (36) Versions 0..2 | |
| May 03 00:40:46.548 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey CreatePartitions (37) Versions 0..2 | |
| May 03 00:40:46.548 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey CreateDelegationToken (38) Versions 0..2 | |
| May 03 00:40:46.548 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey RenewDelegationToken (39) Versions 0..2 | |
| May 03 00:40:46.548 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey ExpireDelegationToken (40) Versions 0..2 | |
| May 03 00:40:46.548 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey DescribeDelegationToken (41) Versions 0..2 | |
| May 03 00:40:46.548 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey DeleteGroups (42) Versions 0..2 | |
| May 03 00:40:46.548 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey Unknown-43? (43) Versions 0..2 | |
| May 03 00:40:46.548 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey Unknown-44? (44) Versions 0..1 | |
| May 03 00:40:46.548 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey Unknown-45? (45) Versions 0..0 | |
| May 03 00:40:46.548 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey Unknown-46? (46) Versions 0..0 | |
| May 03 00:40:46.549 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey Unknown-47? (47) Versions 0..0 | |
| May 03 00:40:46.549 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Feature MsgVer1: Produce (2..2) supported by broker | |
| May 03 00:40:46.549 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Feature MsgVer1: Fetch (2..2) supported by broker | |
| May 03 00:40:46.549 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature MsgVer1 | |
| May 03 00:40:46.549 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Feature MsgVer2: Produce (3..3) supported by broker | |
| May 03 00:40:46.549 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Feature MsgVer2: Fetch (4..4) supported by broker | |
| May 03 00:40:46.549 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature MsgVer2 | |
| May 03 00:40:46.549 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Feature ApiVersion: ApiVersion (0..0) supported by broker | |
| May 03 00:40:46.549 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature ApiVersion | |
| May 03 00:40:46.549 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Feature BrokerGroupCoordinator: FindCoordinator (0..0) supported by broker | |
| May 03 00:40:46.549 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature BrokerGroupCoordinator | |
| May 03 00:40:46.549 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Feature BrokerBalancedConsumer: FindCoordinator (0..0) supported by broker | |
| May 03 00:40:46.549 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Feature BrokerBalancedConsumer: OffsetCommit (1..2) supported by broker | |
| May 03 00:40:46.549 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Feature BrokerBalancedConsumer: OffsetFetch (1..1) supported by broker | |
| May 03 00:40:46.549 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Feature BrokerBalancedConsumer: JoinGroup (0..0) supported by broker | |
| May 03 00:40:46.549 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Feature BrokerBalancedConsumer: SyncGroup (0..0) supported by broker | |
| May 03 00:40:46.550 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Feature BrokerBalancedConsumer: Heartbeat (0..0) supported by broker | |
| May 03 00:40:46.550 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Feature BrokerBalancedConsumer: LeaveGroup (0..0) supported by broker | |
| May 03 00:40:46.550 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature BrokerBalancedConsumer | |
| May 03 00:40:46.550 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Feature ThrottleTime: Produce (1..2) supported by broker | |
| May 03 00:40:46.550 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Feature ThrottleTime: Fetch (1..2) supported by broker | |
| May 03 00:40:46.550 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature ThrottleTime | |
| May 03 00:40:46.550 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Feature Sasl: JoinGroup (0..0) supported by broker | |
| May 03 00:40:46.550 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature Sasl | |
| May 03 00:40:46.550 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Feature SaslHandshake: SaslHandshake (0..0) supported by broker | |
| May 03 00:40:46.550 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature SaslHandshake | |
| May 03 00:40:46.550 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Feature LZ4: FindCoordinator (0..0) supported by broker | |
| May 03 00:40:46.550 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature LZ4 | |
| May 03 00:40:46.550 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Feature OffsetTime: Offset (1..1) supported by broker | |
| May 03 00:40:46.550 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature OffsetTime | |
| May 03 00:40:46.550 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Feature IdempotentProducer: InitProducerId (0..0) supported by broker | |
| May 03 00:40:46.551 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature IdempotentProducer | |
| May 03 00:40:46.551 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Feature ZSTD: Produce (7..7) supported by broker | |
| May 03 00:40:46.551 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Feature ZSTD: Fetch (10..10) supported by broker | |
| May 03 00:40:46.551 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature ZSTD | |
| May 03 00:40:46.551 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Feature SaslAuthReq: SaslHandshake (1..1) supported by broker | |
| May 03 00:40:46.551 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Feature SaslAuthReq: SaslAuthenticate (0..0) supported by broker | |
| May 03 00:40:46.551 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature SaslAuthReq | |
| May 03 00:40:46.551 DEBUG librdkafka: librdkafka: FEATURE [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Updated enabled protocol features to MsgVer1,ApiVersion,BrokerBalancedConsumer,ThrottleTime,Sasl,SaslHandshake,BrokerGroupCoordinator,LZ4,OffsetTime,MsgVer2,IdempotentProducer,ZSTD,SaslAuthReq | |
| May 03 00:40:46.551 DEBUG librdkafka: librdkafka: STATE [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state APIVERSION_QUERY -> UP | |
| May 03 00:40:46.551 DEBUG librdkafka: librdkafka: BROADCAST [thrd:localhost:9092/bootstrap]: Broadcasting state change | |
| May 03 00:40:46.551 DEBUG librdkafka: librdkafka: METADATA [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Request metadata for brokers only: connected | |
| May 03 00:40:46.551 DEBUG librdkafka: librdkafka: BRKMAIN [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: rkb_state: UP | |
| May 03 00:40:46.551 DEBUG librdkafka: librdkafka: SEND [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Sent MetadataRequest (v2, 30 bytes @ 0, CorrId 2) | |
| May 03 00:40:46.552 DEBUG librdkafka: librdkafka: RECV [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received MetadataResponse (v2, 56 bytes, CorrId 2, rtt 0.21ms) | |
| May 03 00:40:46.552 DEBUG librdkafka: librdkafka: METADATA [thrd:main]: localhost:9092/bootstrap: ===== Received metadata: connected ===== | |
| May 03 00:40:46.552 DEBUG librdkafka: librdkafka: METADATA [thrd:main]: localhost:9092/bootstrap: ClusterId: mNnljm4BSEac_7d_0ZNDAQ, ControllerId: 0 | |
| May 03 00:40:46.552 DEBUG librdkafka: librdkafka: METADATA [thrd:main]: localhost:9092/bootstrap: 1 brokers, 0 topics | |
| May 03 00:40:46.552 DEBUG librdkafka: librdkafka: METADATA [thrd:main]: localhost:9092/bootstrap: Broker #0/1: marmoset:9092 NodeId 0 | |
| May 03 00:40:46.552 DEBUG librdkafka: librdkafka: WAKEUPFD [thrd:main]: marmoset:9092/0: Enabled low-latency ops queue wake-ups | |
| May 03 00:40:46.552 DEBUG librdkafka: librdkafka: BROKER [thrd:main]: marmoset:9092/0: Added new broker with NodeId 0 | |
| May 03 00:40:46.552 DEBUG librdkafka: librdkafka: CLUSTERID [thrd:main]: localhost:9092/bootstrap: ClusterId update "" -> "mNnljm4BSEac_7d_0ZNDAQ" | |
| May 03 00:40:46.552 DEBUG librdkafka: librdkafka: CONTROLLERID [thrd:main]: localhost:9092/bootstrap: ControllerId update -1 -> 0 | |
| May 03 00:40:46.552 DEBUG librdkafka: librdkafka: BROADCAST [thrd:main]: Broadcasting state change | |
| May 03 00:40:46.552 DEBUG librdkafka: librdkafka: CGRPLOG [thrd:main]: serving state query-coord | |
| May 03 00:40:46.553 DEBUG librdkafka: librdkafka: BRKMAIN [thrd:marmoset:9092/0]: marmoset:9092/0: Enter main broker thread | |
| May 03 00:40:46.553 DEBUG librdkafka: librdkafka: BRKMAIN [thrd:marmoset:9092/0]: marmoset:9092/0: rkb_state: INIT | |
| May 03 00:40:47.542 DEBUG librdkafka: librdkafka: CGRPLOG [thrd:main]: serving state query-coord | |
| May 03 00:40:47.542 DEBUG librdkafka: librdkafka: CGRPQUERY [thrd:main]: localhost:9092/bootstrap: Group "materialize-kafka-u1/u2": querying for coordinator: intervaled in state query-coord | |
| May 03 00:40:47.542 DEBUG librdkafka: librdkafka: CGRPSTATE [thrd:main]: Group "materialize-kafka-u1/u2" changed state query-coord -> wait-coord (v1, join-state init) | |
| May 03 00:40:47.542 DEBUG librdkafka: librdkafka: BROADCAST [thrd:main]: Broadcasting state change | |
| May 03 00:40:47.542 DEBUG librdkafka: librdkafka: SEND [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Sent FindCoordinatorRequest (v2, 52 bytes @ 0, CorrId 3) | |
| May 03 00:40:47.542 DEBUG librdkafka: librdkafka: CGRPLOG [thrd:main]: serving state wait-coord | |
| May 03 00:40:47.542 DEBUG librdkafka: librdkafka: CGRPLOG [thrd:main]: serving state wait-coord | |
| May 03 00:40:47.542 DEBUG librdkafka: librdkafka: RECV [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received FindCoordinatorResponse (v2, 30 bytes, CorrId 3, rtt 0.22ms) | |
| May 03 00:40:47.542 DEBUG librdkafka: librdkafka: CGRPCOORD [thrd:main]: localhost:9092/bootstrap: Group "materialize-kafka-u1/u2" coordinator is marmoset:9092 id 0 | |
| May 03 00:40:47.542 DEBUG librdkafka: librdkafka: CGRPCOORD [thrd:main]: Group "materialize-kafka-u1/u2" changing coordinator -1 -> 0 | |
| May 03 00:40:47.543 DEBUG librdkafka: librdkafka: COORDSET [thrd:main]: Group "materialize-kafka-u1/u2" coordinator set to broker marmoset:9092/0 | |
| May 03 00:40:47.543 DEBUG librdkafka: librdkafka: CGRPSTATE [thrd:main]: Group "materialize-kafka-u1/u2" changed state wait-coord -> wait-broker-transport (v1, join-state init) | |
| May 03 00:40:47.543 DEBUG librdkafka: librdkafka: BROADCAST [thrd:main]: Broadcasting state change | |
| May 03 00:40:47.543 DEBUG librdkafka: librdkafka: NODENAME [thrd:main]: GroupCoordinator: Broker nodename changed from "" to "marmoset:9092" | |
| May 03 00:40:47.543 DEBUG librdkafka: librdkafka: CONNECT [thrd:GroupCoordinator]: GroupCoordinator: Received CONNECT op | |
| May 03 00:40:47.543 DEBUG librdkafka: librdkafka: CGRPLOG [thrd:main]: serving state wait-broker-transport | |
| May 03 00:40:47.543 DEBUG librdkafka: librdkafka: STATE [thrd:GroupCoordinator]: GroupCoordinator: Broker changed state INIT -> TRY_CONNECT | |
| May 03 00:40:47.543 DEBUG librdkafka: librdkafka: CGRPQUERY [thrd:main]: localhost:9092/bootstrap: Group "materialize-kafka-u1/u2": querying for coordinator: intervaled in state wait-broker-transport | |
| May 03 00:40:47.543 DEBUG librdkafka: librdkafka: BROADCAST [thrd:GroupCoordinator]: Broadcasting state change | |
| May 03 00:40:47.543 DEBUG librdkafka: librdkafka: BRKMAIN [thrd::0/internal]: :0/internal: rkb_state: INIT | |
| May 03 00:40:47.543 DEBUG librdkafka: librdkafka: BROKERFAIL [thrd:GroupCoordinator]: GroupCoordinator: failed: err: Local: Broker transport failure: (errno: Success) | |
| May 03 00:40:47.543 DEBUG librdkafka: librdkafka: FAIL [thrd:GroupCoordinator]: GroupCoordinator: Closing connection due to nodename change (after 0ms in state TRY_CONNECT) | |
| May 03 00:40:47.543 DEBUG librdkafka: librdkafka: STATE [thrd:GroupCoordinator]: GroupCoordinator: Broker changed state TRY_CONNECT -> DOWN | |
| May 03 00:40:47.543 DEBUG librdkafka: librdkafka: BROADCAST [thrd:GroupCoordinator]: Broadcasting state change | |
| May 03 00:40:47.543 DEBUG librdkafka: librdkafka: BUFQ [thrd:GroupCoordinator]: GroupCoordinator/0: Purging bufq with 0 buffers | |
| May 03 00:40:47.543 DEBUG librdkafka: librdkafka: CGRPLOG [thrd:main]: serving state wait-broker-transport | |
| May 03 00:40:47.543 DEBUG librdkafka: librdkafka: BUFQ [thrd:GroupCoordinator]: GroupCoordinator/0: Purging bufq with 0 buffers | |
| May 03 00:40:47.543 DEBUG librdkafka: librdkafka: SEND [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Sent FindCoordinatorRequest (v2, 52 bytes @ 0, CorrId 4) | |
| May 03 00:40:47.544 DEBUG librdkafka: librdkafka: BUFQ [thrd:GroupCoordinator]: GroupCoordinator/0: Updating 0 buffers on connection reset | |
| May 03 00:40:47.544 DEBUG librdkafka: librdkafka: BRKMAIN [thrd:GroupCoordinator]: GroupCoordinator/0: rkb_state: DOWN | |
| May 03 00:40:47.544 DEBUG librdkafka: librdkafka: STATE [thrd:GroupCoordinator]: GroupCoordinator: Broker changed state DOWN -> INIT | |
| May 03 00:40:47.544 DEBUG librdkafka: librdkafka: BROADCAST [thrd:GroupCoordinator]: Broadcasting state change | |
| May 03 00:40:47.544 DEBUG librdkafka: librdkafka: RECV [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received FindCoordinatorResponse (v2, 30 bytes, CorrId 4, rtt 0.30ms) | |
| May 03 00:40:47.544 DEBUG librdkafka: librdkafka: BRKMAIN [thrd:GroupCoordinator]: GroupCoordinator/0: rkb_state: INIT | |
| May 03 00:40:47.544 DEBUG librdkafka: librdkafka: STATE [thrd:GroupCoordinator]: GroupCoordinator: Broker changed state INIT -> TRY_CONNECT | |
| May 03 00:40:47.544 DEBUG librdkafka: librdkafka: CGRPCOORD [thrd:main]: localhost:9092/bootstrap: Group "materialize-kafka-u1/u2" coordinator is marmoset:9092 id 0 | |
| May 03 00:40:47.544 DEBUG librdkafka: librdkafka: BROADCAST [thrd:GroupCoordinator]: Broadcasting state change | |
| May 03 00:40:47.544 DEBUG librdkafka: librdkafka: BRKMAIN [thrd:GroupCoordinator]: GroupCoordinator/0: rkb_state: TRY_CONNECT | |
| May 03 00:40:47.544 DEBUG librdkafka: librdkafka: CGRPLOG [thrd:main]: serving state wait-broker-transport | |
| May 03 00:40:47.544 DEBUG librdkafka: librdkafka: CONNECT [thrd:GroupCoordinator]: GroupCoordinator/0: broker in state TRY_CONNECT connecting | |
| May 03 00:40:47.544 DEBUG librdkafka: librdkafka: CGRPLOG [thrd:main]: serving state wait-broker-transport | |
| May 03 00:40:47.544 DEBUG librdkafka: librdkafka: STATE [thrd:GroupCoordinator]: GroupCoordinator: Broker changed state TRY_CONNECT -> CONNECT | |
| May 03 00:40:47.544 DEBUG librdkafka: librdkafka: BROADCAST [thrd:GroupCoordinator]: Broadcasting state change | |
| May 03 00:40:47.544 DEBUG librdkafka: librdkafka: CONNECT [thrd:GroupCoordinator]: GroupCoordinator/0: Connecting to ipv4#127.0.1.1:9092 (plaintext) with socket 33 | |
| May 03 00:40:47.545 DEBUG librdkafka: librdkafka: CONNECT [thrd:GroupCoordinator]: GroupCoordinator/0: Connected to ipv4#127.0.1.1:9092 | |
| May 03 00:40:47.545 DEBUG librdkafka: librdkafka: CONNECTED [thrd:GroupCoordinator]: GroupCoordinator/0: Connected (#1) | |
| May 03 00:40:47.545 DEBUG librdkafka: librdkafka: FEATURE [thrd:GroupCoordinator]: GroupCoordinator/0: Updated enabled protocol features +ApiVersion to ApiVersion | |
| May 03 00:40:47.545 DEBUG librdkafka: librdkafka: STATE [thrd:GroupCoordinator]: GroupCoordinator: Broker changed state CONNECT -> APIVERSION_QUERY | |
| May 03 00:40:47.545 DEBUG librdkafka: librdkafka: BROADCAST [thrd:GroupCoordinator]: Broadcasting state change | |
| May 03 00:40:47.545 DEBUG librdkafka: librdkafka: BRKMAIN [thrd:GroupCoordinator]: GroupCoordinator/0: rkb_state: APIVERSION_QUERY | |
| May 03 00:40:47.545 DEBUG librdkafka: librdkafka: SEND [thrd:GroupCoordinator]: GroupCoordinator/0: Sent ApiVersionRequest (v3, 45 bytes @ 0, CorrId 1) | |
| May 03 00:40:47.545 DEBUG librdkafka: librdkafka: RECV [thrd:GroupCoordinator]: GroupCoordinator/0: Received ApiVersionResponse (v3, 344 bytes, CorrId 1, rtt 0.26ms) | |
| May 03 00:40:47.546 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: Broker API support: | |
| May 03 00:40:47.546 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey Produce (0) Versions 0..8 | |
| May 03 00:40:47.546 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey Fetch (1) Versions 0..11 | |
| May 03 00:40:47.546 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey Offset (2) Versions 0..5 | |
| May 03 00:40:47.546 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey Metadata (3) Versions 0..9 | |
| May 03 00:40:47.546 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey LeaderAndIsr (4) Versions 0..4 | |
| May 03 00:40:47.546 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey StopReplica (5) Versions 0..2 | |
| May 03 00:40:47.546 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey UpdateMetadata (6) Versions 0..6 | |
| May 03 00:40:47.546 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey ControlledShutdown (7) Versions 0..3 | |
| May 03 00:40:47.546 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey OffsetCommit (8) Versions 0..8 | |
| May 03 00:40:47.546 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey OffsetFetch (9) Versions 0..7 | |
| May 03 00:40:47.546 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey FindCoordinator (10) Versions 0..3 | |
| May 03 00:40:47.546 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey JoinGroup (11) Versions 0..7 | |
| May 03 00:40:47.546 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey Heartbeat (12) Versions 0..4 | |
| May 03 00:40:47.546 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey LeaveGroup (13) Versions 0..4 | |
| May 03 00:40:47.547 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey SyncGroup (14) Versions 0..5 | |
| May 03 00:40:47.547 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey DescribeGroups (15) Versions 0..5 | |
| May 03 00:40:47.547 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey ListGroups (16) Versions 0..3 | |
| May 03 00:40:47.547 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey SaslHandshake (17) Versions 0..1 | |
| May 03 00:40:47.547 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey ApiVersion (18) Versions 0..3 | |
| May 03 00:40:47.547 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey CreateTopics (19) Versions 0..5 | |
| May 03 00:40:47.547 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey DeleteTopics (20) Versions 0..4 | |
| May 03 00:40:47.547 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey DeleteRecords (21) Versions 0..1 | |
| May 03 00:40:47.547 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey InitProducerId (22) Versions 0..3 | |
| May 03 00:40:47.547 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey OffsetForLeaderEpoch (23) Versions 0..3 | |
| May 03 00:40:47.547 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey AddPartitionsToTxn (24) Versions 0..1 | |
| May 03 00:40:47.547 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey AddOffsetsToTxn (25) Versions 0..1 | |
| May 03 00:40:47.547 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey EndTxn (26) Versions 0..1 | |
| May 03 00:40:47.547 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey WriteTxnMarkers (27) Versions 0..0 | |
| May 03 00:40:47.547 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey TxnOffsetCommit (28) Versions 0..3 | |
| May 03 00:40:47.547 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey DescribeAcls (29) Versions 0..2 | |
| May 03 00:40:47.547 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey CreateAcls (30) Versions 0..2 | |
| May 03 00:40:47.548 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey DeleteAcls (31) Versions 0..2 | |
| May 03 00:40:47.548 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey DescribeConfigs (32) Versions 0..2 | |
| May 03 00:40:47.548 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey AlterConfigs (33) Versions 0..1 | |
| May 03 00:40:47.548 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey AlterReplicaLogDirs (34) Versions 0..1 | |
| May 03 00:40:47.548 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey DescribeLogDirs (35) Versions 0..1 | |
| May 03 00:40:47.548 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey SaslAuthenticate (36) Versions 0..2 | |
| May 03 00:40:47.548 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey CreatePartitions (37) Versions 0..2 | |
| May 03 00:40:47.548 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey CreateDelegationToken (38) Versions 0..2 | |
| May 03 00:40:47.548 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey RenewDelegationToken (39) Versions 0..2 | |
| May 03 00:40:47.548 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey ExpireDelegationToken (40) Versions 0..2 | |
| May 03 00:40:47.548 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey DescribeDelegationToken (41) Versions 0..2 | |
| May 03 00:40:47.548 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey DeleteGroups (42) Versions 0..2 | |
| May 03 00:40:47.548 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey Unknown-43? (43) Versions 0..2 | |
| May 03 00:40:47.548 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey Unknown-44? (44) Versions 0..1 | |
| May 03 00:40:47.549 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey Unknown-45? (45) Versions 0..0 | |
| May 03 00:40:47.549 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey Unknown-46? (46) Versions 0..0 | |
| May 03 00:40:47.549 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey Unknown-47? (47) Versions 0..0 | |
| May 03 00:40:47.549 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: Feature MsgVer1: Produce (2..2) supported by broker | |
| May 03 00:40:47.549 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: Feature MsgVer1: Fetch (2..2) supported by broker | |
| May 03 00:40:47.549 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: Enabling feature MsgVer1 | |
| May 03 00:40:47.549 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: Feature MsgVer2: Produce (3..3) supported by broker | |
| May 03 00:40:47.549 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: Feature MsgVer2: Fetch (4..4) supported by broker | |
| May 03 00:40:47.549 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: Enabling feature MsgVer2 | |
| May 03 00:40:47.549 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: Feature ApiVersion: ApiVersion (0..0) supported by broker | |
| May 03 00:40:47.549 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: Enabling feature ApiVersion | |
| May 03 00:40:47.549 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: Feature BrokerGroupCoordinator: FindCoordinator (0..0) supported by broker | |
| May 03 00:40:47.549 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: Enabling feature BrokerGroupCoordinator | |
| May 03 00:40:47.550 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: Feature BrokerBalancedConsumer: FindCoordinator (0..0) supported by broker | |
| May 03 00:40:47.550 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: Feature BrokerBalancedConsumer: OffsetCommit (1..2) supported by broker | |
| May 03 00:40:47.550 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: Feature BrokerBalancedConsumer: OffsetFetch (1..1) supported by broker | |
| May 03 00:40:47.550 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: Feature BrokerBalancedConsumer: JoinGroup (0..0) supported by broker | |
| May 03 00:40:47.550 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: Feature BrokerBalancedConsumer: SyncGroup (0..0) supported by broker | |
| May 03 00:40:47.550 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: Feature BrokerBalancedConsumer: Heartbeat (0..0) supported by broker | |
| May 03 00:40:47.550 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: Feature BrokerBalancedConsumer: LeaveGroup (0..0) supported by broker | |
| May 03 00:40:47.550 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: Enabling feature BrokerBalancedConsumer | |
| May 03 00:40:47.550 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: Feature ThrottleTime: Produce (1..2) supported by broker | |
| May 03 00:40:47.550 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: Feature ThrottleTime: Fetch (1..2) supported by broker | |
| May 03 00:40:47.550 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: Enabling feature ThrottleTime | |
| May 03 00:40:47.550 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: Feature Sasl: JoinGroup (0..0) supported by broker | |
| May 03 00:40:47.550 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: Enabling feature Sasl | |
| May 03 00:40:47.550 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: Feature SaslHandshake: SaslHandshake (0..0) supported by broker | |
| May 03 00:40:47.551 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: Enabling feature SaslHandshake | |
| May 03 00:40:47.551 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: Feature LZ4: FindCoordinator (0..0) supported by broker | |
| May 03 00:40:47.551 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: Enabling feature LZ4 | |
| May 03 00:40:47.551 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: Feature OffsetTime: Offset (1..1) supported by broker | |
| May 03 00:40:47.551 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: Enabling feature OffsetTime | |
| May 03 00:40:47.551 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: Feature IdempotentProducer: InitProducerId (0..0) supported by broker | |
| May 03 00:40:47.551 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: Enabling feature IdempotentProducer | |
| May 03 00:40:47.551 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: Feature ZSTD: Produce (7..7) supported by broker | |
| May 03 00:40:47.551 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: Feature ZSTD: Fetch (10..10) supported by broker | |
| May 03 00:40:47.551 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: Enabling feature ZSTD | |
| May 03 00:40:47.551 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: Feature SaslAuthReq: SaslHandshake (1..1) supported by broker | |
| May 03 00:40:47.551 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: Feature SaslAuthReq: SaslAuthenticate (0..0) supported by broker | |
| May 03 00:40:47.551 DEBUG librdkafka: librdkafka: APIVERSION [thrd:GroupCoordinator]: GroupCoordinator/0: Enabling feature SaslAuthReq | |
| May 03 00:40:47.552 DEBUG librdkafka: librdkafka: FEATURE [thrd:GroupCoordinator]: GroupCoordinator/0: Updated enabled protocol features to MsgVer1,ApiVersion,BrokerBalancedConsumer,ThrottleTime,Sasl,SaslHandshake,BrokerGroupCoordinator,LZ4,OffsetTime,MsgVer2,IdempotentProducer,ZSTD,SaslAuthReq | |
| May 03 00:40:47.552 DEBUG librdkafka: librdkafka: STATE [thrd:GroupCoordinator]: GroupCoordinator: Broker changed state APIVERSION_QUERY -> UP | |
| May 03 00:40:47.552 DEBUG librdkafka: librdkafka: BROADCAST [thrd:GroupCoordinator]: Broadcasting state change | |
| May 03 00:40:47.552 DEBUG librdkafka: librdkafka: METADATA [thrd:GroupCoordinator]: GroupCoordinator/0: Request metadata for brokers only: connected | |
| May 03 00:40:47.552 DEBUG librdkafka: librdkafka: BRKMAIN [thrd:GroupCoordinator]: GroupCoordinator/0: rkb_state: UP | |
| May 03 00:40:47.552 DEBUG librdkafka: librdkafka: SEND [thrd:GroupCoordinator]: GroupCoordinator/0: Sent MetadataRequest (v2, 30 bytes @ 0, CorrId 2) | |
| May 03 00:40:47.552 DEBUG librdkafka: librdkafka: BRKMAIN [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: rkb_state: UP | |
| May 03 00:40:47.552 DEBUG librdkafka: librdkafka: RECV [thrd:GroupCoordinator]: GroupCoordinator/0: Received MetadataResponse (v2, 56 bytes, CorrId 2, rtt 0.15ms) | |
| May 03 00:40:47.552 DEBUG librdkafka: librdkafka: METADATA [thrd:main]: GroupCoordinator/0: ===== Received metadata: connected ===== | |
| May 03 00:40:47.552 DEBUG librdkafka: librdkafka: METADATA [thrd:main]: GroupCoordinator/0: ClusterId: mNnljm4BSEac_7d_0ZNDAQ, ControllerId: 0 | |
| May 03 00:40:47.552 DEBUG librdkafka: librdkafka: METADATA [thrd:main]: GroupCoordinator/0: 1 brokers, 0 topics | |
| May 03 00:40:47.552 DEBUG librdkafka: librdkafka: METADATA [thrd:main]: GroupCoordinator/0: Broker #0/1: marmoset:9092 NodeId 0 | |
| May 03 00:40:47.553 DEBUG librdkafka: librdkafka: CGRPLOG [thrd:main]: serving state wait-broker-transport | |
| May 03 00:40:47.553 DEBUG librdkafka: librdkafka: CGRPSTATE [thrd:main]: Group "materialize-kafka-u1/u2" changed state wait-broker-transport -> up (v1, join-state init) | |
| May 03 00:40:47.553 DEBUG librdkafka: librdkafka: BROADCAST [thrd:main]: Broadcasting state change | |
| May 03 00:40:47.553 DEBUG librdkafka: librdkafka: JOIN [thrd:main]: Group "materialize-kafka-u1/u2": join with 0 (1) subscribed topic(s) | |
| May 03 00:40:47.553 DEBUG librdkafka: librdkafka: METADATA [thrd:main]: Hinted cache of 1/1 topic(s) being queried | |
| May 03 00:40:47.553 DEBUG librdkafka: librdkafka: CGRPMETADATA [thrd:main]: consumer join: metadata for subscription only available for 0/1 topics (-1ms old) | |
| May 03 00:40:47.553 DEBUG librdkafka: librdkafka: METADATA [thrd:main]: localhost:9092/bootstrap: Request metadata for 1 topic(s): consumer join | |
| May 03 00:40:47.553 DEBUG librdkafka: librdkafka: BRKMAIN [thrd:marmoset:9092/0]: marmoset:9092/0: rkb_state: INIT | |
| May 03 00:40:47.553 DEBUG librdkafka: librdkafka: JOIN [thrd:main]: Group "materialize-kafka-u1/u2": postponing join until up-to-date metadata is available | |
| May 03 00:40:47.553 DEBUG librdkafka: librdkafka: SEND [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Sent MetadataRequest (v2, 57 bytes @ 0, CorrId 5) | |
| May 03 00:40:47.553 DEBUG librdkafka: librdkafka: RECV [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received MetadataResponse (v2, 116 bytes, CorrId 5, rtt 0.27ms) | |
| May 03 00:40:47.554 DEBUG librdkafka: librdkafka: METADATA [thrd:main]: localhost:9092/bootstrap: ===== Received metadata (for 1 requested topics): consumer join ===== | |
| May 03 00:40:47.554 DEBUG librdkafka: librdkafka: METADATA [thrd:main]: localhost:9092/bootstrap: ClusterId: mNnljm4BSEac_7d_0ZNDAQ, ControllerId: 0 | |
| May 03 00:40:47.554 DEBUG librdkafka: librdkafka: METADATA [thrd:main]: localhost:9092/bootstrap: 1 brokers, 1 topics | |
| May 03 00:40:47.554 DEBUG librdkafka: librdkafka: METADATA [thrd:main]: localhost:9092/bootstrap: Broker #0/1: marmoset:9092 NodeId 0 | |
| May 03 00:40:47.554 DEBUG librdkafka: librdkafka: METADATA [thrd:main]: localhost:9092/bootstrap: Topic #0/1: testdrive-data-1766087232 with 1 partitions | |
| May 03 00:40:47.554 DEBUG librdkafka: librdkafka: METADATA [thrd:main]: localhost:9092/bootstrap: 1/1 requested topic(s) seen in metadata | |
| May 03 00:40:47.554 DEBUG librdkafka: librdkafka: SUBSCRIPTION [thrd:main]: Group "materialize-kafka-u1/u2": effective subscription list changed from 0 to 1 topic(s): | |
| May 03 00:40:47.554 DEBUG librdkafka: librdkafka: SUBSCRIPTION [thrd:main]: Topic testdrive-data-1766087232 with 1 partition(s) | |
| May 03 00:40:47.554 DEBUG librdkafka: librdkafka: REJOIN [thrd:main]: Group "materialize-kafka-u1/u2": subscription updated from metadata change: rejoining group | |
| May 03 00:40:47.554 DEBUG librdkafka: librdkafka: GRPLEADER [thrd:main]: Group "materialize-kafka-u1/u2": resetting group leader info: Group rejoin | |
| May 03 00:40:47.554 DEBUG librdkafka: librdkafka: REJOIN [thrd:main]: Group "materialize-kafka-u1/u2" rejoining in join-state init without an assignment | |
| May 03 00:40:47.554 DEBUG librdkafka: librdkafka: REBALANCE [thrd:main]: Group "materialize-kafka-u1/u2" is rebalancing in state up (join-state init) without assignment: group rejoin | |
| May 03 00:40:47.554 DEBUG librdkafka: librdkafka: CGRPJOINSTATE [thrd:main]: Group "materialize-kafka-u1/u2" changed join state init -> wait-unassign (v1, state up) | |
| May 03 00:40:47.554 DEBUG librdkafka: librdkafka: UNASSIGN [thrd:main]: Group "materialize-kafka-u1/u2": unassign done in state up (join state wait-unassign): without new assignment: unassign (no previous assignment) | |
| May 03 00:40:47.555 DEBUG librdkafka: librdkafka: CGRPJOINSTATE [thrd:main]: Group "materialize-kafka-u1/u2" changed join state wait-unassign -> init (v1, state up) | |
| May 03 00:40:47.555 DEBUG librdkafka: librdkafka: CGRPLOG [thrd:main]: serving state up | |
| May 03 00:40:47.555 DEBUG librdkafka: librdkafka: JOIN [thrd:main]: Group "materialize-kafka-u1/u2": join with 1 (1) subscribed topic(s) | |
| May 03 00:40:47.555 DEBUG librdkafka: librdkafka: CGRPMETADATA [thrd:main]: consumer join: metadata for subscription is up to date (0ms old) | |
| May 03 00:40:47.555 DEBUG librdkafka: librdkafka: JOIN [thrd:main]: marmoset:9092/0: Joining group "materialize-kafka-u1/u2" with 1 subscribed topic(s) | |
| May 03 00:40:47.555 DEBUG librdkafka: librdkafka: CGRPJOINSTATE [thrd:main]: Group "materialize-kafka-u1/u2" changed join state init -> wait-join (v1, state up) | |
| May 03 00:40:47.555 DEBUG librdkafka: librdkafka: CGRPLOG [thrd:main]: serving state up | |
| May 03 00:40:47.555 DEBUG librdkafka: librdkafka: SEND [thrd:GroupCoordinator]: GroupCoordinator/0: Sent JoinGroupRequest (v5, 178 bytes @ 0, CorrId 3) | |
| May 03 00:40:47.555 DEBUG librdkafka: librdkafka: BROADCAST [thrd:GroupCoordinator]: Broadcasting state change | |
| May 03 00:40:47.555 DEBUG librdkafka: librdkafka: RECV [thrd:GroupCoordinator]: GroupCoordinator/0: Received JoinGroupResponse (v5, 69 bytes, CorrId 3, rtt 0.50ms) | |
| May 03 00:40:47.556 DEBUG librdkafka: librdkafka: JOINGROUP [thrd:main]: JoinGroup response: GenerationId -1, Protocol , LeaderId , my MemberId materialized-e1e65948-a9fe-4d33-b7ff-b904471dd2ad, 0 members in group: Broker: Group member needs a valid member ID | |
| May 03 00:40:47.556 DEBUG librdkafka: librdkafka: REQERR [thrd:main]: GroupCoordinator/0: JoinGroupRequest failed: Broker: Group member needs a valid member ID: explicit actions Ignore | |
| May 03 00:40:47.556 DEBUG librdkafka: librdkafka: MEMBERID [thrd:main]: Group "materialize-kafka-u1/u2": updating member id "" -> "materialized-e1e65948-a9fe-4d33-b7ff-b904471dd2ad" | |
| May 03 00:40:47.556 DEBUG librdkafka: librdkafka: CGRPJOINSTATE [thrd:main]: Group "materialize-kafka-u1/u2" changed join state wait-join -> init (v1, state up) | |
| May 03 00:40:47.556 DEBUG librdkafka: librdkafka: CGRPLOG [thrd:main]: serving state up | |
| May 03 00:40:47.556 DEBUG librdkafka: librdkafka: JOIN [thrd:main]: Group "materialize-kafka-u1/u2": join with 1 (1) subscribed topic(s) | |
| May 03 00:40:47.556 DEBUG librdkafka: librdkafka: CGRPMETADATA [thrd:main]: consumer join: metadata for subscription is up to date (2ms old) | |
| May 03 00:40:47.556 DEBUG librdkafka: librdkafka: JOIN [thrd:main]: marmoset:9092/0: Joining group "materialize-kafka-u1/u2" with 1 subscribed topic(s) | |
| May 03 00:40:47.556 DEBUG librdkafka: librdkafka: CGRPJOINSTATE [thrd:main]: Group "materialize-kafka-u1/u2" changed join state init -> wait-join (v1, state up) | |
| May 03 00:40:47.556 DEBUG librdkafka: librdkafka: SEND [thrd:GroupCoordinator]: GroupCoordinator/0: Sent JoinGroupRequest (v5, 227 bytes @ 0, CorrId 4) | |
| May 03 00:40:47.556 DEBUG librdkafka: librdkafka: BROADCAST [thrd:GroupCoordinator]: Broadcasting state change | |
| May 03 00:40:47.558 DEBUG librdkafka: librdkafka: RECV [thrd:GroupCoordinator]: GroupCoordinator/0: Received JoinGroupResponse (v5, 217 bytes, CorrId 4, rtt 1.75ms) | |
| May 03 00:40:47.558 DEBUG librdkafka: librdkafka: JOINGROUP [thrd:main]: JoinGroup response: GenerationId 1, Protocol range, LeaderId materialized-e1e65948-a9fe-4d33-b7ff-b904471dd2ad (me), my MemberId materialized-e1e65948-a9fe-4d33-b7ff-b904471dd2ad, 1 members in group: (no error) | |
| May 03 00:40:47.558 DEBUG librdkafka: librdkafka: JOINGROUP [thrd:main]: Elected leader for group "materialize-kafka-u1/u2" with 1 member(s) | |
| May 03 00:40:47.558 DEBUG librdkafka: librdkafka: GRPLEADER [thrd:main]: Group "materialize-kafka-u1/u2": resetting group leader info: JoinGroup response clean-up | |
| May 03 00:40:47.558 DEBUG librdkafka: librdkafka: CGRPJOINSTATE [thrd:main]: Group "materialize-kafka-u1/u2" changed join state wait-join -> wait-metadata (v1, state up) | |
| May 03 00:40:47.558 DEBUG librdkafka: librdkafka: METADATA [thrd:main]: GroupCoordinator/0: Request metadata for 1 topic(s): partition assignor | |
| May 03 00:40:47.559 DEBUG librdkafka: librdkafka: CGRPLOG [thrd:main]: serving state up | |
| May 03 00:40:47.559 DEBUG librdkafka: librdkafka: SEND [thrd:GroupCoordinator]: GroupCoordinator/0: Sent MetadataRequest (v2, 57 bytes @ 0, CorrId 5) | |
| May 03 00:40:47.559 DEBUG librdkafka: librdkafka: RECV [thrd:GroupCoordinator]: GroupCoordinator/0: Received MetadataResponse (v2, 116 bytes, CorrId 5, rtt 0.16ms) | |
| May 03 00:40:47.559 DEBUG librdkafka: librdkafka: METADATA [thrd:main]: GroupCoordinator/0: ===== Received metadata (for 1 requested topics): partition assignor ===== | |
| May 03 00:40:47.559 DEBUG librdkafka: librdkafka: METADATA [thrd:main]: GroupCoordinator/0: ClusterId: mNnljm4BSEac_7d_0ZNDAQ, ControllerId: 0 | |
| May 03 00:40:47.559 DEBUG librdkafka: librdkafka: METADATA [thrd:main]: GroupCoordinator/0: 1 brokers, 1 topics | |
| May 03 00:40:47.559 DEBUG librdkafka: librdkafka: METADATA [thrd:main]: GroupCoordinator/0: Broker #0/1: marmoset:9092 NodeId 0 | |
| May 03 00:40:47.559 DEBUG librdkafka: librdkafka: METADATA [thrd:main]: GroupCoordinator/0: Topic #0/1: testdrive-data-1766087232 with 1 partitions | |
| May 03 00:40:47.559 DEBUG librdkafka: librdkafka: METADATA [thrd:main]: GroupCoordinator/0: 1/1 requested topic(s) seen in metadata | |
| May 03 00:40:47.559 DEBUG librdkafka: librdkafka: CGRPLOG [thrd:main]: serving state up | |
| May 03 00:40:47.559 DEBUG librdkafka: librdkafka: ASSIGN [thrd:main]: Group "materialize-kafka-u1/u2" running range assignment for 1 member(s): | |
| May 03 00:40:47.559 DEBUG librdkafka: librdkafka: ASSIGN [thrd:main]: Member "materialized-e1e65948-a9fe-4d33-b7ff-b904471dd2ad" (me) with 1 subscription(s): | |
| May 03 00:40:47.559 DEBUG librdkafka: librdkafka: ASSIGN [thrd:main]: testdrive-data-1766087232 [-1] | |
| May 03 00:40:47.560 DEBUG librdkafka: librdkafka: ASSIGN [thrd:main]: range: Topic testdrive-data-1766087232 with 1 partition(s) and 1 subscribing member(s) | |
| May 03 00:40:47.560 DEBUG librdkafka: librdkafka: ASSIGN [thrd:main]: range: Member "materialized-e1e65948-a9fe-4d33-b7ff-b904471dd2ad": assigned topic testdrive-data-1766087232 partitions 0..0 | |
| May 03 00:40:47.560 DEBUG librdkafka: librdkafka: ASSIGN [thrd:main]: Group "materialize-kafka-u1/u2" range assignment for 1 member(s) finished in 0.291ms: | |
| May 03 00:40:47.560 DEBUG librdkafka: librdkafka: ASSIGN [thrd:main]: Member "materialized-e1e65948-a9fe-4d33-b7ff-b904471dd2ad" (me) assigned 1 partition(s): | |
| May 03 00:40:47.560 DEBUG librdkafka: librdkafka: ASSIGN [thrd:main]: testdrive-data-1766087232 [0] | |
| May 03 00:40:47.560 DEBUG librdkafka: librdkafka: ASSIGNOR [thrd:main]: Group "materialize-kafka-u1/u2": "range" assignor run for 1 member(s) | |
| May 03 00:40:47.560 DEBUG librdkafka: librdkafka: CGRPJOINSTATE [thrd:main]: Group "materialize-kafka-u1/u2" changed join state wait-metadata -> wait-sync (v1, state up) | |
| May 03 00:40:47.560 DEBUG librdkafka: librdkafka: CGRPLOG [thrd:main]: serving state up | |
| May 03 00:40:47.560 DEBUG librdkafka: librdkafka: SEND [thrd:GroupCoordinator]: GroupCoordinator/0: Sent SyncGroupRequest (v3, 212 bytes @ 0, CorrId 6) | |
| May 03 00:40:47.560 DEBUG librdkafka: librdkafka: BROADCAST [thrd:GroupCoordinator]: Broadcasting state change | |
| May 03 00:40:47.561 DEBUG librdkafka: librdkafka: RECV [thrd:GroupCoordinator]: GroupCoordinator/0: Received SyncGroupResponse (v3, 55 bytes, CorrId 6, rtt 1.04ms) | |
| May 03 00:40:47.561 DEBUG librdkafka: librdkafka: SYNCGROUP [thrd:main]: SyncGroup response: Success (45 bytes of MemberState data) | |
| May 03 00:40:47.561 DEBUG librdkafka: librdkafka: ASSIGN [thrd:main]: Group "materialize-kafka-u1/u2": delegating assign of 1 partition(s) to application rebalance callback on queue rd_kafka_cgrp_new: new assignment | |
| May 03 00:40:47.561 DEBUG librdkafka: librdkafka: CGRPJOINSTATE [thrd:main]: Group "materialize-kafka-u1/u2" changed join state wait-sync -> wait-assign-rebalance_cb (v1, state up) | |
| May 03 00:40:47.561 DEBUG librdkafka: librdkafka: CGRPLOG [thrd:main]: serving state up | |
| May 03 00:40:47.561 DEBUG librdkafka: librdkafka: HEARTBEAT [thrd:main]: GroupCoordinator/0: Heartbeat for group "materialize-kafka-u1/u2" generation id 1 | |
| May 03 00:40:47.562 DEBUG librdkafka: librdkafka: SEND [thrd:GroupCoordinator]: GroupCoordinator/0: Sent HeartbeatRequest (v3, 108 bytes @ 0, CorrId 7) | |
| May 03 00:40:47.562 DEBUG librdkafka: librdkafka: RECV [thrd:GroupCoordinator]: GroupCoordinator/0: Received HeartbeatResponse (v3, 6 bytes, CorrId 7, rtt 0.18ms) | |
| May 03 00:40:47.562 DEBUG librdkafka: librdkafka: CGRPLOG [thrd:main]: serving state up | |
| May 03 00:40:47.563 DEBUG librdkafka: librdkafka: CGRPOP [thrd:main]: Group "materialize-kafka-u1/u2" received op ASSIGN (v0) in state up (join state wait-assign-rebalance_cb, v1 vs 0) | |
| May 03 00:40:47.563 DEBUG librdkafka: librdkafka: ASSIGN [thrd:main]: Group "materialize-kafka-u1/u2": new assignment of 1 partition(s) in join state wait-assign-rebalance_cb | |
| May 03 00:40:47.563 DEBUG librdkafka: librdkafka: TOPIC [thrd:main]: New local topic: testdrive-data-1766087232 | |
| May 03 00:40:47.563 DEBUG librdkafka: librdkafka: TOPPARNEW [thrd:main]: NEW testdrive-data-1766087232 [-1] 0x7f5804003bf0 (at rd_kafka_topic_new0:397) | |
| May 03 00:40:47.563 DEBUG librdkafka: librdkafka: STATE [thrd:main]: Topic testdrive-data-1766087232 changed state unknown -> exists | |
| May 03 00:40:47.563 DEBUG librdkafka: librdkafka: PARTCNT [thrd:main]: Topic testdrive-data-1766087232 partition count changed from 0 to 1 | |
| May 03 00:40:47.563 DEBUG librdkafka: librdkafka: TOPPARNEW [thrd:main]: NEW testdrive-data-1766087232 [0] 0x7f5804003ff0 (at rd_kafka_topic_partition_cnt_update:713) | |
| May 03 00:40:47.563 DEBUG librdkafka: librdkafka: METADATA [thrd:main]: Topic testdrive-data-1766087232 partition 0 Leader 0 | |
| May 03 00:40:47.563 DEBUG librdkafka: librdkafka: BRKDELGT [thrd:main]: testdrive-data-1766087232 [0]: delegate to broker marmoset:9092/0 (rktp 0x7f5804003ff0, term 0, ref 2) | |
| May 03 00:40:47.563 DEBUG librdkafka: librdkafka: BRKDELGT [thrd:main]: testdrive-data-1766087232 [0]: delegating to broker marmoset:9092/0 for partition with 0 messages (0 bytes) queued | |
| May 03 00:40:47.563 DEBUG librdkafka: librdkafka: BRKMIGR [thrd:main]: Migrating topic testdrive-data-1766087232 [0] 0x7f5804003ff0 from (none) to marmoset:9092/0 (sending PARTITION_JOIN to marmoset:9092/0) | |
| May 03 00:40:47.563 DEBUG librdkafka: librdkafka: DESP [thrd:main]: Setting topic testdrive-data-1766087232 [0] partition as desired | |
| May 03 00:40:47.563 DEBUG librdkafka: librdkafka: BARRIER [thrd:main]: Group "materialize-kafka-u1/u2": rd_kafka_cgrp_assign:2575: new version barrier v2 | |
| May 03 00:40:47.563 DEBUG librdkafka: librdkafka: ASSIGN [thrd:main]: Group "materialize-kafka-u1/u2": assigning 1 partition(s) in join state wait-assign-rebalance_cb | |
| May 03 00:40:47.563 DEBUG librdkafka: librdkafka: TOPBRK [thrd:marmoset:9092/0]: marmoset:9092/0: Topic testdrive-data-1766087232 [0]: joining broker (rktp 0x7f5804003ff0, 0 message(s) queued) | |
| May 03 00:40:47.563 DEBUG librdkafka: librdkafka: BROADCAST [thrd:marmoset:9092/0]: Broadcasting state change | |
| May 03 00:40:47.563 DEBUG librdkafka: librdkafka: CGRPJOINSTATE [thrd:main]: Group "materialize-kafka-u1/u2" changed join state wait-assign-rebalance_cb -> assigned (v2, state up) | |
| May 03 00:40:47.564 DEBUG librdkafka: librdkafka: STATE [thrd:marmoset:9092/0]: marmoset:9092/0: Broker changed state INIT -> TRY_CONNECT | |
| May 03 00:40:47.564 DEBUG librdkafka: librdkafka: BARRIER [thrd:main]: Group "materialize-kafka-u1/u2": rd_kafka_cgrp_partitions_fetch_start0:1848: new version barrier v3 | |
| May 03 00:40:47.564 DEBUG librdkafka: librdkafka: BROADCAST [thrd:marmoset:9092/0]: Broadcasting state change | |
| May 03 00:40:47.564 DEBUG librdkafka: librdkafka: FETCHSTART [thrd:main]: Group "materialize-kafka-u1/u2": starting fetchers for 1 assigned partition(s) in join-state assigned (usable_offsets=no, v3, line 2627) | |
| May 03 00:40:47.564 DEBUG librdkafka: librdkafka: FETCHSTART [thrd:main]: List with 1 partition(s): | |
| May 03 00:40:47.564 DEBUG librdkafka: librdkafka: BRKMAIN [thrd:marmoset:9092/0]: marmoset:9092/0: rkb_state: TRY_CONNECT | |
| May 03 00:40:47.564 DEBUG librdkafka: librdkafka: FETCHSTART [thrd:main]: testdrive-data-1766087232 [0] offset INVALID | |
| May 03 00:40:47.564 DEBUG librdkafka: librdkafka: CONNECT [thrd:marmoset:9092/0]: marmoset:9092/0: broker in state TRY_CONNECT connecting | |
| May 03 00:40:47.564 DEBUG librdkafka: librdkafka: OFFSET [thrd:main]: GroupCoordinator/0: OffsetFetchRequest(v1) for 1/1 partition(s) | |
| May 03 00:40:47.564 DEBUG librdkafka: librdkafka: STATE [thrd:marmoset:9092/0]: marmoset:9092/0: Broker changed state TRY_CONNECT -> CONNECT | |
| May 03 00:40:47.564 DEBUG librdkafka: librdkafka: OFFSET [thrd:main]: GroupCoordinator/0: Fetch committed offsets for 1/1 partition(s) | |
| May 03 00:40:47.564 DEBUG librdkafka: librdkafka: BROADCAST [thrd:marmoset:9092/0]: Broadcasting state change | |
| May 03 00:40:47.564 DEBUG librdkafka: librdkafka: CGRPLOG [thrd:main]: serving state up | |
| May 03 00:40:47.564 DEBUG librdkafka: librdkafka: SEND [thrd:GroupCoordinator]: GroupCoordinator/0: Sent OffsetFetchRequest (v1, 90 bytes @ 0, CorrId 8) | |
| May 03 00:40:47.564 DEBUG librdkafka: librdkafka: CONNECT [thrd:marmoset:9092/0]: marmoset:9092/0: Connecting to ipv4#127.0.1.1:9092 (plaintext) with socket 34 | |
| May 03 00:40:47.564 DEBUG librdkafka: librdkafka: CONNECT [thrd:marmoset:9092/0]: marmoset:9092/0: Connected to ipv4#127.0.1.1:9092 | |
| May 03 00:40:47.564 DEBUG librdkafka: librdkafka: RECV [thrd:GroupCoordinator]: GroupCoordinator/0: Received OffsetFetchResponse (v1, 51 bytes, CorrId 8, rtt 0.34ms) | |
| May 03 00:40:47.564 DEBUG librdkafka: librdkafka: CONNECTED [thrd:marmoset:9092/0]: marmoset:9092/0: Connected (#1) | |
| May 03 00:40:47.564 DEBUG librdkafka: librdkafka: OFFSETFETCH [thrd:main]: List with 1 partition(s): | |
| May 03 00:40:47.564 DEBUG librdkafka: librdkafka: FEATURE [thrd:marmoset:9092/0]: marmoset:9092/0: Updated enabled protocol features +ApiVersion to ApiVersion | |
| May 03 00:40:47.564 DEBUG librdkafka: librdkafka: OFFSETFETCH [thrd:main]: testdrive-data-1766087232 [0] offset INVALID | |
| May 03 00:40:47.565 DEBUG librdkafka: librdkafka: OFFSET [thrd:main]: Topic testdrive-data-1766087232 [0]: setting default offset INVALID | |
| May 03 00:40:47.565 DEBUG librdkafka: librdkafka: STATE [thrd:marmoset:9092/0]: marmoset:9092/0: Broker changed state CONNECT -> APIVERSION_QUERY | |
| May 03 00:40:47.565 DEBUG librdkafka: librdkafka: OFFSETFETCH [thrd:main]: GroupCoordinator/0: OffsetFetchResponse: testdrive-data-1766087232 [0] offset -1, metadata 0 byte(s) | |
| May 03 00:40:47.565 DEBUG librdkafka: librdkafka: BROADCAST [thrd:marmoset:9092/0]: Broadcasting state change | |
| May 03 00:40:47.565 DEBUG librdkafka: librdkafka: OFFFETCH [thrd:main]: GroupCoordinator/0: OffsetFetch for 1/1 partition(s) returned Success | |
| May 03 00:40:47.565 DEBUG librdkafka: librdkafka: BRKMAIN [thrd:marmoset:9092/0]: marmoset:9092/0: rkb_state: APIVERSION_QUERY | |
| May 03 00:40:47.565 DEBUG librdkafka: librdkafka: BARRIER [thrd:main]: Group "materialize-kafka-u1/u2": rd_kafka_cgrp_partitions_fetch_start0:1848: new version barrier v4 | |
| May 03 00:40:47.565 DEBUG librdkafka: librdkafka: FETCHSTART [thrd:main]: Group "materialize-kafka-u1/u2": starting fetchers for 1 assigned partition(s) in join-state assigned (usable_offsets=yes, v4, line 1779) | |
| May 03 00:40:47.565 DEBUG librdkafka: librdkafka: SEND [thrd:marmoset:9092/0]: marmoset:9092/0: Sent ApiVersionRequest (v3, 45 bytes @ 0, CorrId 1) | |
| May 03 00:40:47.565 DEBUG librdkafka: librdkafka: FETCHSTART [thrd:main]: List with 1 partition(s): | |
| May 03 00:40:47.565 DEBUG librdkafka: librdkafka: FETCHSTART [thrd:main]: testdrive-data-1766087232 [0] offset INVALID | |
| May 03 00:40:47.565 DEBUG librdkafka: librdkafka: CGRPJOINSTATE [thrd:main]: Group "materialize-kafka-u1/u2" changed join state assigned -> started (v4, state up) | |
| May 03 00:40:47.565 DEBUG librdkafka: librdkafka: BARRIER [thrd:main]: testdrive-data-1766087232 [0]: rd_kafka_toppar_op_fetch_start:2307: new version barrier v2 | |
| May 03 00:40:47.565 DEBUG librdkafka: librdkafka: CONSUMER [thrd:main]: Start consuming testdrive-data-1766087232 [0] at offset INVALID (v2) | |
| May 03 00:40:47.565 DEBUG librdkafka: librdkafka: RECV [thrd:marmoset:9092/0]: marmoset:9092/0: Received ApiVersionResponse (v3, 344 bytes, CorrId 1, rtt 0.22ms) | |
| May 03 00:40:47.565 DEBUG librdkafka: librdkafka: CGRPLOG [thrd:main]: serving state up | |
| May 03 00:40:47.565 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: Broker API support: | |
| May 03 00:40:47.565 DEBUG librdkafka: librdkafka: OP [thrd:main]: testdrive-data-1766087232 [0] received op FETCH_START (v2) in fetch-state none (opv1) | |
| May 03 00:40:47.565 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: ApiKey Produce (0) Versions 0..8 | |
| May 03 00:40:47.565 DEBUG librdkafka: librdkafka: FETCH [thrd:main]: Start fetch for testdrive-data-1766087232 [0] in state none at offset INVALID (v2) | |
| May 03 00:40:47.565 DEBUG librdkafka: librdkafka: PARTSTATE [thrd:main]: Partition testdrive-data-1766087232 [0] changed fetch state none -> offset-query | |
| May 03 00:40:47.565 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: ApiKey Fetch (1) Versions 0..11 | |
| May 03 00:40:47.565 DEBUG librdkafka: librdkafka: OFFSET [thrd:main]: testdrive-data-1766087232 [0]: offset reset (at offset INVALID) to BEGINNING: no previously committed offset available: Local: No offset stored | |
| May 03 00:40:47.565 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: ApiKey Offset (2) Versions 0..5 | |
| May 03 00:40:47.565 DEBUG librdkafka: librdkafka: OFFREQ [thrd:main]: marmoset:9092/0: Partition testdrive-data-1766087232 [0]: querying for logical offset BEGINNING (opv 2) | |
| May 03 00:40:47.565 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: ApiKey Metadata (3) Versions 0..9 | |
| May 03 00:40:47.566 DEBUG librdkafka: librdkafka: OFFSET [thrd:main]: marmoset:9092/0: OffsetRequest (v0, opv 0) for 1 topic(s) and 1 partition(s) | |
| May 03 00:40:47.566 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: ApiKey LeaderAndIsr (4) Versions 0..4 | |
| May 03 00:40:47.566 DEBUG librdkafka: librdkafka: PARTSTATE [thrd:main]: Partition testdrive-data-1766087232 [0] changed fetch state offset-query -> offset-wait | |
| May 03 00:40:47.566 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: ApiKey StopReplica (5) Versions 0..2 | |
| May 03 00:40:47.566 DEBUG librdkafka: librdkafka: CGRPLOG [thrd:main]: serving state up | |
| May 03 00:40:47.566 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: ApiKey UpdateMetadata (6) Versions 0..6 | |
| May 03 00:40:47.566 DEBUG librdkafka: librdkafka: CGRPOP [thrd:main]: Group "materialize-kafka-u1/u2" received op PARTITION_JOIN in state up (join state started, v4) for testdrive-data-1766087232 [0] | |
| May 03 00:40:47.566 DEBUG librdkafka: librdkafka: PARTADD [thrd:main]: Group "materialize-kafka-u1/u2": add testdrive-data-1766087232 [0] | |
| May 03 00:40:47.566 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: ApiKey ControlledShutdown (7) Versions 0..3 | |
| May 03 00:40:47.566 DEBUG librdkafka: librdkafka: CGRPLOG [thrd:main]: serving state up | |
| May 03 00:40:47.566 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: ApiKey OffsetCommit (8) Versions 0..8 | |
| May 03 00:40:47.566 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: ApiKey OffsetFetch (9) Versions 0..7 | |
| May 03 00:40:47.566 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: ApiKey FindCoordinator (10) Versions 0..3 | |
| May 03 00:40:47.566 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: ApiKey JoinGroup (11) Versions 0..7 | |
| May 03 00:40:47.566 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: ApiKey Heartbeat (12) Versions 0..4 | |
| May 03 00:40:47.566 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: ApiKey LeaveGroup (13) Versions 0..4 | |
| May 03 00:40:47.566 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: ApiKey SyncGroup (14) Versions 0..5 | |
| May 03 00:40:47.566 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: ApiKey DescribeGroups (15) Versions 0..5 | |
| May 03 00:40:47.566 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: ApiKey ListGroups (16) Versions 0..3 | |
| May 03 00:40:47.567 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: ApiKey SaslHandshake (17) Versions 0..1 | |
| May 03 00:40:47.567 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: ApiKey ApiVersion (18) Versions 0..3 | |
| May 03 00:40:47.567 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: ApiKey CreateTopics (19) Versions 0..5 | |
| May 03 00:40:47.567 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: ApiKey DeleteTopics (20) Versions 0..4 | |
| May 03 00:40:47.567 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: ApiKey DeleteRecords (21) Versions 0..1 | |
| May 03 00:40:47.567 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: ApiKey InitProducerId (22) Versions 0..3 | |
| May 03 00:40:47.567 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: ApiKey OffsetForLeaderEpoch (23) Versions 0..3 | |
| May 03 00:40:47.567 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: ApiKey AddPartitionsToTxn (24) Versions 0..1 | |
| May 03 00:40:47.567 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: ApiKey AddOffsetsToTxn (25) Versions 0..1 | |
| May 03 00:40:47.567 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: ApiKey EndTxn (26) Versions 0..1 | |
| May 03 00:40:47.567 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: ApiKey WriteTxnMarkers (27) Versions 0..0 | |
| May 03 00:40:47.567 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: ApiKey TxnOffsetCommit (28) Versions 0..3 | |
| May 03 00:40:47.567 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: ApiKey DescribeAcls (29) Versions 0..2 | |
| May 03 00:40:47.567 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: ApiKey CreateAcls (30) Versions 0..2 | |
| May 03 00:40:47.568 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: ApiKey DeleteAcls (31) Versions 0..2 | |
| May 03 00:40:47.568 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: ApiKey DescribeConfigs (32) Versions 0..2 | |
| May 03 00:40:47.568 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: ApiKey AlterConfigs (33) Versions 0..1 | |
| May 03 00:40:47.568 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: ApiKey AlterReplicaLogDirs (34) Versions 0..1 | |
| May 03 00:40:47.568 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: ApiKey DescribeLogDirs (35) Versions 0..1 | |
| May 03 00:40:47.568 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: ApiKey SaslAuthenticate (36) Versions 0..2 | |
| May 03 00:40:47.568 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: ApiKey CreatePartitions (37) Versions 0..2 | |
| May 03 00:40:47.568 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: ApiKey CreateDelegationToken (38) Versions 0..2 | |
| May 03 00:40:47.568 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: ApiKey RenewDelegationToken (39) Versions 0..2 | |
| May 03 00:40:47.568 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: ApiKey ExpireDelegationToken (40) Versions 0..2 | |
| May 03 00:40:47.568 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: ApiKey DescribeDelegationToken (41) Versions 0..2 | |
| May 03 00:40:47.568 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: ApiKey DeleteGroups (42) Versions 0..2 | |
| May 03 00:40:47.568 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: ApiKey Unknown-43? (43) Versions 0..2 | |
| May 03 00:40:47.569 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: ApiKey Unknown-44? (44) Versions 0..1 | |
| May 03 00:40:47.569 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: ApiKey Unknown-45? (45) Versions 0..0 | |
| May 03 00:40:47.569 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: ApiKey Unknown-46? (46) Versions 0..0 | |
| May 03 00:40:47.569 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: ApiKey Unknown-47? (47) Versions 0..0 | |
| May 03 00:40:47.569 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: Feature MsgVer1: Produce (2..2) supported by broker | |
| May 03 00:40:47.569 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: Feature MsgVer1: Fetch (2..2) supported by broker | |
| May 03 00:40:47.569 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: Enabling feature MsgVer1 | |
| May 03 00:40:47.569 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: Feature MsgVer2: Produce (3..3) supported by broker | |
| May 03 00:40:47.569 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: Feature MsgVer2: Fetch (4..4) supported by broker | |
| May 03 00:40:47.569 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: Enabling feature MsgVer2 | |
| May 03 00:40:47.569 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: Feature ApiVersion: ApiVersion (0..0) supported by broker | |
| May 03 00:40:47.569 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: Enabling feature ApiVersion | |
| May 03 00:40:47.569 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: Feature BrokerGroupCoordinator: FindCoordinator (0..0) supported by broker | |
| May 03 00:40:47.569 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: Enabling feature BrokerGroupCoordinator | |
| May 03 00:40:47.570 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: Feature BrokerBalancedConsumer: FindCoordinator (0..0) supported by broker | |
| May 03 00:40:47.570 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: Feature BrokerBalancedConsumer: OffsetCommit (1..2) supported by broker | |
| May 03 00:40:47.570 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: Feature BrokerBalancedConsumer: OffsetFetch (1..1) supported by broker | |
| May 03 00:40:47.570 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: Feature BrokerBalancedConsumer: JoinGroup (0..0) supported by broker | |
| May 03 00:40:47.570 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: Feature BrokerBalancedConsumer: SyncGroup (0..0) supported by broker | |
| May 03 00:40:47.570 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: Feature BrokerBalancedConsumer: Heartbeat (0..0) supported by broker | |
| May 03 00:40:47.570 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: Feature BrokerBalancedConsumer: LeaveGroup (0..0) supported by broker | |
| May 03 00:40:47.570 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: Enabling feature BrokerBalancedConsumer | |
| May 03 00:40:47.570 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: Feature ThrottleTime: Produce (1..2) supported by broker | |
| May 03 00:40:47.570 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: Feature ThrottleTime: Fetch (1..2) supported by broker | |
| May 03 00:40:47.570 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: Enabling feature ThrottleTime | |
| May 03 00:40:47.570 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: Feature Sasl: JoinGroup (0..0) supported by broker | |
| May 03 00:40:47.570 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: Enabling feature Sasl | |
| May 03 00:40:47.570 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: Feature SaslHandshake: SaslHandshake (0..0) supported by broker | |
| May 03 00:40:47.571 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: Enabling feature SaslHandshake | |
| May 03 00:40:47.571 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: Feature LZ4: FindCoordinator (0..0) supported by broker | |
| May 03 00:40:47.571 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: Enabling feature LZ4 | |
| May 03 00:40:47.571 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: Feature OffsetTime: Offset (1..1) supported by broker | |
| May 03 00:40:47.571 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: Enabling feature OffsetTime | |
| May 03 00:40:47.571 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: Feature IdempotentProducer: InitProducerId (0..0) supported by broker | |
| May 03 00:40:47.571 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: Enabling feature IdempotentProducer | |
| May 03 00:40:47.571 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: Feature ZSTD: Produce (7..7) supported by broker | |
| May 03 00:40:47.571 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: Feature ZSTD: Fetch (10..10) supported by broker | |
| May 03 00:40:47.571 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: Enabling feature ZSTD | |
| May 03 00:40:47.571 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: Feature SaslAuthReq: SaslHandshake (1..1) supported by broker | |
| May 03 00:40:47.571 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: Feature SaslAuthReq: SaslAuthenticate (0..0) supported by broker | |
| May 03 00:40:47.571 DEBUG librdkafka: librdkafka: APIVERSION [thrd:marmoset:9092/0]: marmoset:9092/0: Enabling feature SaslAuthReq | |
| May 03 00:40:47.572 DEBUG librdkafka: librdkafka: FEATURE [thrd:marmoset:9092/0]: marmoset:9092/0: Updated enabled protocol features to MsgVer1,ApiVersion,BrokerBalancedConsumer,ThrottleTime,Sasl,SaslHandshake,BrokerGroupCoordinator,LZ4,OffsetTime,MsgVer2,IdempotentProducer,ZSTD,SaslAuthReq | |
| May 03 00:40:47.572 DEBUG librdkafka: librdkafka: STATE [thrd:marmoset:9092/0]: marmoset:9092/0: Broker changed state APIVERSION_QUERY -> UP | |
| May 03 00:40:47.572 DEBUG librdkafka: librdkafka: BROADCAST [thrd:marmoset:9092/0]: Broadcasting state change | |
| May 03 00:40:47.572 DEBUG librdkafka: librdkafka: METADATA [thrd:marmoset:9092/0]: Skipping metadata refresh of 1 topic(s): connected: already being requested | |
| May 03 00:40:47.572 DEBUG librdkafka: librdkafka: BRKMAIN [thrd:marmoset:9092/0]: marmoset:9092/0: rkb_state: UP | |
| May 03 00:40:47.572 DEBUG librdkafka: librdkafka: SEND [thrd:marmoset:9092/0]: marmoset:9092/0: Sent OffsetRequest (v0, 81 bytes @ 0, CorrId 2) | |
| May 03 00:40:47.572 DEBUG librdkafka: librdkafka: RECV [thrd:marmoset:9092/0]: marmoset:9092/0: Received OffsetResponse (v0, 53 bytes, CorrId 2, rtt 0.20ms) | |
| May 03 00:40:47.572 DEBUG librdkafka: librdkafka: OFFSET [thrd:main]: marmoset:9092/0: Offset reply for topic testdrive-data-1766087232 [0] (v2 vs v2) | |
| May 03 00:40:47.572 DEBUG librdkafka: librdkafka: OFFSET [thrd:main]: Offset BEGINNING request for testdrive-data-1766087232 [0] returned offset 0 (0) | |
| May 03 00:40:47.572 DEBUG librdkafka: librdkafka: PARTSTATE [thrd:main]: Partition testdrive-data-1766087232 [0] changed fetch state offset-wait -> active | |
| May 03 00:40:47.572 DEBUG librdkafka: librdkafka: FETCH [thrd:main]: Partition testdrive-data-1766087232 [0] start fetching at offset 0 | |
| May 03 00:40:47.573 DEBUG librdkafka: librdkafka: WAKEUP [thrd:main]: marmoset:9092/0: Wake-up | |
| May 03 00:40:47.573 DEBUG librdkafka: librdkafka: CGRPLOG [thrd:main]: serving state up | |
| May 03 00:40:47.573 DEBUG librdkafka: librdkafka: FETCHDEC [thrd:marmoset:9092/0]: Topic testdrive-data-1766087232 [0]: fetch decide: updating to version 2 (was 0) at offset 0 (was 0) | |
| May 03 00:40:47.573 DEBUG librdkafka: librdkafka: FETCH [thrd:marmoset:9092/0]: marmoset:9092/0: Topic testdrive-data-1766087232 [0] in state active at offset 0 (0/100000 msgs, 0/1048576 kb queued, opv 2) is fetchable | |
| May 03 00:40:47.573 DEBUG librdkafka: librdkafka: FETCHADD [thrd:marmoset:9092/0]: marmoset:9092/0: Added testdrive-data-1766087232 [0] to fetch list (1 entries, opv 2, 0 messages queued): fetchable | |
| May 03 00:40:47.573 DEBUG librdkafka: librdkafka: FETCH [thrd:marmoset:9092/0]: marmoset:9092/0: Fetch topic testdrive-data-1766087232 [0] at offset 0 (v2) | |
| May 03 00:40:47.573 DEBUG librdkafka: librdkafka: FETCH [thrd:marmoset:9092/0]: marmoset:9092/0: Fetch 1/1/1 toppar(s) | |
| May 03 00:40:47.573 DEBUG librdkafka: librdkafka: SEND [thrd:marmoset:9092/0]: marmoset:9092/0: Sent FetchRequest (v11, 120 bytes @ 0, CorrId 3) | |
| May 03 00:40:47.574 DEBUG librdkafka: librdkafka: RECV [thrd:marmoset:9092/0]: marmoset:9092/0: Received FetchResponse (v11, 163 bytes, CorrId 3, rtt 0.58ms) | |
| May 03 00:40:47.574 DEBUG librdkafka: librdkafka: FETCH [thrd:marmoset:9092/0]: marmoset:9092/0: Topic testdrive-data-1766087232 [0] MessageSet size 76, error "Success", MaxOffset 1, LSO 1, Ver 2/2 | |
| May 03 00:40:47.574 DEBUG librdkafka: librdkafka: CONSUME [thrd:marmoset:9092/0]: marmoset:9092/0: Enqueue 1 message(s) (8 bytes, 1 ops) on testdrive-data-1766087232 [0] fetch queue (qlen 1, v2, last_offset 0, 0 ctrl msgs, uncompressed) | |
| May 03 00:40:47.574 DEBUG librdkafka: librdkafka: FETCH [thrd:marmoset:9092/0]: marmoset:9092/0: Fetch topic testdrive-data-1766087232 [0] at offset 1 (v2) | |
| May 03 00:40:47.574 DEBUG librdkafka: librdkafka: FETCH [thrd:marmoset:9092/0]: marmoset:9092/0: Fetch 1/1/1 toppar(s) | |
| May 03 00:40:47.574 DEBUG librdkafka: librdkafka: SEND [thrd:marmoset:9092/0]: marmoset:9092/0: Sent FetchRequest (v11, 120 bytes @ 0, CorrId 4) | |
| May 03 00:40:47.675 DEBUG librdkafka: librdkafka: RECV [thrd:marmoset:9092/0]: marmoset:9092/0: Received FetchResponse (v11, 87 bytes, CorrId 4, rtt 100.48ms) | |
| May 03 00:40:47.675 DEBUG librdkafka: librdkafka: FETCH [thrd:marmoset:9092/0]: marmoset:9092/0: Topic testdrive-data-1766087232 [0] MessageSet size 0, error "Success", MaxOffset 1, LSO 1, Ver 2/2 | |
| May 03 00:40:47.675 DEBUG librdkafka: librdkafka: FETCH [thrd:marmoset:9092/0]: marmoset:9092/0: Fetch topic testdrive-data-1766087232 [0] at offset 1 (v2) | |
| May 03 00:40:47.675 DEBUG librdkafka: librdkafka: FETCH [thrd:marmoset:9092/0]: marmoset:9092/0: Fetch 1/1/1 toppar(s) | |
| May 03 00:40:47.675 DEBUG librdkafka: librdkafka: SEND [thrd:marmoset:9092/0]: marmoset:9092/0: Sent FetchRequest (v11, 120 bytes @ 0, CorrId 5) | |
| May 03 00:40:47.776 DEBUG librdkafka: librdkafka: RECV [thrd:marmoset:9092/0]: marmoset:9092/0: Received FetchResponse (v11, 87 bytes, CorrId 5, rtt 100.37ms) | |
| May 03 00:40:47.776 DEBUG librdkafka: librdkafka: FETCH [thrd:marmoset:9092/0]: marmoset:9092/0: Topic testdrive-data-1766087232 [0] MessageSet size 0, error "Success", MaxOffset 1, LSO 1, Ver 2/2 | |
| May 03 00:40:47.776 DEBUG librdkafka: librdkafka: FETCH [thrd:marmoset:9092/0]: marmoset:9092/0: Fetch topic testdrive-data-1766087232 [0] at offset 1 (v2) | |
| May 03 00:40:47.776 DEBUG librdkafka: librdkafka: FETCH [thrd:marmoset:9092/0]: marmoset:9092/0: Fetch 1/1/1 toppar(s) | |
| May 03 00:40:47.776 DEBUG librdkafka: librdkafka: SEND [thrd:marmoset:9092/0]: marmoset:9092/0: Sent FetchRequest (v11, 120 bytes @ 0, CorrId 6) | |
| May 03 00:40:47.877 DEBUG librdkafka: librdkafka: RECV [thrd:marmoset:9092/0]: marmoset:9092/0: Received FetchResponse (v11, 87 bytes, CorrId 6, rtt 100.66ms) | |
| May 03 00:40:47.877 DEBUG librdkafka: librdkafka: FETCH [thrd:marmoset:9092/0]: marmoset:9092/0: Topic testdrive-data-1766087232 [0] MessageSet size 0, error "Success", MaxOffset 1, LSO 1, Ver 2/2 | |
| May 03 00:40:47.877 DEBUG librdkafka: librdkafka: FETCH [thrd:marmoset:9092/0]: marmoset:9092/0: Fetch topic testdrive-data-1766087232 [0] at offset 1 (v2) | |
| May 03 00:40:47.877 DEBUG librdkafka: librdkafka: FETCH [thrd:marmoset:9092/0]: marmoset:9092/0: Fetch 1/1/1 toppar(s) | |
| May 03 00:40:47.877 DEBUG librdkafka: librdkafka: SEND [thrd:marmoset:9092/0]: marmoset:9092/0: Sent FetchRequest (v11, 120 bytes @ 0, CorrId 7) | |
| May 03 00:40:47.978 DEBUG librdkafka: librdkafka: RECV [thrd:marmoset:9092/0]: marmoset:9092/0: Received FetchResponse (v11, 87 bytes, CorrId 7, rtt 100.41ms) | |
| May 03 00:40:47.978 DEBUG librdkafka: librdkafka: FETCH [thrd:marmoset:9092/0]: marmoset:9092/0: Topic testdrive-data-1766087232 [0] MessageSet size 0, error "Success", MaxOffset 1, LSO 1, Ver 2/2 | |
| May 03 00:40:47.978 DEBUG librdkafka: librdkafka: FETCH [thrd:marmoset:9092/0]: marmoset:9092/0: Fetch topic testdrive-data-1766087232 [0] at offset 1 (v2) | |
| May 03 00:40:47.978 DEBUG librdkafka: librdkafka: FETCH [thrd:marmoset:9092/0]: marmoset:9092/0: Fetch 1/1/1 toppar(s) | |
| May 03 00:40:47.978 DEBUG librdkafka: librdkafka: SEND [thrd:marmoset:9092/0]: marmoset:9092/0: Sent FetchRequest (v11, 120 bytes @ 0, CorrId 8) | |
| May 03 00:40:48.065 DEBUG librdkafka: librdkafka: CGRPLOG [thrd:main]: serving state up | |
| May 03 00:40:48.065 DEBUG librdkafka: librdkafka: CGRPLOG [thrd:main]: serving state up | |
| May 03 00:40:48.065 DEBUG librdkafka: librdkafka: CGRPLOG [thrd:main]: serving state up | |
| May 03 00:40:48.065 DEBUG librdkafka: librdkafka: CGRPLOG [thrd:main]: serving state up | |
| May 03 00:40:48.065 DEBUG librdkafka: librdkafka: CGRPLOG [thrd:main]: serving state up | |
| May 03 00:40:48.079 DEBUG librdkafka: librdkafka: RECV [thrd:marmoset:9092/0]: marmoset:9092/0: Received FetchResponse (v11, 87 bytes, CorrId 8, rtt 100.79ms) | |
| May 03 00:40:48.079 DEBUG librdkafka: librdkafka: FETCH [thrd:marmoset:9092/0]: marmoset:9092/0: Topic testdrive-data-1766087232 [0] MessageSet size 0, error "Success", MaxOffset 1, LSO 1, Ver 2/2 | |
| May 03 00:40:48.079 DEBUG librdkafka: librdkafka: FETCH [thrd:marmoset:9092/0]: marmoset:9092/0: Fetch topic testdrive-data-1766087232 [0] at offset 1 (v2) | |
| May 03 00:40:48.079 DEBUG librdkafka: librdkafka: FETCH [thrd:marmoset:9092/0]: marmoset:9092/0: Fetch 1/1/1 toppar(s) | |
| May 03 00:40:48.079 DEBUG librdkafka: librdkafka: SEND [thrd:marmoset:9092/0]: marmoset:9092/0: Sent FetchRequest (v11, 120 bytes @ 0, CorrId 9) | |
| May 03 00:40:48.180 DEBUG librdkafka: librdkafka: RECV [thrd:marmoset:9092/0]: marmoset:9092/0: Received FetchResponse (v11, 87 bytes, CorrId 9, rtt 100.44ms) | |
| May 03 00:40:48.180 DEBUG librdkafka: librdkafka: FETCH [thrd:marmoset:9092/0]: marmoset:9092/0: Topic testdrive-data-1766087232 [0] MessageSet size 0, error "Success", MaxOffset 1, LSO 1, Ver 2/2 | |
| May 03 00:40:48.180 DEBUG librdkafka: librdkafka: FETCH [thrd:marmoset:9092/0]: marmoset:9092/0: Fetch topic testdrive-data-1766087232 [0] at offset 1 (v2) | |
| May 03 00:40:48.180 DEBUG librdkafka: librdkafka: FETCH [thrd:marmoset:9092/0]: marmoset:9092/0: Fetch 1/1/1 toppar(s) | |
| May 03 00:40:48.180 DEBUG librdkafka: librdkafka: SEND [thrd:marmoset:9092/0]: marmoset:9092/0: Sent FetchRequest (v11, 120 bytes @ 0, CorrId 10) | |
| May 03 00:40:48.281 DEBUG librdkafka: librdkafka: RECV [thrd:marmoset:9092/0]: marmoset:9092/0: Received FetchResponse (v11, 87 bytes, CorrId 10, rtt 100.59ms) | |
| May 03 00:40:48.281 DEBUG librdkafka: librdkafka: FETCH [thrd:marmoset:9092/0]: marmoset:9092/0: Topic testdrive-data-1766087232 [0] MessageSet size 0, error "Success", MaxOffset 1, LSO 1, Ver 2/2 | |
| May 03 00:40:48.281 DEBUG librdkafka: librdkafka: FETCH [thrd:marmoset:9092/0]: marmoset:9092/0: Fetch topic testdrive-data-1766087232 [0] at offset 1 (v2) | |
| May 03 00:40:48.281 DEBUG librdkafka: librdkafka: FETCH [thrd:marmoset:9092/0]: marmoset:9092/0: Fetch 1/1/1 toppar(s) | |
| May 03 00:40:48.281 DEBUG librdkafka: librdkafka: SEND [thrd:marmoset:9092/0]: marmoset:9092/0: Sent FetchRequest (v11, 120 bytes @ 0, CorrId 11) | |
| May 03 00:40:48.382 DEBUG librdkafka: librdkafka: RECV [thrd:marmoset:9092/0]: marmoset:9092/0: Received FetchResponse (v11, 87 bytes, CorrId 11, rtt 100.48ms) | |
| May 03 00:40:48.382 DEBUG librdkafka: librdkafka: FETCH [thrd:marmoset:9092/0]: marmoset:9092/0: Topic testdrive-data-1766087232 [0] MessageSet size 0, error "Success", MaxOffset 1, LSO 1, Ver 2/2 | |
| May 03 00:40:48.382 DEBUG librdkafka: librdkafka: FETCH [thrd:marmoset:9092/0]: marmoset:9092/0: Fetch topic testdrive-data-1766087232 [0] at offset 1 (v2) | |
| May 03 00:40:48.382 DEBUG librdkafka: librdkafka: FETCH [thrd:marmoset:9092/0]: marmoset:9092/0: Fetch 1/1/1 toppar(s) | |
| May 03 00:40:48.382 DEBUG librdkafka: librdkafka: SEND [thrd:marmoset:9092/0]: marmoset:9092/0: Sent FetchRequest (v11, 120 bytes @ 0, CorrId 12) | |
| May 03 00:40:48.452 DEBUG librdkafka: librdkafka: RECV [thrd:marmoset:9092/0]: marmoset:9092/0: Received FetchResponse (v11, 164 bytes, CorrId 12, rtt 70.00ms) | |
| May 03 00:40:48.453 DEBUG librdkafka: librdkafka: FETCH [thrd:marmoset:9092/0]: marmoset:9092/0: Topic testdrive-data-1766087232 [0] MessageSet size 77, error "Success", MaxOffset 2, LSO 2, Ver 2/2 | |
| May 03 00:40:48.453 DEBUG librdkafka: librdkafka: CONSUME [thrd:marmoset:9092/0]: marmoset:9092/0: Enqueue 1 message(s) (9 bytes, 1 ops) on testdrive-data-1766087232 [0] fetch queue (qlen 1, v2, last_offset 1, 0 ctrl msgs, uncompressed) | |
| May 03 00:40:48.453 DEBUG librdkafka: librdkafka: FETCH [thrd:marmoset:9092/0]: marmoset:9092/0: Fetch topic testdrive-data-1766087232 [0] at offset 2 (v2) | |
| May 03 00:40:48.453 DEBUG librdkafka: librdkafka: FETCH [thrd:marmoset:9092/0]: marmoset:9092/0: Fetch 1/1/1 toppar(s) | |
| May 03 00:40:48.453 DEBUG librdkafka: librdkafka: SEND [thrd:marmoset:9092/0]: marmoset:9092/0: Sent FetchRequest (v11, 120 bytes @ 0, CorrId 13) | |
| May 03 00:40:48.487 DEBUG librdkafka: librdkafka: MEMBERID [thrd:app]: Group "materialize-kafka-u3/u4": updating member id "(not-set)" -> "" | |
| May 03 00:40:48.487 DEBUG librdkafka: librdkafka: WAKEUPFD [thrd:app]: GroupCoordinator: Enabled low-latency ops queue wake-ups | |
| May 03 00:40:48.487 DEBUG librdkafka: librdkafka: BROKER [thrd:app]: GroupCoordinator: Added new broker with NodeId -1 | |
| May 03 00:40:48.487 DEBUG librdkafka: librdkafka: WAKEUPFD [thrd:app]: localhost:9092/bootstrap: Enabled low-latency ops queue wake-ups | |
| May 03 00:40:48.487 DEBUG librdkafka: librdkafka: BROKER [thrd:app]: localhost:9092/bootstrap: Added new broker with NodeId -1 | |
| May 03 00:40:48.487 DEBUG librdkafka: librdkafka: INIT [thrd:app]: librdkafka v1.4.2 (0x10402ff) materialized#consumer-6 initialized (builtin.features gzip,snappy,ssl,sasl,regex,lz4,sasl_gssapi,sasl_plain,sasl_scram,plugins,sasl_oauthbearer, CMAKE GNU GNU PKGCONFIG HDRHISTOGRAM ZLIB LIBDL PLUGINS SSL SASL_SCRAM SASL_OAUTHBEARER SASL_CYRUS C11THREADS CRC32C_HW SNAPPY SOCKEM, debug 0xfffff) | |
| May 03 00:40:48.487 DEBUG librdkafka: librdkafka: BRKMAIN [thrd:GroupCoordinator]: GroupCoordinator: Enter main broker thread | |
| May 03 00:40:48.488 DEBUG librdkafka: librdkafka: BRKMAIN [thrd:GroupCoordinator]: GroupCoordinator: rkb_state: INIT | |
| May 03 00:40:48.488 DEBUG librdkafka: librdkafka: BRKMAIN [thrd::0/internal]: :0/internal: Enter main broker thread | |
| May 03 00:40:48.488 DEBUG librdkafka: librdkafka: BRKMAIN [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enter main broker thread | |
| May 03 00:40:48.488 DEBUG librdkafka: librdkafka: BRKMAIN [thrd::0/internal]: :0/internal: rkb_state: INIT | |
| May 03 00:40:48.488 DEBUG librdkafka: librdkafka: CGRPOP [thrd:main]: Group "materialize-kafka-u3/u4" received op SUBSCRIBE (v0) in state init (join state init, v1 vs 0) | |
| May 03 00:40:48.488 DEBUG librdkafka: librdkafka: BRKMAIN [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: rkb_state: INIT | |
| May 03 00:40:48.488 DEBUG librdkafka: librdkafka: SUBSCRIBE [thrd:main]: Group "materialize-kafka-u3/u4": subscribe to new subscription of 1 topics (join state init) | |
| May 03 00:40:48.488 DEBUG librdkafka: librdkafka: UNSUBSCRIBE [thrd:main]: Group "materialize-kafka-u3/u4": unsubscribe from current unset subscription of 0 topics (leave group=no, join state init, v1) | |
| May 03 00:40:48.488 DEBUG librdkafka: librdkafka: GRPLEADER [thrd:main]: Group "materialize-kafka-u3/u4": resetting group leader info: unsubscribe | |
| May 03 00:40:48.488 DEBUG librdkafka: librdkafka: REBALANCE [thrd:main]: Group "materialize-kafka-u3/u4" is rebalancing in state init (join-state init) without assignment: unsubscribe | |
| May 03 00:40:48.488 DEBUG librdkafka: librdkafka: CGRPJOINSTATE [thrd:main]: Group "materialize-kafka-u3/u4" changed join state init -> wait-unassign (v1, state init) | |
| May 03 00:40:48.488 DEBUG librdkafka: librdkafka: UNASSIGN [thrd:main]: Group "materialize-kafka-u3/u4": unassign done in state init (join state wait-unassign): without new assignment: unassign (no previous assignment) | |
| May 03 00:40:48.488 DEBUG librdkafka: librdkafka: CGRPJOINSTATE [thrd:main]: Group "materialize-kafka-u3/u4" changed join state wait-unassign -> init (v1, state init) | |
| May 03 00:40:48.488 DEBUG librdkafka: librdkafka: CGRPLOG [thrd:main]: serving state init | |
| May 03 00:40:48.489 DEBUG librdkafka: librdkafka: CGRPSTATE [thrd:main]: Group "materialize-kafka-u3/u4" changed state init -> query-coord (v1, join-state init) | |
| May 03 00:40:48.489 DEBUG librdkafka: librdkafka: BROADCAST [thrd:main]: Broadcasting state change | |
| May 03 00:40:48.489 DEBUG librdkafka: librdkafka: CONNECT [thrd:main]: localhost:9092/bootstrap: Selected for cluster connection: coordinator query (broker has 0 connection attempt(s)) | |
| May 03 00:40:48.489 DEBUG librdkafka: librdkafka: CGRPQUERY [thrd:main]: Group "materialize-kafka-u3/u4": no broker available for coordinator query: intervaled in state query-coord | |
| May 03 00:40:48.489 DEBUG librdkafka: librdkafka: CONNECT [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received CONNECT op | |
| May 03 00:40:48.489 DEBUG librdkafka: librdkafka: STATE [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state INIT -> TRY_CONNECT | |
| May 03 00:40:48.489 DEBUG librdkafka: librdkafka: BROADCAST [thrd:localhost:9092/bootstrap]: Broadcasting state change | |
| May 03 00:40:48.489 DEBUG librdkafka: librdkafka: BRKMAIN [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: rkb_state: TRY_CONNECT | |
| May 03 00:40:48.489 DEBUG librdkafka: librdkafka: CONNECT [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: broker in state TRY_CONNECT connecting | |
| May 03 00:40:48.489 DEBUG librdkafka: librdkafka: STATE [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state TRY_CONNECT -> CONNECT | |
| May 03 00:40:48.489 DEBUG librdkafka: librdkafka: BROADCAST [thrd:localhost:9092/bootstrap]: Broadcasting state change | |
| May 03 00:40:48.490 DEBUG librdkafka: librdkafka: CONNECT [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connecting to ipv4#127.0.0.1:9092 (plaintext) with socket 44 | |
| May 03 00:40:48.490 DEBUG librdkafka: librdkafka: CONNECT [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connected to ipv4#127.0.0.1:9092 | |
| May 03 00:40:48.490 DEBUG librdkafka: librdkafka: CONNECTED [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connected (#1) | |
| May 03 00:40:48.490 DEBUG librdkafka: librdkafka: FEATURE [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Updated enabled protocol features +ApiVersion to ApiVersion | |
| May 03 00:40:48.490 DEBUG librdkafka: librdkafka: STATE [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state CONNECT -> APIVERSION_QUERY | |
| May 03 00:40:48.490 DEBUG librdkafka: librdkafka: BROADCAST [thrd:localhost:9092/bootstrap]: Broadcasting state change | |
| May 03 00:40:48.490 DEBUG librdkafka: librdkafka: BRKMAIN [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: rkb_state: APIVERSION_QUERY | |
| May 03 00:40:48.490 DEBUG librdkafka: librdkafka: SEND [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Sent ApiVersionRequest (v3, 45 bytes @ 0, CorrId 1) | |
| May 03 00:40:48.491 DEBUG librdkafka: librdkafka: RECV [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received ApiVersionResponse (v3, 344 bytes, CorrId 1, rtt 0.20ms) | |
| May 03 00:40:48.491 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker API support: | |
| May 03 00:40:48.491 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey Produce (0) Versions 0..8 | |
| May 03 00:40:48.491 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey Fetch (1) Versions 0..11 | |
| May 03 00:40:48.491 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey Offset (2) Versions 0..5 | |
| May 03 00:40:48.491 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey Metadata (3) Versions 0..9 | |
| May 03 00:40:48.491 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey LeaderAndIsr (4) Versions 0..4 | |
| May 03 00:40:48.491 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey StopReplica (5) Versions 0..2 | |
| May 03 00:40:48.491 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey UpdateMetadata (6) Versions 0..6 | |
| May 03 00:40:48.491 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey ControlledShutdown (7) Versions 0..3 | |
| May 03 00:40:48.492 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey OffsetCommit (8) Versions 0..8 | |
| May 03 00:40:48.492 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey OffsetFetch (9) Versions 0..7 | |
| May 03 00:40:48.492 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey FindCoordinator (10) Versions 0..3 | |
| May 03 00:40:48.492 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey JoinGroup (11) Versions 0..7 | |
| May 03 00:40:48.492 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey Heartbeat (12) Versions 0..4 | |
| May 03 00:40:48.492 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey LeaveGroup (13) Versions 0..4 | |
| May 03 00:40:48.492 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey SyncGroup (14) Versions 0..5 | |
| May 03 00:40:48.492 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey DescribeGroups (15) Versions 0..5 | |
| May 03 00:40:48.492 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey ListGroups (16) Versions 0..3 | |
| May 03 00:40:48.492 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey SaslHandshake (17) Versions 0..1 | |
| May 03 00:40:48.492 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey ApiVersion (18) Versions 0..3 | |
| May 03 00:40:48.492 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey CreateTopics (19) Versions 0..5 | |
| May 03 00:40:48.492 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey DeleteTopics (20) Versions 0..4 | |
| May 03 00:40:48.493 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey DeleteRecords (21) Versions 0..1 | |
| May 03 00:40:48.493 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey InitProducerId (22) Versions 0..3 | |
| May 03 00:40:48.493 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey OffsetForLeaderEpoch (23) Versions 0..3 | |
| May 03 00:40:48.493 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey AddPartitionsToTxn (24) Versions 0..1 | |
| May 03 00:40:48.493 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey AddOffsetsToTxn (25) Versions 0..1 | |
| May 03 00:40:48.493 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey EndTxn (26) Versions 0..1 | |
| May 03 00:40:48.493 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey WriteTxnMarkers (27) Versions 0..0 | |
| May 03 00:40:48.493 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey TxnOffsetCommit (28) Versions 0..3 | |
| May 03 00:40:48.493 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey DescribeAcls (29) Versions 0..2 | |
| May 03 00:40:48.493 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey CreateAcls (30) Versions 0..2 | |
| May 03 00:40:48.493 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey DeleteAcls (31) Versions 0..2 | |
| May 03 00:40:48.493 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey DescribeConfigs (32) Versions 0..2 | |
| May 03 00:40:48.493 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey AlterConfigs (33) Versions 0..1 | |
| May 03 00:40:48.494 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey AlterReplicaLogDirs (34) Versions 0..1 | |
| May 03 00:40:48.494 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey DescribeLogDirs (35) Versions 0..1 | |
| May 03 00:40:48.494 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey SaslAuthenticate (36) Versions 0..2 | |
| May 03 00:40:48.494 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey CreatePartitions (37) Versions 0..2 | |
| May 03 00:40:48.494 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey CreateDelegationToken (38) Versions 0..2 | |
| May 03 00:40:48.494 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey RenewDelegationToken (39) Versions 0..2 | |
| May 03 00:40:48.494 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey ExpireDelegationToken (40) Versions 0..2 | |
| May 03 00:40:48.494 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey DescribeDelegationToken (41) Versions 0..2 | |
| May 03 00:40:48.494 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey DeleteGroups (42) Versions 0..2 | |
| May 03 00:40:48.494 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey Unknown-43? (43) Versions 0..2 | |
| May 03 00:40:48.494 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey Unknown-44? (44) Versions 0..1 | |
| May 03 00:40:48.494 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey Unknown-45? (45) Versions 0..0 | |
| May 03 00:40:48.494 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey Unknown-46? (46) Versions 0..0 | |
| May 03 00:40:48.495 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: ApiKey Unknown-47? (47) Versions 0..0 | |
| May 03 00:40:48.495 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Feature MsgVer1: Produce (2..2) supported by broker | |
| May 03 00:40:48.495 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Feature MsgVer1: Fetch (2..2) supported by broker | |
| May 03 00:40:48.495 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature MsgVer1 | |
| May 03 00:40:48.495 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Feature MsgVer2: Produce (3..3) supported by broker | |
| May 03 00:40:48.495 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Feature MsgVer2: Fetch (4..4) supported by broker | |
| May 03 00:40:48.495 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature MsgVer2 | |
| May 03 00:40:48.495 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Feature ApiVersion: ApiVersion (0..0) supported by broker | |
| May 03 00:40:48.495 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature ApiVersion | |
| May 03 00:40:48.495 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Feature BrokerGroupCoordinator: FindCoordinator (0..0) supported by broker | |
| May 03 00:40:48.495 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature BrokerGroupCoordinator | |
| May 03 00:40:48.495 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Feature BrokerBalancedConsumer: FindCoordinator (0..0) supported by broker | |
| May 03 00:40:48.495 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Feature BrokerBalancedConsumer: OffsetCommit (1..2) supported by broker | |
| May 03 00:40:48.496 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Feature BrokerBalancedConsumer: OffsetFetch (1..1) supported by broker | |
| May 03 00:40:48.496 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Feature BrokerBalancedConsumer: JoinGroup (0..0) supported by broker | |
| May 03 00:40:48.496 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Feature BrokerBalancedConsumer: SyncGroup (0..0) supported by broker | |
| May 03 00:40:48.496 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Feature BrokerBalancedConsumer: Heartbeat (0..0) supported by broker | |
| May 03 00:40:48.496 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Feature BrokerBalancedConsumer: LeaveGroup (0..0) supported by broker | |
| May 03 00:40:48.496 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature BrokerBalancedConsumer | |
| May 03 00:40:48.496 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Feature ThrottleTime: Produce (1..2) supported by broker | |
| May 03 00:40:48.496 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Feature ThrottleTime: Fetch (1..2) supported by broker | |
| May 03 00:40:48.496 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature ThrottleTime | |
| May 03 00:40:48.496 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Feature Sasl: JoinGroup (0..0) supported by broker | |
| May 03 00:40:48.496 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature Sasl | |
| May 03 00:40:48.496 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Feature SaslHandshake: SaslHandshake (0..0) supported by broker | |
| May 03 00:40:48.496 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature SaslHandshake | |
| May 03 00:40:48.497 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Feature LZ4: FindCoordinator (0..0) supported by broker | |
| May 03 00:40:48.497 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature LZ4 | |
| May 03 00:40:48.497 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Feature OffsetTime: Offset (1..1) supported by broker | |
| May 03 00:40:48.497 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature OffsetTime | |
| May 03 00:40:48.497 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Feature IdempotentProducer: InitProducerId (0..0) supported by broker | |
| May 03 00:40:48.497 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature IdempotentProducer | |
| May 03 00:40:48.497 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Feature ZSTD: Produce (7..7) supported by broker | |
| May 03 00:40:48.497 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Feature ZSTD: Fetch (10..10) supported by broker | |
| May 03 00:40:48.497 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature ZSTD | |
| May 03 00:40:48.497 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Feature SaslAuthReq: SaslHandshake (1..1) supported by broker | |
| May 03 00:40:48.497 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Feature SaslAuthReq: SaslAuthenticate (0..0) supported by broker | |
| May 03 00:40:48.498 DEBUG librdkafka: librdkafka: APIVERSION [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature SaslAuthReq | |
| May 03 00:40:48.498 DEBUG librdkafka: librdkafka: FEATURE [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Updated enabled protocol features to MsgVer1,ApiVersion,BrokerBalancedConsumer,ThrottleTime,Sasl,SaslHandshake,BrokerGroupCoordinator,LZ4,OffsetTime,MsgVer2,IdempotentProducer,ZSTD,SaslAuthReq | |
| May 03 00:40:48.498 DEBUG librdkafka: librdkafka: STATE [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state APIVERSION_QUERY -> UP | |
| May 03 00:40:48.498 DEBUG librdkafka: librdkafka: BROADCAST [thrd:localhost:9092/bootstrap]: Broadcasting state change | |
| May 03 00:40:48.498 DEBUG librdkafka: librdkafka: METADATA [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Request metadata for brokers only: connected | |
| May 03 00:40:48.498 DEBUG librdkafka: librdkafka: BRKMAIN [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: rkb_state: UP | |
| May 03 00:40:48.498 DEBUG librdkafka: librdkafka: SEND [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Sent MetadataRequest (v2, 30 bytes @ 0, CorrId 2) | |
| May 03 00:40:48.498 DEBUG librdkafka: librdkafka: RECV [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received MetadataResponse (v2, 56 bytes, CorrId 2, rtt 0.23ms) | |
| May 03 00:40:48.498 DEBUG librdkafka: librdkafka: METADATA [thrd:main]: localhost:9092/bootstrap: ===== Received metadata: connected ===== | |
| May 03 00:40:48.499 DEBUG librdkafka: librdkafka: METADATA [thrd:main]: localhost:9092/bootstrap: ClusterId: mNnljm4BSEac_7d_0ZNDAQ, ControllerId: 0 | |
| May 03 00:40:48.499 DEBUG librdkafka: librdkafka: METADATA [thrd:main]: localhost:9092/bootstrap: 1 brokers, 0 topics | |
| May 03 00:40:48.499 DEBUG librdkafka: librdkafka: METADATA [thrd:main]: localhost:9092/bootstrap: Broker #0/1: marmoset:9092 NodeId 0 | |
| May 03 00:40:48.499 DEBUG librdkafka: librdkafka: WAKEUPFD [thrd:main]: marmoset:9092/0: Enabled low-latency ops queue wake-ups | |
| May 03 00:40:48.499 DEBUG librdkafka: librdkafka: BROKER [thrd:main]: marmoset:9092/0: Added new broker with NodeId 0 | |
| May 03 00:40:48.499 DEBUG librdkafka: librdkafka: CLUSTERID [thrd:main]: localhost:9092/bootstrap: ClusterId update "" -> "mNnljm4BSEac_7d_0ZNDAQ" | |
| May 03 00:40:48.499 DEBUG librdkafka: librdkafka: CONTROLLERID [thrd:main]: localhost:9092/bootstrap: ControllerId update -1 -> 0 | |
| May 03 00:40:48.499 DEBUG librdkafka: librdkafka: BROADCAST [thrd:main]: Broadcasting state change | |
| May 03 00:40:48.499 DEBUG librdkafka: librdkafka: CGRPLOG [thrd:main]: serving state query-coord | |
| May 03 00:40:48.499 DEBUG librdkafka: librdkafka: BRKMAIN [thrd:marmoset:9092/0]: marmoset:9092/0: Enter main broker thread | |
| May 03 00:40:48.500 DEBUG librdkafka: librdkafka: BRKMAIN [thrd:marmoset:9092/0]: marmoset:9092/0: rkb_state: INIT | |
| May 03 00:40:48.542 DEBUG librdkafka: librdkafka: CGRPLOG [thrd:main]: serving state up | |
| May 03 00:40:48.543 DEBUG librdkafka: librdkafka: BRKMAIN [thrd::0/internal]: :0/internal: rkb_state: INIT | |
| May 03 00:40:48.553 DEBUG librdkafka: librdkafka: BRKMAIN [thrd:GroupCoordinator]: GroupCoordinator/0: rkb_state: UP | |
| May 03 00:40:48.554 DEBUG librdkafka: librdkafka: BRKMAIN [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: rkb_state: UP | |
| May 03 00:40:48.554 DEBUG librdkafka: librdkafka: RECV [thrd:marmoset:9092/0]: marmoset:9092/0: Received FetchResponse (v11, 87 bytes, CorrId 13, rtt 101.01ms) | |
| May 03 00:40:48.554 DEBUG librdkafka: librdkafka: FETCH [thrd:marmoset:9092/0]: marmoset:9092/0: Topic testdrive-data-1766087232 [0] MessageSet size 0, error "Success", MaxOffset 2, LSO 2, Ver 2/2 | |
| May 03 00:40:48.554 DEBUG librdkafka: librdkafka: FETCH [thrd:marmoset:9092/0]: marmoset:9092/0: Fetch topic testdrive-data-1766087232 [0] at offset 2 (v2) | |
| May 03 00:40:48.554 DEBUG librdkafka: librdkafka: FETCH [thrd:marmoset:9092/0]: marmoset:9092/0: Fetch 1/1/1 toppar(s) | |
| May 03 00:40:48.554 DEBUG librdkafka: librdkafka: SEND [thrd:marmoset:9092/0]: marmoset:9092/0: Sent FetchRequest (v11, 120 bytes @ 0, CorrId 14) | |
| May 03 00:40:48.564 DEBUG librdkafka: librdkafka: CGRPLOG [thrd:main]: serving state up | |
| May 03 00:40:48.564 DEBUG librdkafka: librdkafka: CGRPLOG [thrd:main]: serving state up | |
| May 03 00:40:48.564 DEBUG librdkafka: librdkafka: CGRPLOG [thrd:main]: serving state up | |
| May 03 00:40:48.564 DEBUG librdkafka: librdkafka: CGRPLOG [thrd:main]: serving state up | |
| May 03 00:40:48.565 DEBUG librdkafka: librdkafka: CGRPLOG [thrd:main]: serving state up | |
| May 03 00:40:48.565 DEBUG librdkafka: librdkafka: CGRPLOG [thrd:main]: serving state up | |
| May 03 00:40:48.565 DEBUG librdkafka: librdkafka: CGRPLOG [thrd:main]: serving state up | |
| May 03 00:40:48.565 DEBUG librdkafka: librdkafka: CGRPLOG [thrd:main]: serving state up | |
| May 03 00:40:48.565 DEBUG librdkafka: librdkafka: CGRPLOG [thrd:main]: serving state up | |
| May 03 00:40:48.565 DEBUG librdkafka: librdkafka: CGRPLOG [thrd:main]: serving state up | |
| May 03 00:40:48.565 DEBUG librdkafka: librdkafka: CGRPLOG [thrd:main]: serving state up | |
| May 03 00:40:48.565 DEBUG librdkafka: librdkafka: CGRPLOG [thrd:main]: serving state up | |
| May 03 00:40:48.565 DEBUG librdkafka: librdkafka: CGRPLOG [thrd:main]: serving state up | |
| May 03 00:40:48.573 DEBUG librdkafka: librdkafka: BRKMAIN [thrd:marmoset:9092/0]: marmoset:9092/0: rkb_state: UP | |
| May 03 00:40:48.655 DEBUG librdkafka: librdkafka: RECV [thrd:marmoset:9092/0]: marmoset:9092/0: Received FetchResponse (v11, 87 bytes, CorrId 14, rtt 100.45ms) | |
| May 03 00:40:48.655 DEBUG librdkafka: librdkafka: FETCH [thrd:marmoset:9092/0]: marmoset:9092/0: Topic testdrive-data-1766087232 [0] MessageSet size 0, error "Success", MaxOffset 2, LSO 2, Ver 2/2 | |
| May 03 00:40:48.655 DEBUG librdkafka: librdkafka: FETCH [thrd:marmoset:9092/0]: marmoset:9092/0: Fetch topic testdrive-data-1766087232 [0] at offset 2 (v2) | |
| May 03 00:40:48.655 DEBUG librdkafka: librdkafka: FETCH [thrd:marmoset:9092/0]: marmoset:9092/0: Fetch 1/1/1 toppar(s) | |
| May 03 00:40:48.655 DEBUG librdkafka: librdkafka: SEND [thrd:marmoset:9092/0]: marmoset:9092/0: Sent FetchRequest (v11, 120 bytes @ 0, CorrId 15) | |
| May 03 00:40:48.756 DEBUG librdkafka: librdkafka: RECV [thrd:marmoset:9092/0]: marmoset:9092/0: Received FetchResponse (v11, 87 bytes, CorrId 15, rtt 100.64ms) | |
| May 03 00:40:48.756 DEBUG librdkafka: librdkafka: FETCH [thrd:marmoset:9092/0]: marmoset:9092/0: Topic testdrive-data-1766087232 [0] MessageSet size 0, error "Success", MaxOffset 2, LSO 2, Ver 2/2 | |
| May 03 00:40:48.756 DEBUG librdkafka: librdkafka: FETCH [thrd:marmoset:9092/0]: marmoset:9092/0: Fetch topic testdrive-data-1766087232 [0] at offset 2 (v2) | |
| May 03 00:40:48.756 DEBUG librdkafka: librdkafka: FETCH [thrd:marmoset:9092/0]: marmoset:9092/0: Fetch 1/1/1 toppar(s) | |
| May 03 00:40:48.757 DEBUG librdkafka: librdkafka: SEND [thrd:marmoset:9092/0]: marmoset:9092/0: Sent FetchRequest (v11, 120 bytes @ 0, CorrId 16) | |
| May 03 00:40:48.857 DEBUG librdkafka: librdkafka: RECV [thrd:marmoset:9092/0]: marmoset:9092/0: Received FetchResponse (v11, 87 bytes, CorrId 16, rtt 100.42ms) | |
| May 03 00:40:48.857 DEBUG librdkafka: librdkafka: FETCH [thrd:marmoset:9092/0]: marmoset:9092/0: Topic testdrive-data-1766087232 [0] MessageSet size 0, error "Success", MaxOffset 2, LSO 2, Ver 2/2 | |
| May 03 00:40:48.857 DEBUG librdkafka: librdkafka: FETCH [thrd:marmoset:9092/0]: marmoset:9092/0: Fetch topic testdrive-data-1766087232 [0] at offset 2 (v2) | |
| May 03 00:40:48.857 DEBUG librdkafka: librdkafka: FETCH [thrd:marmoset:9092/0]: marmoset:9092/0: Fetch 1/1/1 toppar(s) | |
| May 03 00:40:48.858 DEBUG librdkafka: librdkafka: SEND [thrd:marmoset:9092/0]: marmoset:9092/0: Sent FetchRequest (v11, 120 bytes @ 0, CorrId 17) |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment