Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

Subscribed topic not available even though it's already created #1175

Open
7 tasks
saartamir opened this issue Apr 16, 2024 · 5 comments
Open
7 tasks

Subscribed topic not available even though it's already created #1175

saartamir opened this issue Apr 16, 2024 · 5 comments
Labels
wait info

Comments

@saartamir
Copy link

Description

Since we moved from confluent-kafka-go 1.9.2 to 2.3.0, we get this error: "code": 3, "err": "Subscribed topic not available: XXX: Broker: Unknown topic or partition"
it didn't happen before (for this previously created topic). I do manage to pull all the data from the topic, with the correct amount of partitions (so I know it's not just automatically created)

How to reproduce

basically I just use .Poll()

ev := consumer.Poll(100)
	if ev == nil {
		continue
	}
	switch ev.(type) {
	case kafka.Error:
		log.Error("kafka error", zap.Int("code", int(ev.(kafka.Error).Code())), zap.String("err", ev.(kafka.Error).Error()))

Checklist

Please provide the following information:

  • confluent-kafka-go and librdkafka version (LibraryVersion()):
  • Apache Kafka broker version:
  • Client configuration: ConfigMap{...}
  • Operating system:
  • Provide client logs (with "debug": ".." as necessary)
  • Provide broker log excerpts
  • Critical issue
@milindl
Copy link
Contributor

milindl commented Apr 18, 2024

Hi @saartamir , what's the subscription like: Is it a regex based subscription, or just a normal one?
The exact steps to repro are: create the topic, run consumer, and wait for error. Right?

@saartamir
Copy link
Author

@milindl just a normal one, using the exact topic name.
And yes these are the exact steps. You should get the error immediately, while messages are read just fine (we do use create topic automatic, but I don't see any new topic created, it's using the correct topic)

@milindl
Copy link
Contributor

milindl commented Apr 25, 2024

Thanks @saartamir , I couldn't reproduce it locally (the error wasn't there either as a result of Subscribe or within the consumer Poll).
Could you add "debug": "all" to your config and post the logs here after the error? (warning, this can be very verbose though)

@saartamir
Copy link
Author

@milindl sorry it took me some time to reply.
This is what I'm doing, including the debug flag:

Creating the topic:

➜ ~ kafka-topics --create --bootstrap-server localhost:9092 --replication-factor 1 --topic Test
Created topic Test.
➜ ~ kafka-topics --list --bootstrap-server localhost:9092
Test
__consumer_offsets

debug trace:

%7|1714632169.865|MEMBERID|rdkafka#consumer-1| [thrd:app]: Group "EventSinkGO4000041": updating member id "(not-set)" -> ""
%7|1714632169.865|WAKEUPFD|rdkafka#consumer-1| [thrd:app]: GroupCoordinator: Enabled low-latency ops queue wake-ups
%7|1714632169.865|BROKER|rdkafka#consumer-1| [thrd:app]: GroupCoordinator: Added new broker with NodeId -1
%7|1714632169.865|WAKEUPFD|rdkafka#consumer-1| [thrd:app]: localhost:9092/bootstrap: Enabled low-latency ops queue wake-ups
%7|1714632169.865|BROKER|rdkafka#consumer-1| [thrd:app]: localhost:9092/bootstrap: Added new broker with NodeId -1
%7|1714632169.865|BRKMAIN|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Enter main broker thread
%7|1714632169.865|BRKMAIN|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enter main broker thread
%7|1714632169.865|INIT|rdkafka#consumer-1| [thrd:app]: librdkafka v2.3.0 (0x20300ff) rdkafka#consumer-1 initialized (builtin.features gzip,snappy,ssl,sasl,regex,lz4,sasl_gssapi,sasl_plain,sasl_scram,plugins,zstd,sasl_oauthbearer,http,oidc, STRIP STATIC_LINKING GCC GXX PKGCONFIG OSXLD LIBDL PLUGINS ZLIB SSL SASL_CYRUS ZSTD CURL HDRHISTOGRAM SYSLOG SNAPPY SOCKEM SASL_SCRAM SASL_OAUTHBEARER OAUTHBEARER_OIDC, debug 0xfffff)
%7|1714632169.865|CGRPSTATE|rdkafka#consumer-1| [thrd:main]: Group "EventSinkGO4000041" changed state init -> query-coord (join-state init)
%7|1714632169.865|CONF|rdkafka#consumer-1| [thrd:app]: Client configuration:
%7|1714632169.865|CONF|rdkafka#consumer-1| [thrd:app]:   client.software.name = confluent-kafka-go
%7|1714632169.865|CONF|rdkafka#consumer-1| [thrd:app]:   client.software.version = 2.3.0
%7|1714632169.865|CONF|rdkafka#consumer-1| [thrd:app]:   metadata.broker.list = localhost:9092
%7|1714632169.866|CONF|rdkafka#consumer-1| [thrd:app]:   debug = generic,broker,topic,metadata,feature,queue,msg,protocol,cgrp,security,fetch,interceptor,plugin,consumer,admin,eos,mock,assignor,conf,all
%7|1714632169.866|CONF|rdkafka#consumer-1| [thrd:app]:   reconnect.backoff.ms = 0
%7|1714632169.866|CONF|rdkafka#consumer-1| [thrd:app]:   enabled_events = 376
%7|1714632169.866|CONF|rdkafka#consumer-1| [thrd:app]:   default_topic_conf = 0x12df04080
%7|1714632169.866|CONF|rdkafka#consumer-1| [thrd:app]:   ssl.ca.location = probe
%7|1714632169.866|CONF|rdkafka#consumer-1| [thrd:app]:   group.id = EventSinkGO4000041
%7|1714632169.866|CONF|rdkafka#consumer-1| [thrd:app]:   enable.auto.commit = false
%7|1714632169.866|CONF|rdkafka#consumer-1| [thrd:app]:   auto.commit.interval.ms = 500
%7|1714632169.865|BRKMAIN|rdkafka#consumer-1| [thrd::0/internal]: :0/internal: Enter main broker thread
%7|1714632169.865|BROADCAST|rdkafka#consumer-1| [thrd:main]: Broadcasting state change
%7|1714632169.866|CONNECT|rdkafka#consumer-1| [thrd:main]: localhost:9092/bootstrap: Selected for cluster connection: coordinator query (broker has 0 connection attempt(s))
%7|1714632169.866|CONF|rdkafka#consumer-1| [thrd:app]: Default topic configuration:
%7|1714632169.866|CONF|rdkafka#consumer-1| [thrd:app]:   auto.offset.reset = smallest
%7|1714632169.866|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "EventSinkGO4000041": no broker available for coordinator query: intervaled in state query-coord
%7|1714632169.866|CONNECT|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received CONNECT op
%7|1714632169.866|STATE|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state INIT -> TRY_CONNECT
%7|1714632169.866|BROADCAST|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
%7|1714632169.866|CONNECT|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: broker in state TRY_CONNECT connecting
%7|1714632169.866|STATE|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state TRY_CONNECT -> CONNECT
%7|1714632169.866|BROADCAST|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
%7|1714632169.866|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "EventSinkGO4000041" received op SUBSCRIBE in state query-coord (join-state init)
%7|1714632169.866|SUBSCRIBE|rdkafka#consumer-1| [thrd:main]: Group "EventSinkGO4000041": subscribe to new subscription of 1 topics (join-state init)
%7|1714632169.866|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 10ms: coordinator query
%7|1714632169.866|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "EventSinkGO4000041": no broker available for coordinator query: intervaled in state query-coord
%7|1714632169.866|CONNECT|rdkafka#consumer-1| [thrd:app]: Not selecting any broker for cluster connection: still suppressed for 10ms: application metadata request
%7|1714632169.868|CONNECT|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connecting to ipv4#127.0.0.1:9092 (plaintext) with socket 49
%7|1714632169.869|CONNECT|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connected to ipv4#127.0.0.1:9092
%7|1714632169.869|CONNECTED|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connected (#1)
%7|1714632169.869|FEATURE|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Updated enabled protocol features +ApiVersion to ApiVersion
%7|1714632169.869|STATE|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state CONNECT -> APIVERSION_QUERY
%7|1714632169.869|BROADCAST|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
%7|1714632169.869|CONNECT|rdkafka#consumer-1| [thrd:app]: Not selecting any broker for cluster connection: still suppressed for 7ms: application metadata request
%7|1714632169.869|SEND|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Sent ApiVersionRequest (v3, 48 bytes @ 0, CorrId 1)
%7|1714632169.878|RECV|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received ApiVersionResponse (v3, 438 bytes, CorrId 1, rtt 9.36ms)
%7|1714632169.878|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker API support:
%7|1714632169.878|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey Produce (0) Versions 0..9
%7|1714632169.878|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey Fetch (1) Versions 0..13
%7|1714632169.878|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey ListOffsets (2) Versions 0..7
%7|1714632169.878|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey Metadata (3) Versions 0..12
%7|1714632169.878|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey LeaderAndIsr (4) Versions 0..7
%7|1714632169.878|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey StopReplica (5) Versions 0..4
%7|1714632169.878|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey UpdateMetadata (6) Versions 0..8
%7|1714632169.878|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey ControlledShutdown (7) Versions 0..3
%7|1714632169.878|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey OffsetCommit (8) Versions 0..8
%7|1714632169.878|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey OffsetFetch (9) Versions 0..8
%7|1714632169.878|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey FindCoordinator (10) Versions 0..4
%7|1714632169.878|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey JoinGroup (11) Versions 0..9
%7|1714632169.878|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey Heartbeat (12) Versions 0..4
%7|1714632169.878|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey LeaveGroup (13) Versions 0..5
%7|1714632169.878|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey SyncGroup (14) Versions 0..5
%7|1714632169.878|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey DescribeGroups (15) Versions 0..5
%7|1714632169.878|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey ListGroups (16) Versions 0..4
%7|1714632169.878|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey SaslHandshake (17) Versions 0..1
%7|1714632169.878|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey ApiVersion (18) Versions 0..3
%7|1714632169.878|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey CreateTopics (19) Versions 0..7
%7|1714632169.878|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey DeleteTopics (20) Versions 0..6
%7|1714632169.878|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey DeleteRecords (21) Versions 0..2
%7|1714632169.879|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey InitProducerId (22) Versions 0..4
%7|1714632169.879|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey OffsetForLeaderEpoch (23) Versions 0..4
%7|1714632169.879|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey AddPartitionsToTxn (24) Versions 0..3
%7|1714632169.879|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey AddOffsetsToTxn (25) Versions 0..3
%7|1714632169.879|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey EndTxn (26) Versions 0..3
%7|1714632169.879|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey WriteTxnMarkers (27) Versions 0..1
%7|1714632169.879|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey TxnOffsetCommit (28) Versions 0..3
%7|1714632169.879|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey DescribeAcls (29) Versions 0..3
%7|1714632169.879|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey CreateAcls (30) Versions 0..3
%7|1714632169.879|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey DeleteAcls (31) Versions 0..3
%7|1714632169.879|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey DescribeConfigs (32) Versions 0..4
%7|1714632169.879|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey AlterConfigs (33) Versions 0..2
%7|1714632169.879|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey AlterReplicaLogDirs (34) Versions 0..2
%7|1714632169.879|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey DescribeLogDirs (35) Versions 0..4
%7|1714632169.879|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey SaslAuthenticate (36) Versions 0..2
%7|1714632169.879|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey CreatePartitions (37) Versions 0..3
%7|1714632169.879|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey CreateDelegationToken (38) Versions 0..3
%7|1714632169.879|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey RenewDelegationToken (39) Versions 0..2
%7|1714632169.879|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey ExpireDelegationToken (40) Versions 0..2
%7|1714632169.879|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey DescribeDelegationToken (41) Versions 0..3
%7|1714632169.879|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey DeleteGroups (42) Versions 0..2
%7|1714632169.879|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey ElectLeadersRequest (43) Versions 0..2
%7|1714632169.879|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey IncrementalAlterConfigsRequest (44) Versions 0..1
%7|1714632169.879|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey AlterPartitionReassignmentsRequest (45) Versions 0..0
%7|1714632169.879|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey ListPartitionReassignmentsRequest (46) Versions 0..0
%7|1714632169.879|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey OffsetDeleteRequest (47) Versions 0..0
%7|1714632169.879|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey DescribeClientQuotasRequest (48) Versions 0..1
%7|1714632169.879|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey AlterClientQuotasRequest (49) Versions 0..1
%7|1714632169.879|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey DescribeUserScramCredentialsRequest (50) Versions 0..0
%7|1714632169.879|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey AlterUserScramCredentialsRequest (51) Versions 0..0
%7|1714632169.879|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey AlterIsrRequest (56) Versions 0..2
%7|1714632169.879|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey UpdateFeaturesRequest (57) Versions 0..1
%7|1714632169.879|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey EnvelopeRequest (58) Versions 0..0
%7|1714632169.879|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey DescribeCluster (60) Versions 0..0
%7|1714632169.879|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey DescribeProducers (61) Versions 0..0
%7|1714632169.879|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey DescribeTransactions (65) Versions 0..0
%7|1714632169.879|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey ListTransactions (66) Versions 0..0
%7|1714632169.879|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey AllocateProducerIds (67) Versions 0..0
%7|1714632169.879|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature MsgVer1: Produce (2..2) supported by broker
%7|1714632169.879|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature MsgVer1: Fetch (2..2) supported by broker
%7|1714632169.879|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature MsgVer1
%7|1714632169.879|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature MsgVer2: Produce (3..3) supported by broker
%7|1714632169.879|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature MsgVer2: Fetch (4..4) supported by broker
%7|1714632169.879|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature MsgVer2
%7|1714632169.879|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature ApiVersion: ApiVersion (0..0) supported by broker
%7|1714632169.879|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature ApiVersion
%7|1714632169.879|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature BrokerGroupCoordinator: FindCoordinator (0..0) supported by broker
%7|1714632169.879|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature BrokerGroupCoordinator
%7|1714632169.879|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature BrokerBalancedConsumer: FindCoordinator (0..0) supported by broker
%7|1714632169.879|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature BrokerBalancedConsumer: OffsetCommit (1..2) supported by broker
%7|1714632169.879|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature BrokerBalancedConsumer: OffsetFetch (1..1) supported by broker
%7|1714632169.879|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature BrokerBalancedConsumer: JoinGroup (0..0) supported by broker
%7|1714632169.879|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature BrokerBalancedConsumer: SyncGroup (0..0) supported by broker
%7|1714632169.879|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature BrokerBalancedConsumer: Heartbeat (0..0) supported by broker
%7|1714632169.879|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature BrokerBalancedConsumer: LeaveGroup (0..0) supported by broker
%7|1714632169.879|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature BrokerBalancedConsumer
%7|1714632169.879|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature ThrottleTime: Produce (1..2) supported by broker
%7|1714632169.879|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature ThrottleTime: Fetch (1..2) supported by broker
%7|1714632169.879|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature ThrottleTime
%7|1714632169.879|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature Sasl: JoinGroup (0..0) supported by broker
%7|1714632169.879|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature Sasl
%7|1714632169.879|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature SaslHandshake: SaslHandshake (0..0) supported by broker
%7|1714632169.879|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature SaslHandshake
%7|1714632169.879|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature LZ4: FindCoordinator (0..0) supported by broker
%7|1714632169.879|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature LZ4
%7|1714632169.879|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature OffsetTime: ListOffsets (1..1) supported by broker
%7|1714632169.879|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature OffsetTime
%7|1714632169.879|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature IdempotentProducer: InitProducerId (0..0) supported by broker
%7|1714632169.879|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature IdempotentProducer
%7|1714632169.879|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature ZSTD: Produce (7..7) supported by broker
%7|1714632169.879|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature ZSTD: Fetch (10..10) supported by broker
%7|1714632169.879|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature ZSTD
%7|1714632169.879|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature SaslAuthReq: SaslHandshake (1..1) supported by broker
%7|1714632169.879|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature SaslAuthReq: SaslAuthenticate (0..1) supported by broker
%7|1714632169.879|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature SaslAuthReq
%7|1714632169.879|FEATURE|rdkafka#consumer-1| [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
%7|1714632169.879|STATE|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state APIVERSION_QUERY -> UP
%7|1714632169.880|BROADCAST|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
%7|1714632169.880|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: localhost:9092/bootstrap: Group "EventSinkGO4000041": querying for coordinator: intervaled in state query-coord
%7|1714632169.880|METADATA|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Request metadata for brokers only: connected
%7|1714632169.880|CGRPSTATE|rdkafka#consumer-1| [thrd:main]: Group "EventSinkGO4000041" changed state query-coord -> wait-coord (join-state init)
%7|1714632169.880|BROADCAST|rdkafka#consumer-1| [thrd:main]: Broadcasting state change
%7|1714632169.880|METADATA|rdkafka#consumer-1| [thrd:app]: localhost:9092/bootstrap: Request metadata for all topics: application requested
%7|1714632169.880|SEND|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Sent MetadataRequest (v12, 26 bytes @ 0, CorrId 2)
%7|1714632169.880|SEND|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Sent FindCoordinatorRequest (v2, 42 bytes @ 0, CorrId 3)
%7|1714632169.880|SEND|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Sent MetadataRequest (v12, 29 bytes @ 0, CorrId 4)
%7|1714632169.882|RECV|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received MetadataResponse (v12, 55 bytes, CorrId 2, rtt 2.80ms)
%7|1714632169.882|METADATA|rdkafka#consumer-1| [thrd:main]: localhost:9092/bootstrap: ===== Received metadata: connected =====
%7|1714632169.882|METADATA|rdkafka#consumer-1| [thrd:main]: localhost:9092/bootstrap: ClusterId: qpkV0ou8RcWYbqNwD3oREA, ControllerId: 1
%7|1714632169.882|METADATA|rdkafka#consumer-1| [thrd:main]: localhost:9092/bootstrap: 1 brokers, 0 topics
%7|1714632169.882|METADATA|rdkafka#consumer-1| [thrd:main]: localhost:9092/bootstrap:   Broker #0/1: localhost:9092 NodeId 1
%7|1714632169.883|UPDATE|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: NodeId changed from -1 to 1
%7|1714632169.883|UPDATE|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1: Name changed from localhost:9092/bootstrap to localhost:9092/1
%7|1714632169.883|LEADER|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1: Mapped 0 partition(s) to broker
%7|1714632169.883|STATE|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1: Broker changed state UP -> UPDATE
%7|1714632169.883|BROADCAST|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
%7|1714632169.883|BROADCAST|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
%7|1714632169.883|STATE|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1: Broker changed state UPDATE -> UP
%7|1714632169.883|BROADCAST|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
%7|1714632169.883|CLUSTERID|rdkafka#consumer-1| [thrd:main]: localhost:9092/1: ClusterId update "" -> "qpkV0ou8RcWYbqNwD3oREA"
%7|1714632169.883|CONTROLLERID|rdkafka#consumer-1| [thrd:main]: localhost:9092/1: ControllerId update -1 -> 1
%7|1714632169.883|BROADCAST|rdkafka#consumer-1| [thrd:main]: Broadcasting state change
%7|1714632169.884|RECV|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1: Received FindCoordinatorResponse (v2, 31 bytes, CorrId 3, rtt 4.71ms)
%7|1714632169.884|CGRPCOORD|rdkafka#consumer-1| [thrd:main]: localhost:9092/1: Group "EventSinkGO4000041" coordinator is localhost:9092 id 1
%7|1714632169.884|CGRPCOORD|rdkafka#consumer-1| [thrd:main]: Group "EventSinkGO4000041" changing coordinator -1 -> 1
%7|1714632169.884|COORDSET|rdkafka#consumer-1| [thrd:main]: Group "EventSinkGO4000041" coordinator set to broker localhost:9092/1
%7|1714632169.884|CGRPSTATE|rdkafka#consumer-1| [thrd:main]: Group "EventSinkGO4000041" changed state wait-coord -> wait-broker-transport (join-state init)
%7|1714632169.884|BROADCAST|rdkafka#consumer-1| [thrd:main]: Broadcasting state change
%7|1714632169.884|NODENAME|rdkafka#consumer-1| [thrd:main]: GroupCoordinator: Broker nodename changed from "" to "localhost:9092"
%7|1714632169.884|NODEID|rdkafka#consumer-1| [thrd:main]: GroupCoordinator: Broker nodeid changed from -1 to 1
%7|1714632169.884|CONNECT|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Received CONNECT op
%7|1714632169.884|STATE|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Broker changed state INIT -> TRY_CONNECT
%7|1714632169.884|BROADCAST|rdkafka#consumer-1| [thrd:GroupCoordinator]: Broadcasting state change
%7|1714632169.884|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: localhost:9092/1: Group "EventSinkGO4000041": querying for coordinator: intervaled in state wait-broker-transport
%7|1714632169.884|CONNECT|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1: broker in state TRY_CONNECT connecting
%7|1714632169.884|STATE|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Broker changed state TRY_CONNECT -> CONNECT
%7|1714632169.884|BROADCAST|rdkafka#consumer-1| [thrd:GroupCoordinator]: Broadcasting state change
%7|1714632169.884|SEND|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1: Sent FindCoordinatorRequest (v2, 42 bytes @ 0, CorrId 5)
%7|1714632169.886|CONNECT|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1: Connecting to ipv4#127.0.0.1:9092 (plaintext) with socket 50
%7|1714632169.886|CONNECT|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1: Connected to ipv4#127.0.0.1:9092
%7|1714632169.886|CONNECTED|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1: Connected (#1)
%7|1714632169.886|FEATURE|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1: Updated enabled protocol features +ApiVersion to ApiVersion
%7|1714632169.886|STATE|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Broker changed state CONNECT -> APIVERSION_QUERY
%7|1714632169.886|BROADCAST|rdkafka#consumer-1| [thrd:GroupCoordinator]: Broadcasting state change
%7|1714632169.886|SEND|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1: Sent ApiVersionRequest (v3, 48 bytes @ 0, CorrId 1)
%7|1714632169.887|RECV|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1: Received MetadataResponse (v12, 2185 bytes, CorrId 4, rtt 7.79ms)
%7|1714632169.887|METADATA|rdkafka#consumer-1| [thrd:main]: localhost:9092/1: ===== Received metadata: application requested =====
%7|1714632169.887|METADATA|rdkafka#consumer-1| [thrd:main]: localhost:9092/1: ClusterId: qpkV0ou8RcWYbqNwD3oREA, ControllerId: 1
%7|1714632169.887|METADATA|rdkafka#consumer-1| [thrd:main]: localhost:9092/1: 1 brokers, 13 topics
%7|1714632169.887|METADATA|rdkafka#consumer-1| [thrd:main]: localhost:9092/1:   Broker #0/1: localhost:9092 NodeId 1
%7|1714632169.888|METADATA|rdkafka#consumer-1| [thrd:main]: localhost:9092/1:   Topic Test with 1 partitions
%7|1714632169.888|METADATA|rdkafka#consumer-1| [thrd:main]: Expired 0 entries older than 0ms from metadata cache (0 entries remain)
%7|1714632169.888|METADATA|rdkafka#consumer-1| [thrd:main]: localhost:9092/1: Caching full metadata with 1 broker(s) and 13 topic(s): application requested
%7|1714632169.888|TOPICERR|rdkafka#consumer-1| [thrd:main]: Subscribed topic not available: Test: Broker: Unknown topic or partition
%7|1714632169.888|SUBSCRIPTION|rdkafka#consumer-1| [thrd:main]: Group "EventSinkGO4000041": no topics in metadata matched subscription
2024-05-02 09:42:49.888 error   anzu_events_sink_go/main.go:177 kafka error     {"code": 3, "err": "Subscribed topic not available: Test: Broker: Unknown topic or partition"}
main.consumeMessages
        /Users/saar/anzu/anzu_go/anzu_events_sink_go/main.go:177
%7|1714632169.892|RECV|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1: Received FindCoordinatorResponse (v2, 31 bytes, CorrId 5, rtt 7.34ms)
%7|1714632169.892|CGRPCOORD|rdkafka#consumer-1| [thrd:main]: localhost:9092/1: Group "EventSinkGO4000041" coordinator is localhost:9092 id 1
%7|1714632169.897|RECV|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1: Received ApiVersionResponse (v3, 438 bytes, CorrId 1, rtt 10.92ms)
%7|1714632169.897|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1: Broker API support:
%7|1714632169.897|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:   ApiKey Produce (0) Versions 0..9
%7|1714632169.897|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:   ApiKey Fetch (1) Versions 0..13
%7|1714632169.897|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:   ApiKey ListOffsets (2) Versions 0..7
%7|1714632169.897|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:   ApiKey Metadata (3) Versions 0..12
%7|1714632169.897|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:   ApiKey LeaderAndIsr (4) Versions 0..7
%7|1714632169.897|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:   ApiKey StopReplica (5) Versions 0..4
%7|1714632169.897|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:   ApiKey UpdateMetadata (6) Versions 0..8
%7|1714632169.897|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:   ApiKey ControlledShutdown (7) Versions 0..3
%7|1714632169.897|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:   ApiKey OffsetCommit (8) Versions 0..8
%7|1714632169.897|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:   ApiKey OffsetFetch (9) Versions 0..8
%7|1714632169.897|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:   ApiKey FindCoordinator (10) Versions 0..4
%7|1714632169.897|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:   ApiKey JoinGroup (11) Versions 0..9
%7|1714632169.897|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:   ApiKey Heartbeat (12) Versions 0..4
%7|1714632169.897|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:   ApiKey LeaveGroup (13) Versions 0..5
%7|1714632169.897|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:   ApiKey SyncGroup (14) Versions 0..5
%7|1714632169.897|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:   ApiKey DescribeGroups (15) Versions 0..5
%7|1714632169.897|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:   ApiKey ListGroups (16) Versions 0..4
%7|1714632169.897|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:   ApiKey SaslHandshake (17) Versions 0..1
%7|1714632169.897|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:   ApiKey ApiVersion (18) Versions 0..3
%7|1714632169.897|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:   ApiKey CreateTopics (19) Versions 0..7
%7|1714632169.897|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:   ApiKey DeleteTopics (20) Versions 0..6
%7|1714632169.897|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:   ApiKey DeleteRecords (21) Versions 0..2
%7|1714632169.897|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:   ApiKey InitProducerId (22) Versions 0..4
%7|1714632169.897|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:   ApiKey OffsetForLeaderEpoch (23) Versions 0..4
%7|1714632169.897|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:   ApiKey AddPartitionsToTxn (24) Versions 0..3
%7|1714632169.897|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:   ApiKey AddOffsetsToTxn (25) Versions 0..3
%7|1714632169.897|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:   ApiKey EndTxn (26) Versions 0..3
%7|1714632169.897|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:   ApiKey WriteTxnMarkers (27) Versions 0..1
%7|1714632169.897|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:   ApiKey TxnOffsetCommit (28) Versions 0..3
%7|1714632169.897|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:   ApiKey DescribeAcls (29) Versions 0..3
%7|1714632169.897|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:   ApiKey CreateAcls (30) Versions 0..3
%7|1714632169.897|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:   ApiKey DeleteAcls (31) Versions 0..3
%7|1714632169.897|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:   ApiKey DescribeConfigs (32) Versions 0..4
%7|1714632169.897|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:   ApiKey AlterConfigs (33) Versions 0..2
%7|1714632169.897|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:   ApiKey AlterReplicaLogDirs (34) Versions 0..2
%7|1714632169.897|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:   ApiKey DescribeLogDirs (35) Versions 0..4
%7|1714632169.897|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:   ApiKey SaslAuthenticate (36) Versions 0..2
%7|1714632169.897|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:   ApiKey CreatePartitions (37) Versions 0..3
%7|1714632169.897|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:   ApiKey CreateDelegationToken (38) Versions 0..3
%7|1714632169.897|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:   ApiKey RenewDelegationToken (39) Versions 0..2
%7|1714632169.897|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:   ApiKey ExpireDelegationToken (40) Versions 0..2
%7|1714632169.897|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:   ApiKey DescribeDelegationToken (41) Versions 0..3
%7|1714632169.897|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:   ApiKey DeleteGroups (42) Versions 0..2
%7|1714632169.898|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:   ApiKey ElectLeadersRequest (43) Versions 0..2
%7|1714632169.898|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:   ApiKey IncrementalAlterConfigsRequest (44) Versions 0..1
%7|1714632169.898|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:   ApiKey AlterPartitionReassignmentsRequest (45) Versions 0..0
%7|1714632169.898|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:   ApiKey ListPartitionReassignmentsRequest (46) Versions 0..0
%7|1714632169.898|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:   ApiKey OffsetDeleteRequest (47) Versions 0..0
%7|1714632169.898|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:   ApiKey DescribeClientQuotasRequest (48) Versions 0..1
%7|1714632169.898|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:   ApiKey AlterClientQuotasRequest (49) Versions 0..1
%7|1714632169.898|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:   ApiKey DescribeUserScramCredentialsRequest (50) Versions 0..0
%7|1714632169.898|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:   ApiKey AlterUserScramCredentialsRequest (51) Versions 0..0
%7|1714632169.898|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:   ApiKey AlterIsrRequest (56) Versions 0..2
%7|1714632169.898|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:   ApiKey UpdateFeaturesRequest (57) Versions 0..1
%7|1714632169.898|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:   ApiKey EnvelopeRequest (58) Versions 0..0
%7|1714632169.898|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:   ApiKey DescribeCluster (60) Versions 0..0
%7|1714632169.898|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:   ApiKey DescribeProducers (61) Versions 0..0
%7|1714632169.898|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:   ApiKey DescribeTransactions (65) Versions 0..0
%7|1714632169.898|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:   ApiKey ListTransactions (66) Versions 0..0
%7|1714632169.898|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:   ApiKey AllocateProducerIds (67) Versions 0..0
%7|1714632169.898|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:  Feature MsgVer1: Produce (2..2) supported by broker
%7|1714632169.898|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:  Feature MsgVer1: Fetch (2..2) supported by broker
%7|1714632169.898|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1: Enabling feature MsgVer1
%7|1714632169.898|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:  Feature MsgVer2: Produce (3..3) supported by broker
%7|1714632169.898|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:  Feature MsgVer2: Fetch (4..4) supported by broker
%7|1714632169.898|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1: Enabling feature MsgVer2
%7|1714632169.898|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:  Feature ApiVersion: ApiVersion (0..0) supported by broker
%7|1714632169.898|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1: Enabling feature ApiVersion
%7|1714632169.898|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:  Feature BrokerGroupCoordinator: FindCoordinator (0..0) supported by broker
%7|1714632169.898|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1: Enabling feature BrokerGroupCoordinator
%7|1714632169.898|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:  Feature BrokerBalancedConsumer: FindCoordinator (0..0) supported by broker
%7|1714632169.898|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:  Feature BrokerBalancedConsumer: OffsetCommit (1..2) supported by broker
%7|1714632169.898|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:  Feature BrokerBalancedConsumer: OffsetFetch (1..1) supported by broker
%7|1714632169.898|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:  Feature BrokerBalancedConsumer: JoinGroup (0..0) supported by broker
%7|1714632169.898|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:  Feature BrokerBalancedConsumer: SyncGroup (0..0) supported by broker
%7|1714632169.898|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:  Feature BrokerBalancedConsumer: Heartbeat (0..0) supported by broker
%7|1714632169.898|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:  Feature BrokerBalancedConsumer: LeaveGroup (0..0) supported by broker
%7|1714632169.898|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1: Enabling feature BrokerBalancedConsumer
%7|1714632169.898|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:  Feature ThrottleTime: Produce (1..2) supported by broker
%7|1714632169.898|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:  Feature ThrottleTime: Fetch (1..2) supported by broker
%7|1714632169.898|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1: Enabling feature ThrottleTime
%7|1714632169.898|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:  Feature Sasl: JoinGroup (0..0) supported by broker
%7|1714632169.898|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1: Enabling feature Sasl
%7|1714632169.898|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:  Feature SaslHandshake: SaslHandshake (0..0) supported by broker
%7|1714632169.898|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1: Enabling feature SaslHandshake
%7|1714632169.898|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:  Feature LZ4: FindCoordinator (0..0) supported by broker
%7|1714632169.898|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1: Enabling feature LZ4
%7|1714632169.898|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:  Feature OffsetTime: ListOffsets (1..1) supported by broker
%7|1714632169.898|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1: Enabling feature OffsetTime
%7|1714632169.898|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:  Feature IdempotentProducer: InitProducerId (0..0) supported by broker
%7|1714632169.898|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1: Enabling feature IdempotentProducer
%7|1714632169.898|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:  Feature ZSTD: Produce (7..7) supported by broker
%7|1714632169.898|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:  Feature ZSTD: Fetch (10..10) supported by broker
%7|1714632169.898|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1: Enabling feature ZSTD
%7|1714632169.898|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:  Feature SaslAuthReq: SaslHandshake (1..1) supported by broker
%7|1714632169.898|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1:  Feature SaslAuthReq: SaslAuthenticate (0..1) supported by broker
%7|1714632169.898|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1: Enabling feature SaslAuthReq
%7|1714632169.898|FEATURE|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1: Updated enabled protocol features to MsgVer1,ApiVersion,BrokerBalancedConsumer,ThrottleTime,Sasl,SaslHandshake,BrokerGroupCoordinator,LZ4,OffsetTime,MsgVer2,IdempotentProducer,ZSTD,SaslAuthReq
%7|1714632169.898|STATE|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Broker changed state APIVERSION_QUERY -> UP
%7|1714632169.898|BROADCAST|rdkafka#consumer-1| [thrd:GroupCoordinator]: Broadcasting state change
%7|1714632169.898|METADATA|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1: Request metadata for brokers only: connected
%7|1714632169.898|CGRPSTATE|rdkafka#consumer-1| [thrd:main]: Group "EventSinkGO4000041" changed state wait-broker-transport -> up (join-state init)
%7|1714632169.898|BROADCAST|rdkafka#consumer-1| [thrd:main]: Broadcasting state change
%7|1714632169.898|JOIN|rdkafka#consumer-1| [thrd:main]: Group "EventSinkGO4000041": join with 0 subscribed topic(s)
%7|1714632169.898|METADATA|rdkafka#consumer-1| [thrd:main]: Hinted cache of 1/1 topic(s) being queried
%7|1714632169.898|CGRPMETADATA|rdkafka#consumer-1| [thrd:main]: consumer join: metadata for subscription only available for 0/1 topics (-1ms old)
%7|1714632169.898|SEND|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1: Sent MetadataRequest (v12, 26 bytes @ 0, CorrId 2)
%7|1714632169.898|METADATA|rdkafka#consumer-1| [thrd:main]: localhost:9092/1: Request metadata for 1 topic(s): consumer join
%7|1714632169.898|JOIN|rdkafka#consumer-1| [thrd:main]: Group "EventSinkGO4000041": postponing join until up-to-date metadata is available
%7|1714632169.898|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "EventSinkGO4000041" changed join state init -> wait-metadata (state up)
%7|1714632169.898|DUMP|rdkafka#consumer-1| [thrd:main]: Assignment dump (started_cnt=0, wait_stop_cnt=0)
%7|1714632169.898|DUMP_ALL|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s):
%7|1714632169.898|DUMP_PND|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s):
%7|1714632169.898|DUMP_QRY|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s):
%7|1714632169.898|DUMP_REM|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s):
%7|1714632169.898|ASSIGNDONE|rdkafka#consumer-1| [thrd:main]: Group "EventSinkGO4000041": assignment operations done in join-state wait-metadata (rebalance rejoin=false)
%7|1714632169.898|SEND|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1: Sent MetadataRequest (v12, 48 bytes @ 0, CorrId 6)
%7|1714632169.902|RECV|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1: Received MetadataResponse (v12, 55 bytes, CorrId 2, rtt 3.85ms)
%7|1714632169.902|RECV|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1: Received MetadataResponse (v12, 111 bytes, CorrId 6, rtt 3.82ms)
%7|1714632169.902|METADATA|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/1: ===== Received metadata: connected =====
%7|1714632169.902|METADATA|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/1: ClusterId: qpkV0ou8RcWYbqNwD3oREA, ControllerId: 1
%7|1714632169.902|METADATA|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/1: 1 brokers, 0 topics
%7|1714632169.902|METADATA|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/1:   Broker #0/1: localhost:9092 NodeId 1
%7|1714632169.902|METADATA|rdkafka#consumer-1| [thrd:main]: localhost:9092/1: ===== Received metadata (for 1 requested topics): consumer join =====
%7|1714632169.902|METADATA|rdkafka#consumer-1| [thrd:main]: localhost:9092/1: ClusterId: qpkV0ou8RcWYbqNwD3oREA, ControllerId: 1
%7|1714632169.902|METADATA|rdkafka#consumer-1| [thrd:main]: localhost:9092/1: 1 brokers, 1 topics
%7|1714632169.902|METADATA|rdkafka#consumer-1| [thrd:main]: localhost:9092/1:   Broker #0/1: localhost:9092 NodeId 1
%7|1714632169.902|METADATA|rdkafka#consumer-1| [thrd:main]: localhost:9092/1:   Topic Test with 1 partitions
%7|1714632169.902|METADATA|rdkafka#consumer-1| [thrd:main]: localhost:9092/1: 1/1 requested topic(s) seen in metadata
%7|1714632169.902|SUBSCRIPTION|rdkafka#consumer-1| [thrd:main]: Group "EventSinkGO4000041": effective subscription list changed from 0 to 1 topic(s):
%7|1714632169.902|SUBSCRIPTION|rdkafka#consumer-1| [thrd:main]:  Topic Test with 1 partition(s)
%7|1714632169.902|REJOIN|rdkafka#consumer-1| [thrd:main]: Group "EventSinkGO4000041": subscription updated from metadata change: rejoining group in state wait-metadata
%7|1714632169.902|GRPLEADER|rdkafka#consumer-1| [thrd:main]: Group "EventSinkGO4000041": resetting group leader info: group (re)join
%7|1714632169.902|REJOIN|rdkafka#consumer-1| [thrd:main]: Group "EventSinkGO4000041" (re)joining in join-state wait-metadata with 0 assigned partition(s): Metadata for subscribed topic(s) has changed
%7|1714632169.902|REBALANCE|rdkafka#consumer-1| [thrd:main]: Group "EventSinkGO4000041" initiating rebalance (NONE) in state up (join-state wait-metadata) with 0 assigned partition(s): Metadata for subscribed topic(s) has changed
%7|1714632169.902|REJOIN|rdkafka#consumer-1| [thrd:main]: Group "EventSinkGO4000041": Rejoining group without an assignment: Metadata for subscribed topic(s) has changed
%7|1714632169.902|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "EventSinkGO4000041" changed join state wait-metadata -> init (state up)
%7|1714632169.902|JOIN|rdkafka#consumer-1| [thrd:main]: Group "EventSinkGO4000041": join with 1 subscribed topic(s)
%7|1714632169.902|CGRPMETADATA|rdkafka#consumer-1| [thrd:main]: consumer join: metadata for subscription is up to date (0ms old)
%7|1714632169.902|JOIN|rdkafka#consumer-1| [thrd:main]: localhost:9092/1: Joining group "EventSinkGO4000041" with 1 subscribed topic(s) and member id ""
%7|1714632169.902|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "EventSinkGO4000041" changed join state init -> wait-join (state up)
%7|1714632169.902|SEND|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1: Sent JoinGroupRequest (v5, 146 bytes @ 0, CorrId 3)
%7|1714632169.902|BROADCAST|rdkafka#consumer-1| [thrd:GroupCoordinator]: Broadcasting state change
%7|1714632169.910|RECV|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1: Received JoinGroupResponse (v5, 64 bytes, CorrId 3, rtt 7.84ms)
%7|1714632169.910|JOINGROUP|rdkafka#consumer-1| [thrd:main]: JoinGroup response: GenerationId -1, Protocol , LeaderId , my MemberId rdkafka-a92495c1-002f-464b-9d31-8c51f05ada4f, member metadata count 0: Broker: Group member needs a valid member ID
%7|1714632169.910|REQERR|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/1: JoinGroupRequest failed: Broker: Group member needs a valid member ID: explicit actions Ignore
%7|1714632169.910|MEMBERID|rdkafka#consumer-1| [thrd:main]: Group "EventSinkGO4000041": updating member id "" -> "rdkafka-a92495c1-002f-464b-9d31-8c51f05ada4f"
%7|1714632169.910|REJOIN|rdkafka#consumer-1| [thrd:main]: Group "EventSinkGO4000041": Rejoining group without an assignment: JoinGroup error: Broker: Group member needs a valid member ID
%7|1714632169.910|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "EventSinkGO4000041" changed join state wait-join -> init (state up)
%7|1714632169.910|JOIN|rdkafka#consumer-1| [thrd:main]: Group "EventSinkGO4000041": join with 1 subscribed topic(s)
%7|1714632169.910|CGRPMETADATA|rdkafka#consumer-1| [thrd:main]: consumer join: metadata for subscription is up to date (8ms old)
%7|1714632169.910|JOIN|rdkafka#consumer-1| [thrd:main]: localhost:9092/1: Joining group "EventSinkGO4000041" with 1 subscribed topic(s) and member id "rdkafka-a92495c1-002f-464b-9d31-8c51f05ada4f"
%7|1714632169.910|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "EventSinkGO4000041" changed join state init -> wait-join (state up)
%7|1714632169.910|SEND|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1: Sent JoinGroupRequest (v5, 190 bytes @ 0, CorrId 4)
%7|1714632169.910|BROADCAST|rdkafka#consumer-1| [thrd:GroupCoordinator]: Broadcasting state change
%7|1714632172.917|RECV|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1: Received JoinGroupResponse (v5, 191 bytes, CorrId 4, rtt 3007.23ms)
%7|1714632172.917|JOINGROUP|rdkafka#consumer-1| [thrd:main]: JoinGroup response: GenerationId 45, Protocol range, LeaderId rdkafka-a92495c1-002f-464b-9d31-8c51f05ada4f (me), my MemberId rdkafka-a92495c1-002f-464b-9d31-8c51f05ada4f, member metadata count 1: (no error)
%7|1714632172.917|JOINGROUP|rdkafka#consumer-1| [thrd:main]: I am elected leader for group "EventSinkGO4000041" with 1 member(s)
%7|1714632172.918|GRPLEADER|rdkafka#consumer-1| [thrd:main]: Group "EventSinkGO4000041": resetting group leader info: JoinGroup response clean-up
%7|1714632172.918|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "EventSinkGO4000041" changed join state wait-join -> wait-metadata (state up)
%7|1714632172.918|METADATA|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/1: Request metadata for 1 topic(s): partition assignor
%7|1714632172.918|SEND|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1: Sent MetadataRequest (v12, 48 bytes @ 0, CorrId 5)
%7|1714632172.919|RECV|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1: Received MetadataResponse (v12, 111 bytes, CorrId 5, rtt 1.12ms)
%7|1714632172.919|METADATA|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/1: ===== Received metadata (for 1 requested topics): partition assignor =====
%7|1714632172.919|METADATA|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/1: ClusterId: qpkV0ou8RcWYbqNwD3oREA, ControllerId: 1
%7|1714632172.919|METADATA|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/1: 1 brokers, 1 topics
%7|1714632172.919|METADATA|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/1:   Broker #0/1: localhost:9092 NodeId 1
%7|1714632172.919|METADATA|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/1:   Topic Test with 1 partitions
%7|1714632172.919|METADATA|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/1: 1/1 requested topic(s) seen in metadata
%7|1714632172.919|ASSIGN|rdkafka#consumer-1| [thrd:main]: Group "EventSinkGO4000041" running range assignor for 1 member(s) and 1 eligible subscribed topic(s):
%7|1714632172.919|ASSIGN|rdkafka#consumer-1| [thrd:main]:  Member "rdkafka-a92495c1-002f-464b-9d31-8c51f05ada4f" (me) with 0 owned partition(s) and 1 subscribed topic(s):
%7|1714632172.919|ASSIGN|rdkafka#consumer-1| [thrd:main]:   Test [-1]
%7|1714632172.919|ASSIGN|rdkafka#consumer-1| [thrd:main]: range: Topic Test with 1 partition(s) and 1 subscribing member(s), single-topic non-rack-aware assignment for 1 leftover partitions
%7|1714632172.919|ASSIGN|rdkafka#consumer-1| [thrd:main]: Group "EventSinkGO4000041" range assignment for 1 member(s) finished in 0.314ms:
%7|1714632172.919|ASSIGN|rdkafka#consumer-1| [thrd:main]:  Member "rdkafka-a92495c1-002f-464b-9d31-8c51f05ada4f" (me) assigned 1 partition(s):
%7|1714632172.919|ASSIGN|rdkafka#consumer-1| [thrd:main]:   Test [0]
%7|1714632172.919|ASSIGNOR|rdkafka#consumer-1| [thrd:main]: Group "EventSinkGO4000041": "range" assignor run for 1 member(s)
%7|1714632172.919|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "EventSinkGO4000041" changed join state wait-metadata -> wait-sync (state up)
%7|1714632172.920|SEND|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1: Sent SyncGroupRequest (v3, 171 bytes @ 0, CorrId 6)
%7|1714632172.920|BROADCAST|rdkafka#consumer-1| [thrd:GroupCoordinator]: Broadcasting state change
%7|1714632172.928|RECV|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1: Received SyncGroupResponse (v3, 34 bytes, CorrId 6, rtt 7.10ms)
%7|1714632172.928|SYNCGROUP|rdkafka#consumer-1| [thrd:main]: SyncGroup response: Success (24 bytes of MemberState data)
%7|1714632172.928|ASSIGNMENT|rdkafka#consumer-1| [thrd:main]: List with 1 partition(s):
%7|1714632172.928|ASSIGNMENT|rdkafka#consumer-1| [thrd:main]:  Test [0] offset INVALID
%7|1714632172.928|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "EventSinkGO4000041" changed join state wait-sync -> wait-assign-call (state up)
%7|1714632172.928|ASSIGN|rdkafka#consumer-1| [thrd:main]: Group "EventSinkGO4000041": delegating assign of 1 partition(s) to application on queue rd_kafka_cgrp_new: new assignment
%7|1714632172.928|ASSIGNMENT|rdkafka#consumer-1| [thrd:main]: Group "EventSinkGO4000041": setting group assignment to 1 partition(s)
%7|1714632172.928|GRPASSIGNMENT|rdkafka#consumer-1| [thrd:main]: List with 1 partition(s):
%7|1714632172.928|GRPASSIGNMENT|rdkafka#consumer-1| [thrd:main]:  Test [0] offset INVALID
%7|1714632172.928|HEARTBEAT|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/1: Heartbeat for group "EventSinkGO4000041" generation id 45
%7|1714632172.928|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "EventSinkGO4000041" received op GET_REBALANCE_PROTOCOL in state up (join-state wait-assign-call)
%7|1714632172.929|SEND|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1: Sent HeartbeatRequest (v3, 93 bytes @ 0, CorrId 7)
%7|1714632172.929|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "EventSinkGO4000041" received op ASSIGN in state up (join-state wait-assign-call)
%7|1714632172.929|ASSIGN|rdkafka#consumer-1| [thrd:main]: Group "EventSinkGO4000041": new assignment of 1 partition(s) in join-state wait-assign-call
%7|1714632172.929|CLEARASSIGN|rdkafka#consumer-1| [thrd:main]: No current assignment to clear
%7|1714632172.929|TOPIC|rdkafka#consumer-1| [thrd:main]: New local topic: Test
%7|1714632172.929|TOPPARNEW|rdkafka#consumer-1| [thrd:main]: NEW Test [-1] 0x152808800 refcnt 0x152808890 (at rd_kafka_topic_new0:472)
%7|1714632172.929|STATE|rdkafka#consumer-1| [thrd:main]: Topic Test changed state unknown -> exists
%7|1714632172.929|PARTCNT|rdkafka#consumer-1| [thrd:main]: Topic Test partition count changed from 0 to 1
%7|1714632172.929|TOPPARNEW|rdkafka#consumer-1| [thrd:main]: NEW Test [0] 0x152808e00 refcnt 0x152808e90 (at rd_kafka_topic_partition_cnt_update:912)
%7|1714632172.929|METADATA|rdkafka#consumer-1| [thrd:main]:   Topic Test partition 0 Leader 1 Epoch 0
%7|1714632172.929|BROKER|rdkafka#consumer-1| [thrd:main]: Test [0]: leader -1 epoch -1 -> leader 1 epoch 0
%7|1714632172.929|BRKDELGT|rdkafka#consumer-1| [thrd:main]: Test [0]: delegate to broker localhost:9092/1 (rktp 0x152808e00, term 0, ref 3)
%7|1714632172.929|BRKDELGT|rdkafka#consumer-1| [thrd:main]: Test [0]: delegating to broker localhost:9092/1 for partition with 0 messages (0 bytes) queued
%7|1714632172.929|BRKMIGR|rdkafka#consumer-1| [thrd:main]: Migrating topic Test [0] 0x152808e00 from (none) to localhost:9092/1 (sending PARTITION_JOIN to localhost:9092/1)
%7|1714632172.929|VALIDATE|rdkafka#consumer-1| [thrd:main]: Test [0]: skipping offset validation in fetch state none
%7|1714632172.929|CONF|rdkafka#consumer-1| [thrd:main]: Topic "Test" configuration (default_topic_conf):
%7|1714632172.929|CONF|rdkafka#consumer-1| [thrd:main]:   auto.offset.reset = smallest
%7|1714632172.929|DESIRED|rdkafka#consumer-1| [thrd:main]: Test [0]: marking as DESIRED
%7|1714632172.929|ASSIGNMENT|rdkafka#consumer-1| [thrd:main]: Added 1 partition(s) to assignment which now consists of 1 partition(s) where of 1 are in pending state and 0 are being queried
%7|1714632172.929|PAUSE|rdkafka#consumer-1| [thrd:main]: Resuming fetchers for 1 assigned partition(s): assign called
%7|1714632172.929|RESUME|rdkafka#consumer-1| [thrd:main]: Library resuming 1 partition(s)
%7|1714632172.929|BARRIER|rdkafka#consumer-1| [thrd:main]: Test [0]: rd_kafka_toppar_op_pause_resume:2305: new version barrier v2
%7|1714632172.929|RESUME|rdkafka#consumer-1| [thrd:main]: Resume Test [0] (v2)
%7|1714632172.929|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "EventSinkGO4000041" changed join state wait-assign-call -> steady (state up)
%7|1714632172.929|DUMP|rdkafka#consumer-1| [thrd:main]: Assignment dump (started_cnt=0, wait_stop_cnt=0)
%7|1714632172.929|DUMP_ALL|rdkafka#consumer-1| [thrd:main]: List with 1 partition(s):
%7|1714632172.929|DUMP_ALL|rdkafka#consumer-1| [thrd:main]:  Test [0] offset STORED
%7|1714632172.930|DUMP_PND|rdkafka#consumer-1| [thrd:main]: List with 1 partition(s):
%7|1714632172.930|DUMP_PND|rdkafka#consumer-1| [thrd:main]:  Test [0] offset STORED
%7|1714632172.930|DUMP_QRY|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s):
%7|1714632172.930|DUMP_REM|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s):
%7|1714632172.930|SRVPEND|rdkafka#consumer-1| [thrd:main]: Querying committed offset for pending assigned partition Test [0]
%7|1714632172.930|OFFSETFETCH|rdkafka#consumer-1| [thrd:main]: Fetching committed offsets for 1 pending partition(s) in assignment
%7|1714632172.930|OFFSET|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/1: Group EventSinkGO4000041 OffsetFetchRequest(v7) for 1/1 partition(s)
%7|1714632172.930|OFFSET|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/1: Fetch committed offsets for 1/1 partition(s)
%7|1714632172.930|ASSIGNMENT|rdkafka#consumer-1| [thrd:main]: Current assignment of 1 partition(s) with 1 pending adds, 1 offset queries, 0 partitions awaiting stop and 0 offset commits in progress
%7|1714632172.930|OP|rdkafka#consumer-1| [thrd:main]: Test [0] received op PAUSE (v2) in fetch-state none (opv1)
%7|1714632172.930|TOPBRK|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1: Topic Test [0]: joining broker (rktp 0x152808e00, 0 message(s) queued)
%7|1714632172.930|BROADCAST|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
%7|1714632172.930|RECV|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1: Received HeartbeatResponse (v3, 6 bytes, CorrId 7, rtt 1.17ms)
%7|1714632172.930|SEND|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1: Sent OffsetFetchRequest (v7, 55 bytes @ 0, CorrId 8)
%7|1714632172.930|RESUME|rdkafka#consumer-1| [thrd:main]: Not resuming Test [0]: partition is not paused by library
%7|1714632172.932|RECV|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1: Received OffsetFetchResponse (v7, 36 bytes, CorrId 8, rtt 2.29ms)
%7|1714632172.932|OFFSETFETCH|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/1: OffsetFetchResponse: Test [0] offset -1, leader epoch -1, metadata 0 byte(s): NO_ERROR
%7|1714632172.932|OFFFETCH|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/1: OffsetFetch for 1/1 partition(s) (0 unstable partition(s)) returned Success
%7|1714632172.932|OFFSETFETCH|rdkafka#consumer-1| [thrd:main]: Adding Test [0] back to pending list with offset INVALID
%7|1714632172.932|DUMP|rdkafka#consumer-1| [thrd:main]: Assignment dump (started_cnt=0, wait_stop_cnt=0)
%7|1714632172.932|DUMP_ALL|rdkafka#consumer-1| [thrd:main]: List with 1 partition(s):
%7|1714632172.932|DUMP_ALL|rdkafka#consumer-1| [thrd:main]:  Test [0] offset STORED
%7|1714632172.932|DUMP_PND|rdkafka#consumer-1| [thrd:main]: List with 1 partition(s):
%7|1714632172.932|DUMP_PND|rdkafka#consumer-1| [thrd:main]:  Test [0] offset INVALID
%7|1714632172.932|DUMP_QRY|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s):
%7|1714632172.932|DUMP_REM|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s):
%7|1714632172.932|SRVPEND|rdkafka#consumer-1| [thrd:main]: Starting pending assigned partition Test [0] at offset INVALID (leader epoch -1)
%7|1714632172.932|BARRIER|rdkafka#consumer-1| [thrd:main]: Test [0]: rd_kafka_toppar_op_pause_resume:2305: new version barrier v3
%7|1714632172.932|RESUME|rdkafka#consumer-1| [thrd:main]: Resume Test [0] (v3)
%7|1714632172.932|BARRIER|rdkafka#consumer-1| [thrd:main]: Test [0]: rd_kafka_toppar_op_fetch_start:2219: new version barrier v4
%7|1714632172.932|CONSUMER|rdkafka#consumer-1| [thrd:main]: Start consuming Test [0] at offset INVALID (leader epoch -1) (v4)
%7|1714632172.932|ASSIGNDONE|rdkafka#consumer-1| [thrd:main]: Group "EventSinkGO4000041": assignment operations done in join-state steady (rebalance rejoin=false)
%7|1714632172.932|OP|rdkafka#consumer-1| [thrd:main]: Test [0] received op PAUSE (v3) in fetch-state none (opv2)
%7|1714632172.932|RESUME|rdkafka#consumer-1| [thrd:main]: Not resuming Test [0]: partition is not paused by library
%7|1714632172.932|OP|rdkafka#consumer-1| [thrd:main]: Test [0] received op FETCH_START (v4) in fetch-state none (opv3)
%7|1714632172.932|FETCH|rdkafka#consumer-1| [thrd:main]: Start fetch for Test [0] in state none at offset INVALID (leader epoch -1) (v4)
%7|1714632172.932|PARTSTATE|rdkafka#consumer-1| [thrd:main]: Partition Test [0] changed fetch state none -> offset-query
%7|1714632172.932|OFFSET|rdkafka#consumer-1| [thrd:main]: Test [0]: offset reset (at offset INVALID (leader epoch -1), broker -1) to offset BEGINNING (leader epoch -1): no previously committed offset available: Local: No offset stored
%7|1714632172.932|OFFSET|rdkafka#consumer-1| [thrd:main]: Test [0]: backoff: (re)starting offset query timer for offset BEGINNING (leader epoch -1)
%7|1714632172.932|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "EventSinkGO4000041" received op PARTITION_JOIN in state up (join-state steady) for Test [0]
%7|1714632172.932|PARTADD|rdkafka#consumer-1| [thrd:main]: Group "EventSinkGO4000041": add Test [0]
%7|1714632173.033|OFFSET|rdkafka#consumer-1| [thrd:main]: Topic Test [0]: timed offset query for offset BEGINNING (leader epoch -1) in state offset-query
%7|1714632173.033|OFFREQ|rdkafka#consumer-1| [thrd:main]: localhost:9092/1: Partition Test [0]: querying for logical offset BEGINNING (opv 4)
%7|1714632173.033|PARTSTATE|rdkafka#consumer-1| [thrd:main]: Partition Test [0] changed fetch state offset-query -> offset-wait
%7|1714632173.033|OFFSET|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1: ListOffsetsRequest (v7, opv 4) for 1 topic(s) and 1 partition(s)
%7|1714632173.033|SEND|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1: Sent ListOffsetsRequest (v7, 53 bytes @ 0, CorrId 7)
%7|1714632173.037|RECV|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1: Received ListOffsetsResponse (v7, 41 bytes, CorrId 7, rtt 3.28ms)
%7|1714632173.037|OFFSET|rdkafka#consumer-1| [thrd:main]: localhost:9092/1: Offset reply for topic Test [0] (v4 vs v4)
%7|1714632173.037|OFFSET|rdkafka#consumer-1| [thrd:main]: Offset BEGINNING request for Test [0] returned offset 0 (0) leader epoch 0
%7|1714632173.037|PARTSTATE|rdkafka#consumer-1| [thrd:main]: Partition Test [0] changed fetch state offset-wait -> active
%7|1714632173.037|FETCH|rdkafka#consumer-1| [thrd:main]: Partition Test [0] start fetching at offset 0 (leader epoch 0)
%7|1714632173.037|WAKEUP|rdkafka#consumer-1| [thrd:main]: localhost:9092/1: Wake-up: ready to fetch
%7|1714632173.037|FETCHDEC|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: Topic Test [0]: fetch decide: updating to version 4 (was 0) at offset 0 (leader epoch 0) (was offset 0 (leader epoch -1))
%7|1714632173.037|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1: Topic Test [0] in state active at offset 0 (leader epoch 0) (0/100000 msgs, 0/65536 kb queued, opv 4) is fetchable
%7|1714632173.037|FETCHADD|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1: Added Test [0] to fetch list (1 entries, opv 4, 0 messages queued): fetchable
%7|1714632173.037|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1: Fetch topic Test [0] at offset 0 (leader epoch 0, current leader epoch 0, v4)
%7|1714632173.037|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1: Fetch 1/1/1 toppar(s)
%7|1714632173.037|SEND|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1: Sent FetchRequest (v11, 94 bytes @ 0, CorrId 8)
%7|1714632173.541|RECV|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1: Received FetchResponse (v11, 66 bytes, CorrId 8, rtt 503.88ms)
%7|1714632173.541|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1: Topic Test [0] MessageSet size 0, error "Success", MaxOffset 0, LSO 0, Ver 4/4
%7|1714632173.541|FETCHERR|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1: Test [0]: Fetch failed at offset 0 (leader epoch 0): _PARTITION_EOF
%7|1714632173.541|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1: Fetch topic Test [0] at offset 0 (leader epoch 0, current leader epoch 0, v4)
%7|1714632173.541|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1: Fetch 1/1/1 toppar(s)
%7|1714632173.541|SEND|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1: Sent FetchRequest (v11, 94 bytes @ 0, CorrId 9)
%7|1714632174.045|RECV|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1: Received FetchResponse (v11, 66 bytes, CorrId 9, rtt 503.27ms)
%7|1714632174.045|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1: Topic Test [0] MessageSet size 0, error "Success", MaxOffset 0, LSO 0, Ver 4/4
%7|1714632174.045|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1: Fetch topic Test [0] at offset 0 (leader epoch 0, current leader epoch 0, v4)
%7|1714632174.045|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1: Fetch 1/1/1 toppar(s)
%7|1714632174.045|SEND|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1: Sent FetchRequest (v11, 94 bytes @ 0, CorrId 10)
%7|1714632174.551|RECV|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1: Received FetchResponse (v11, 66 bytes, CorrId 10, rtt 505.82ms)
%7|1714632174.551|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1: Topic Test [0] MessageSet size 0, error "Success", MaxOffset 0, LSO 0, Ver 4/4
%7|1714632174.551|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1: Fetch topic Test [0] at offset 0 (leader epoch 0, current leader epoch 0, v4)
%7|1714632174.551|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1: Fetch 1/1/1 toppar(s)
%7|1714632174.551|SEND|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1: Sent FetchRequest (v11, 94 bytes @ 0, CorrId 11)
%7|1714632174.894|CLOSE|rdkafka#consumer-1| [thrd:app]: Closing consumer
%7|1714632174.894|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "EventSinkGO4000041" received op TERMINATE in state up (join-state steady)
%7|1714632174.894|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Terminating group "EventSinkGO4000041" in state up with 1 partition(s)
%7|1714632174.894|UNSUBSCRIBE|rdkafka#consumer-1| [thrd:main]: Group "EventSinkGO4000041": unsubscribe from current subscription of size 1 (leave group=true, has joined=true, rdkafka-a92495c1-002f-464b-9d31-8c51f05ada4f, join-state steady)
%7|1714632174.894|SUBSCRIPTION|rdkafka#consumer-1| [thrd:main]: Group "EventSinkGO4000041": clearing subscribed topics list (1)
%7|1714632174.894|SUBSCRIPTION|rdkafka#consumer-1| [thrd:main]: Group "EventSinkGO4000041": effective subscription list changed from 1 to 0 topic(s):
%7|1714632174.894|GRPLEADER|rdkafka#consumer-1| [thrd:main]: Group "EventSinkGO4000041": resetting group leader info: unsubscribe
%7|1714632174.894|REBALANCE|rdkafka#consumer-1| [thrd:main]: Group "EventSinkGO4000041" initiating rebalance (EAGER) in state up (join-state steady) with 1 assigned partition(s): unsubscribe
%7|1714632174.894|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "EventSinkGO4000041" changed join state steady -> wait-unassign-call (state up)
%7|1714632174.894|ASSIGN|rdkafka#consumer-1| [thrd:main]: Group "EventSinkGO4000041": delegating revoke of 1 partition(s) to application on queue rd_kafka_cgrp_new: unsubscribe
%7|1714632174.894|PAUSE|rdkafka#consumer-1| [thrd:main]: Pausing fetchers for 1 assigned partition(s): rebalance
%7|1714632174.894|PAUSE|rdkafka#consumer-1| [thrd:main]: Library pausing 1 partition(s)
%7|1714632174.894|BARRIER|rdkafka#consumer-1| [thrd:main]: Test [0]: rd_kafka_toppar_op_pause_resume:2305: new version barrier v5
%7|1714632174.894|PAUSE|rdkafka#consumer-1| [thrd:main]: Pause Test [0] (v5)
%7|1714632174.894|ASSIGNMENT|rdkafka#consumer-1| [thrd:main]: Group "EventSinkGO4000041": clearing group assignment
%7|1714632174.894|DUMP|rdkafka#consumer-1| [thrd:main]: Assignment dump (started_cnt=1, wait_stop_cnt=0)
%7|1714632174.894|DUMP_ALL|rdkafka#consumer-1| [thrd:main]: List with 1 partition(s):
%7|1714632174.894|DUMP_ALL|rdkafka#consumer-1| [thrd:main]:  Test [0] offset STORED
%7|1714632174.894|DUMP_PND|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s):
%7|1714632174.894|DUMP_QRY|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s):
%7|1714632174.894|DUMP_REM|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s):
%7|1714632174.894|ASSIGNDONE|rdkafka#consumer-1| [thrd:main]: Group "EventSinkGO4000041": assignment operations done in join-state wait-unassign-call (rebalance rejoin=false)
%7|1714632174.894|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "EventSinkGO4000041": waiting for assign call, 1 toppar(s), 0 commit(s) (state up, join-state wait-unassign-call) before terminating
%7|1714632174.894|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "EventSinkGO4000041": waiting for assign call, 1 toppar(s), 0 commit(s) (state up, join-state wait-unassign-call) before terminating
%7|1714632174.895|OP|rdkafka#consumer-1| [thrd:main]: Test [0] received op PAUSE (v5) in fetch-state active (opv4)
%7|1714632174.895|PAUSE|rdkafka#consumer-1| [thrd:main]: Pause Test [0]: at offset 0 (leader epoch 0) (state active, v5)
%7|1714632174.895|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "EventSinkGO4000041" received op GET_REBALANCE_PROTOCOL in state up (join-state wait-unassign-call)
%7|1714632174.895|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "EventSinkGO4000041": waiting for assign call, 1 toppar(s), 0 commit(s) (state up, join-state wait-unassign-call) before terminating
%7|1714632174.895|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "EventSinkGO4000041" received op ASSIGN in state up (join-state wait-unassign-call)
%7|1714632174.895|ASSIGN|rdkafka#consumer-1| [thrd:main]: Group "EventSinkGO4000041": Consumer is terminating: treating assign as unassign
%7|1714632174.895|CLEARASSIGN|rdkafka#consumer-1| [thrd:main]: Clearing current assignment of 1 partition(s)
%7|1714632174.895|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "EventSinkGO4000041" changed join state wait-unassign-call -> wait-unassign-to-complete (state up)
%7|1714632174.895|DUMP|rdkafka#consumer-1| [thrd:main]: Assignment dump (started_cnt=1, wait_stop_cnt=0)
%7|1714632174.895|DUMP_ALL|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s):
%7|1714632174.895|DUMP_PND|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s):
%7|1714632174.895|DUMP_QRY|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s):
%7|1714632174.895|DUMP_REM|rdkafka#consumer-1| [thrd:main]: List with 1 partition(s):
%7|1714632174.895|DUMP_REM|rdkafka#consumer-1| [thrd:main]:  Test [0] offset STORED
%7|1714632174.895|BARRIER|rdkafka#consumer-1| [thrd:main]: Test [0]: rd_kafka_toppar_op_fetch_stop:2245: new version barrier v6
%7|1714632174.895|CONSUMER|rdkafka#consumer-1| [thrd:main]: Stop consuming Test [0] (v6)
%7|1714632174.895|BARRIER|rdkafka#consumer-1| [thrd:main]: Test [0]: rd_kafka_toppar_op_pause_resume:2305: new version barrier v7
%7|1714632174.895|RESUME|rdkafka#consumer-1| [thrd:main]: Resume Test [0] (v7)
%7|1714632174.895|DESP|rdkafka#consumer-1| [thrd:main]: Removing (un)desired topic Test [0]
%7|1714632174.895|REMOVE|rdkafka#consumer-1| [thrd:main]: Removing Test [0] from assignment (started=true, pending=false, queried=false, stored offset=INVALID)
%7|1714632174.895|REMOVE|rdkafka#consumer-1| [thrd:main]: Served 1 removed partition(s), with 0 offset(s) to commit
%7|1714632174.895|ASSIGNMENT|rdkafka#consumer-1| [thrd:main]: Current assignment of 0 partition(s) with 0 pending adds, 0 offset queries, 1 partitions awaiting stop and 0 offset commits in progress
%7|1714632174.895|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "EventSinkGO4000041": waiting for 1 toppar(s), assignment in progress, 0 commit(s) (state up, join-state wait-unassign-to-complete) before terminating
%7|1714632174.895|OP|rdkafka#consumer-1| [thrd:main]: Test [0] received op FETCH_STOP (v6) in fetch-state active (opv5)
%7|1714632174.895|FETCH|rdkafka#consumer-1| [thrd:main]: Stopping fetch for Test [0] in state active (v6)
%7|1714632174.895|PARTSTATE|rdkafka#consumer-1| [thrd:main]: Partition Test [0] changed fetch state active -> stopping
%7|1714632174.895|STORETERM|rdkafka#consumer-1| [thrd:main]: Test [0]: offset store terminating
%7|1714632174.895|PARTSTATE|rdkafka#consumer-1| [thrd:main]: Partition Test [0] changed fetch state stopping -> stopped
%7|1714632174.895|OP|rdkafka#consumer-1| [thrd:main]: Test [0] received op PAUSE (v7) in fetch-state stopped (opv6)
%7|1714632174.895|RESUME|rdkafka#consumer-1| [thrd:main]: Not resuming stopped Test [0]: at offset 0 (leader epoch 0) (state stopped, v7)
%7|1714632174.895|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "EventSinkGO4000041": waiting for 1 toppar(s), assignment in progress, 0 commit(s) (state up, join-state wait-unassign-to-complete) before terminating
%7|1714632174.895|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "EventSinkGO4000041" received op PARTITION_LEAVE in state up (join-state wait-unassign-to-complete) for Test [0]
%7|1714632174.895|PARTDEL|rdkafka#consumer-1| [thrd:main]: Group "EventSinkGO4000041": delete Test [0]
%7|1714632174.895|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "EventSinkGO4000041": waiting for 0 toppar(s), assignment in progress, 0 commit(s) (state up, join-state wait-unassign-to-complete) before terminating
%7|1714632174.895|STOPSERVE|rdkafka#consumer-1| [thrd:main]: All partitions awaiting stop are now stopped: serving assignment
%7|1714632174.895|DUMP|rdkafka#consumer-1| [thrd:main]: Assignment dump (started_cnt=0, wait_stop_cnt=0)
%7|1714632174.895|DUMP_ALL|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s):
%7|1714632174.895|DUMP_PND|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s):
%7|1714632174.895|DUMP_QRY|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s):
%7|1714632174.895|DUMP_REM|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s):
%7|1714632174.895|ASSIGNDONE|rdkafka#consumer-1| [thrd:main]: Group "EventSinkGO4000041": assignment operations done in join-state wait-unassign-to-complete (rebalance rejoin=false)
%7|1714632174.895|UNASSIGN|rdkafka#consumer-1| [thrd:main]: Group "EventSinkGO4000041": unassign done in state up (join-state wait-unassign-to-complete)
%7|1714632174.895|MEMBERID|rdkafka#consumer-1| [thrd:main]: Group "EventSinkGO4000041": updating member id "rdkafka-a92495c1-002f-464b-9d31-8c51f05ada4f" -> ""
%7|1714632174.895|LEAVE|rdkafka#consumer-1| [thrd:main]: Group "EventSinkGO4000041": leave (in state up)
%7|1714632174.895|LEAVE|rdkafka#consumer-1| [thrd:main]: localhost:9092/1: Leaving group
%7|1714632174.895|NOREJOIN|rdkafka#consumer-1| [thrd:main]: Group "EventSinkGO4000041": Not rejoining group without an assignment: Unassignment done: no subscribed topics
%7|1714632174.895|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "EventSinkGO4000041" changed join state wait-unassign-to-complete -> init (state up)
%7|1714632174.895|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "EventSinkGO4000041": waiting for 0 toppar(s), 0 commit(s), wait-leave, (state up, join-state init) before terminating
%7|1714632174.896|SEND|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1: Sent LeaveGroupRequest (v1, 87 bytes @ 0, CorrId 9)
%7|1714632174.901|RECV|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1: Received LeaveGroupResponse (v1, 6 bytes, CorrId 9, rtt 5.88ms)
%7|1714632174.901|LEAVEGROUP|rdkafka#consumer-1| [thrd:main]: LeaveGroup response received in state up
%7|1714632174.901|CGRPSTATE|rdkafka#consumer-1| [thrd:main]: Group "EventSinkGO4000041" changed state up -> term (join-state init)
%7|1714632174.901|BROADCAST|rdkafka#consumer-1| [thrd:main]: Broadcasting state change
%7|1714632174.901|ASSIGNMENT|rdkafka#consumer-1| [thrd:main]: Group "EventSinkGO4000041": clearing group assignment
%7|1714632174.901|COORDCLEAR|rdkafka#consumer-1| [thrd:main]: Group "EventSinkGO4000041" broker localhost:9092/1 is no longer coordinator
%7|1714632174.902|NODENAME|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/1: Broker nodename changed from "localhost:9092" to ""
%7|1714632174.902|NODEID|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/1: Broker nodeid changed from 1 to -1
%7|1714632174.902|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Consumer group sub-system terminated (will enqueue reply)
%7|1714632174.902|DESTROY|rdkafka#consumer-1| [thrd:app]: Terminating instance (destroy flags none (0x0))
%7|1714632174.902|TERMINATE|rdkafka#consumer-1| [thrd:app]: Terminating consumer group handler
%7|1714632174.902|TERMINATE|rdkafka#consumer-1| [thrd:app]: Interrupting timers
%7|1714632174.902|TERMINATE|rdkafka#consumer-1| [thrd:app]: Sending TERMINATE to internal main thread
%7|1714632174.902|TERMINATE|rdkafka#consumer-1| [thrd:app]: Joining internal main thread
%7|1714632174.902|FAIL|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Closing connection due to nodename change (after 5003ms in state UP) (_TRANSPORT)
%7|1714632174.902|STATE|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Broker changed state UP -> DOWN
%7|1714632174.902|BROADCAST|rdkafka#consumer-1| [thrd:GroupCoordinator]: Broadcasting state change
%7|1714632174.902|BUFQ|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Purging bufq with 0 buffers
%7|1714632174.902|BUFQ|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Purging bufq with 0 buffers
%7|1714632174.902|BUFQ|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Updating 0 buffers on connection reset
%7|1714632174.902|BRKTERM|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: terminating: broker still has 4 refcnt(s), 0 buffer(s), 0 partition(s)
%7|1714632174.902|METADATA|rdkafka#consumer-1| [thrd:GroupCoordinator]: Requesting metadata for 1/1 topics: broker down
%7|1714632174.902|TERMINATE|rdkafka#consumer-1| [thrd:main]: Internal main thread terminating
%7|1714632174.902|DESTROY|rdkafka#consumer-1| [thrd:main]: Destroy internal
%7|1714632174.902|BROADCAST|rdkafka#consumer-1| [thrd:main]: Broadcasting state change
%7|1714632174.902|DESTROY|rdkafka#consumer-1| [thrd:main]: Removing all topics
%7|1714632174.902|PARTCNT|rdkafka#consumer-1| [thrd:main]: Topic Test partition count changed from 1 to 0
%7|1714632174.902|REMOVE|rdkafka#consumer-1| [thrd:main]: Test [0] no longer reported in metadata
%7|1714632174.902|BRKMIGR|rdkafka#consumer-1| [thrd:main]: Test [0] 0x152808e00 sending final LEAVE for removal by localhost:9092/1
%7|1714632174.902|TOPPARREMOVE|rdkafka#consumer-1| [thrd:main]: Removing toppar Test [-1] 0x152808800
%7|1714632174.902|DESTROY|rdkafka#consumer-1| [thrd:main]: Test [-1]: 0x152808800 DESTROY_FINAL
%7|1714632174.902|DESTROY|rdkafka#consumer-1| [thrd:main]: Sending TERMINATE to localhost:9092/1
%7|1714632174.902|DESTROY|rdkafka#consumer-1| [thrd:main]: Sending TERMINATE to GroupCoordinator
%7|1714632174.902|TERMINATE|rdkafka#consumer-1| [thrd:main]: Purging reply queue
%7|1714632174.902|TERMINATE|rdkafka#consumer-1| [thrd:main]: Decommissioning internal broker
%7|1714632174.902|TERMINATE|rdkafka#consumer-1| [thrd:main]: Join 3 broker thread(s)
%7|1714632174.902|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1: Topic Test [0] in state stopped at offset 0 (leader epoch 0) (0/100000 msgs, 0/65536 kb queued, opv 4) is not fetchable: forced removal
%7|1714632174.902|FETCHADD|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1: Removed Test [0] from fetch list (0 entries, opv 4): forced removal
%7|1714632174.902|METADATA|rdkafka#consumer-1| [thrd:GroupCoordinator]: localhost:9092/1: Request metadata for 1 topic(s): broker down
%7|1714632174.902|TERM|rdkafka#consumer-1| [thrd::0/internal]: :0/internal: Received TERMINATE op in state INIT: 2 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs
%7|1714632174.902|FAIL|rdkafka#consumer-1| [thrd::0/internal]: :0/internal: Client is terminating (after 5036ms in state INIT) (_DESTROY)
%7|1714632174.902|STATE|rdkafka#consumer-1| [thrd::0/internal]: :0/internal: Broker changed state INIT -> DOWN
%7|1714632174.902|BROADCAST|rdkafka#consumer-1| [thrd::0/internal]: Broadcasting state change
%7|1714632174.902|BUFQ|rdkafka#consumer-1| [thrd::0/internal]: :0/internal: Purging bufq with 0 buffers
%7|1714632174.902|BUFQ|rdkafka#consumer-1| [thrd::0/internal]: :0/internal: Purging bufq with 0 buffers
%7|1714632174.902|BUFQ|rdkafka#consumer-1| [thrd::0/internal]: :0/internal: Updating 0 buffers on connection reset
%7|1714632174.902|BRKTERM|rdkafka#consumer-1| [thrd::0/internal]: :0/internal: terminating: broker still has 2 refcnt(s), 0 buffer(s), 0 partition(s)
%7|1714632174.902|TERMINATE|rdkafka#consumer-1| [thrd::0/internal]: :0/internal: Handle is terminating in state DOWN: 1 refcnts (0x15081abe8), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf
%7|1714632174.902|FAIL|rdkafka#consumer-1| [thrd::0/internal]: :0/internal: Broker handle is terminating (after 0ms in state DOWN) (_DESTROY)
%7|1714632174.902|BUFQ|rdkafka#consumer-1| [thrd::0/internal]: :0/internal: Purging bufq with 0 buffers
%7|1714632174.902|TERMINATE|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Handle is terminating in state DOWN: 2 refcnts (0x150819de8), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf
%7|1714632174.902|TOPBRK|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1: Topic Test [0]: leaving broker (0 messages in xmitq, next broker (none), rktp 0x152808e00)
%7|1714632174.902|TOPBRK|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1: Topic Test [0]: no next broker, failing 0 message(s) in partition queue
%7|1714632174.902|BROADCAST|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
%7|1714632174.902|BUFQ|rdkafka#consumer-1| [thrd::0/internal]: :0/internal: Purging bufq with 0 buffers
%7|1714632174.902|TERM|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1: Received TERMINATE op in state UP: 5 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 1 waitresps, 0 retrybufs
%7|1714632174.902|FAIL|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1: Client is terminating (after 5019ms in state UP) (_DESTROY)
%7|1714632174.902|STATE|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1: Broker changed state UP -> DOWN
%7|1714632174.902|BROADCAST|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
%7|1714632174.902|BUFQ|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1: Purging bufq with 1 buffers
%7|1714632174.902|TOPPARREMOVE|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: Removing toppar Test [0] 0x152808e00
%7|1714632174.902|DESTROY|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: Test [0]: 0x152808e00 DESTROY_FINAL
%7|1714632174.902|BUFQ|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1: Purging bufq with 0 buffers
%7|1714632174.902|BUFQ|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1: Updating 0 buffers on connection reset
%7|1714632174.902|BRKTERM|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1: terminating: broker still has 3 refcnt(s), 0 buffer(s), 0 partition(s)
%7|1714632174.902|TERMINATE|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1: Handle is terminating in state DOWN: 2 refcnts (0x15081b9e8), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf
%7|1714632174.902|STATE|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1: Broker changed state DOWN -> INIT
%7|1714632174.902|BROADCAST|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
%7|1714632174.902|STATE|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1: Broker changed state INIT -> TRY_CONNECT
%7|1714632174.902|BROADCAST|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
%7|1714632174.902|BUFQ|rdkafka#consumer-1| [thrd::0/internal]: :0/internal: Updating 0 buffers on connection reset
%7|1714632174.902|TERMINATE|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1: Handle is terminating in state TRY_CONNECT: 1 refcnts (0x15081b9e8), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 1 request(s) in retry+outbuf
%7|1714632174.902|FAIL|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1: Broker handle is terminating (after 0ms in state TRY_CONNECT) (_DESTROY)
%7|1714632174.902|STATE|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1: Broker changed state TRY_CONNECT -> DOWN
%7|1714632174.902|BROADCAST|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
%7|1714632174.902|BUFQ|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1: Purging bufq with 0 buffers
%7|1714632174.902|BUFQ|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1: Purging bufq with 0 buffers
%7|1714632174.902|BUFQ|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1: Updating 0 buffers on connection reset
%7|1714632174.902|STATE|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Broker changed state DOWN -> INIT
%7|1714632174.902|BROADCAST|rdkafka#consumer-1| [thrd:GroupCoordinator]: Broadcasting state change
%7|1714632174.902|TERM|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Received TERMINATE op in state INIT: 2 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs
%7|1714632174.902|FAIL|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Client is terminating (after 0ms in state INIT) (_DESTROY)
%7|1714632174.902|STATE|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Broker changed state INIT -> DOWN
%7|1714632174.902|BROADCAST|rdkafka#consumer-1| [thrd:GroupCoordinator]: Broadcasting state change
%7|1714632174.902|BUFQ|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Purging bufq with 0 buffers
%7|1714632174.902|BUFQ|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Purging bufq with 0 buffers
%7|1714632174.902|BUFQ|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Updating 0 buffers on connection reset
%7|1714632174.902|BRKTERM|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: terminating: broker still has 2 refcnt(s), 0 buffer(s), 0 partition(s)
%7|1714632174.902|TERMINATE|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Handle is terminating in state DOWN: 1 refcnts (0x150819de8), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf
%7|1714632174.902|FAIL|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Broker handle is terminating (after 0ms in state DOWN) (_DESTROY)
%7|1714632174.902|BUFQ|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Purging bufq with 0 buffers
%7|1714632174.902|BUFQ|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Purging bufq with 0 buffers
%7|1714632174.902|BUFQ|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Updating 0 buffers on connection reset
%7|1714632174.902|TERMINATE|rdkafka#consumer-1| [thrd:main]: Internal main thread termination done
%7|1714632174.902|TERMINATE|rdkafka#consumer-1| [thrd:app]: Destroying op queues
%7|1714632174.902|TERMINATE|rdkafka#consumer-1| [thrd:app]: Destroying cgrp
%7|1714632174.902|MEMBERID|rdkafka#consumer-1| [thrd:app]: Group "EventSinkGO4000041": updating member id "" -> "(not-set)"
%7|1714632174.902|TERMINATE|rdkafka#consumer-1| [thrd:app]: Termination done: freeing resources
2024-05-02 09:42:54.902 info    anzu_events_sink_go/main.go:515 Bye bye

@saartamir
Copy link
Author

Hi @milindl any news about it?

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Assignees
No one assigned
Labels
wait info
Projects
None yet
Milestone
No milestone
Development

No branches or pull requests
2 participants
@milindl @saartamir