offset reset (at offset 1111) to BEGINNING: fetch failed due to requested offset not available on the broker: Broker: Offset out of range

[Caratpine]

Description

Hi, master. I encountered an offset reset problem and reported this error, how can I solve it? thanks

How to reproduce

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

[Caratpine]

my config map

csm, err := kafka.NewConsumer(&kafka.ConfigMap{
        "bootstrap.servers":               strings.Join(c.URL, ","),
        "security.protocol":               "sasl_plaintext",
        "sasl.mechanism":                  "SCRAM-SHA-512",
        "sasl.username":                   c.Username,
        "sasl.password":                   c.Password,
        "group.id":                        c.Group,
        "go.application.rebalance.enable": true,
        "auto.offset.reset":               "earliest",
})

kafka offset low = high = 1123

[jliunyu]

Hi @Caratpine, thanks for asking. May I ask which version are you using? There is a fix related to this with v1.8.2, if you are not using v1.8.2, please upgrade. If you already use v1.8.2, can you please provide the debug logs, set debug : all to your config.

[shubhang93]

@jliunyu This still persists in v1.8.2. It hasn't been fixed. I even tried with latest as the value and we get the same error

[jliunyu]

Can you please add "debug" : "all" to your consumer config and provide the debug logs?

[shubhang93]

Before starting my consumer. This is the offset snapshot on my broker

Every 1.0s: ./kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group test_proxcon_0001                          Shubhang-Balkundi: Fri May  6 22:52:54 2022

clients_lib_dir: /Users/shubhangbalkundi/kafka_2.12-2.4.0/bin/../clients/build/libs

Consumer group 'test_proxcon_0001' has no active members.

GROUP             TOPIC           PARTITION  CURRENT-OFFSET  LOG-END-OFFSET  LAG             CONSUMER-ID     HOST            CLIENT-ID
test_proxcon_0001 plain-text-log  0          0               44              44              -               -               -
test_proxcon_0001 plain-text-log  2          0               61              61              -               -               -
test_proxcon_0001 plain-text-log  1          0               38              38              -               -               -

I expect my assigned offsets to be 44,61 and 38 respectively. To simulate an invalid offset I will set all my offsets to 2000 using the consumer.Assign

config := kafka.ConfigMap{
        "bootstrap.servers":        bootstrapServer,
        "debug":                    "all",
        "group.id":                 groupID,
        "enable.auto.commit":       true,
        "enable.auto.offset.store": false,
        "auto.commit.interval.ms":  5000,
        //"go.logs.channel.enable":   true,
        "session.timeout.ms":   10000,
        "auto.offset.reset":    "latest",
        "max.poll.interval.ms": 10000,
    }

Going to start the consumer now

switch rbcEvent := event.(type) {
        case kafka.AssignedPartitions:
            log.Printf("[%s]:Rebalance %s\n", consumer.String(), rbcEvent)
            var parts []kafka.TopicPartition
            for _, atp := range rbcEvent.Partitions {
                atp.Offset, _ = kafka.NewOffset(int64(2000)) // setting offsets to 2000 on purpose
                parts = append(parts, atp)
            }
            fmt.Println("ATP =============== ", parts)
            err := consumer.Assign(parts)
            if err != nil {
                panic(fmt.Sprintf("error resuming parts:%v", err))
            }
.........

Logs upon starting the consumer with debug all

%7|1651858165.901|MEMBERID|rdkafka#consumer-1| [thrd:app]: Group "test_proxcon_0001": updating member id "(not-set)" -> ""
%7|1651858165.901|WAKEUPFD|rdkafka#consumer-1| [thrd:app]: GroupCoordinator: Enabled low-latency ops queue wake-ups
%7|1651858165.901|BROKER|rdkafka#consumer-1| [thrd:app]: GroupCoordinator: Added new broker with NodeId -1
%7|1651858165.901|BRKMAIN|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Enter main broker thread
%7|1651858165.901|CGRPSTATE|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001" changed state init -> query-coord (join-state init)
%7|1651858165.901|BROADCAST|rdkafka#consumer-1| [thrd:main]: Broadcasting state change
%7|1651858165.901|BRKMAIN|rdkafka#consumer-1| [thrd::0/internal]: :0/internal: Enter main broker thread
%7|1651858165.901|WAKEUPFD|rdkafka#consumer-1| [thrd:app]: localhost:9092/bootstrap: Enabled low-latency ops queue wake-ups
%7|1651858165.901|BROKER|rdkafka#consumer-1| [thrd:app]: localhost:9092/bootstrap: Added new broker with NodeId -1
%7|1651858165.901|INIT|rdkafka#consumer-1| [thrd:app]: librdkafka v1.8.2 (0x10802ff) rdkafka#consumer-1 initialized (builtin.features gzip,snappy,ssl,sasl,regex,lz4,sasl_gssapi,sasl_plain,sasl_scram,plugins,zstd,sasl_oauthbearer, STRIP STATIC_LINKING CC GXX PKGCONFIG OSXLD LIBDL PLUGINS STATIC_LIB_zlib ZLIB STATIC_LIB_libcrypto STATIC_LIB_libssl SSL SASL_CYRUS STATIC_LIB_libzstd ZSTD HDRHISTOGRAM SYSLOG SNAPPY SOCKEM SASL_SCRAM SASL_OAUTHBEARER CRC32C_HW, debug 0xfffff)
%7|1651858165.901|BRKMAIN|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enter main broker thread
%7|1651858165.901|CONNECT|rdkafka#consumer-1| [thrd:main]: localhost:9092/bootstrap: Selected for cluster connection: coordinator query (broker has 0 connection attempt(s))
%7|1651858165.901|CONF|rdkafka#consumer-1| [thrd:app]: Client configuration:
%7|1651858165.901|CONF|rdkafka#consumer-1| [thrd:app]:   client.software.name = confluent-kafka-go
%7|1651858165.901|CONF|rdkafka#consumer-1| [thrd:app]:   client.software.version = 1.8.2
%7|1651858165.901|CONF|rdkafka#consumer-1| [thrd:app]:   metadata.broker.list = localhost:9092
%7|1651858165.901|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|1651858165.901|CONF|rdkafka#consumer-1| [thrd:app]:   enabled_events = 376
%7|1651858165.901|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001": no broker available for coordinator query: intervaled in state query-coord
%7|1651858165.901|CONF|rdkafka#consumer-1| [thrd:app]:   default_topic_conf = 0x5305d60
%7|1651858165.901|CONF|rdkafka#consumer-1| [thrd:app]:   ssl.ca.location = probe
%7|1651858165.901|CONF|rdkafka#consumer-1| [thrd:app]:   group.id = test_proxcon_0001
%7|1651858165.901|CONF|rdkafka#consumer-1| [thrd:app]:   session.timeout.ms = 10000
%7|1651858165.901|CONF|rdkafka#consumer-1| [thrd:app]:   max.poll.interval.ms = 10000
%7|1651858165.901|CONF|rdkafka#consumer-1| [thrd:app]:   enable.auto.commit = true
%7|1651858165.901|CONF|rdkafka#consumer-1| [thrd:app]:   auto.commit.interval.ms = 5000
%7|1651858165.901|CONF|rdkafka#consumer-1| [thrd:app]:   enable.auto.offset.store = false
%7|1651858165.901|CONF|rdkafka#consumer-1| [thrd:app]: Default topic configuration:
%7|1651858165.901|CONF|rdkafka#consumer-1| [thrd:app]:   auto.offset.reset = largest
%7|1651858165.901|CONNECT|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received CONNECT op
%7|1651858165.901|STATE|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state INIT -> TRY_CONNECT
%7|1651858165.901|BROADCAST|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
%7|1651858165.901|CONNECT|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: broker in state TRY_CONNECT connecting
%7|1651858165.901|STATE|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state TRY_CONNECT -> CONNECT
%7|1651858165.901|BROADCAST|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
%7|1651858165.902|CONNECT|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connecting to ipv6#[::1]:9092 (plaintext) with socket 18
%7|1651858165.902|CONNECT|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connected to ipv6#[::1]:9092
%7|1651858165.902|CONNECTED|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connected (#1)
%7|1651858165.902|FEATURE|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Updated enabled protocol features +ApiVersion to ApiVersion
%7|1651858165.902|STATE|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state CONNECT -> APIVERSION_QUERY
%7|1651858165.902|BROADCAST|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
%7|1651858165.902|SEND|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Sent ApiVersionRequest (v3, 48 bytes @ 0, CorrId 1)
2022/05/06 22:59:25 setting processing delay to 5000 millis
%7|1651858165.903|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001" received op SUBSCRIBE in state query-coord (join-state init)
%7|1651858165.903|SUBSCRIBE|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001": subscribe to new subscription of 1 topics (join-state init)
%7|1651858165.903|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 48ms: coordinator query
%7|1651858165.903|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001": no broker available for coordinator query: intervaled in state query-coord
%7|1651858165.905|RECV|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received ApiVersionResponse (v3, 410 bytes, CorrId 1, rtt 2.77ms)
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker API support:
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey Produce (0) Versions 0..9
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey Fetch (1) Versions 0..12
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey ListOffsets (2) Versions 0..6
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey Metadata (3) Versions 0..11
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey LeaderAndIsr (4) Versions 0..5
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey StopReplica (5) Versions 0..3
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey UpdateMetadata (6) Versions 0..7
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey ControlledShutdown (7) Versions 0..3
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey OffsetCommit (8) Versions 0..8
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey OffsetFetch (9) Versions 0..7
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey FindCoordinator (10) Versions 0..3
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey JoinGroup (11) Versions 0..7
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey Heartbeat (12) Versions 0..4
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey LeaveGroup (13) Versions 0..4
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey SyncGroup (14) Versions 0..5
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey DescribeGroups (15) Versions 0..5
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey ListGroups (16) Versions 0..4
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey SaslHandshake (17) Versions 0..1
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey ApiVersion (18) Versions 0..3
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey CreateTopics (19) Versions 0..7
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey DeleteTopics (20) Versions 0..6
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey DeleteRecords (21) Versions 0..2
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey InitProducerId (22) Versions 0..4
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey OffsetForLeaderEpoch (23) Versions 0..4
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey AddPartitionsToTxn (24) Versions 0..3
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey AddOffsetsToTxn (25) Versions 0..3
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey EndTxn (26) Versions 0..3
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey WriteTxnMarkers (27) Versions 0..1
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey TxnOffsetCommit (28) Versions 0..3
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey DescribeAcls (29) Versions 0..2
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey CreateAcls (30) Versions 0..2
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey DeleteAcls (31) Versions 0..2
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey DescribeConfigs (32) Versions 0..4
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey AlterConfigs (33) Versions 0..2
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey AlterReplicaLogDirs (34) Versions 0..2
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey DescribeLogDirs (35) Versions 0..2
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey SaslAuthenticate (36) Versions 0..2
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey CreatePartitions (37) Versions 0..3
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey CreateDelegationToken (38) Versions 0..2
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey RenewDelegationToken (39) Versions 0..2
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey ExpireDelegationToken (40) Versions 0..2
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey DescribeDelegationToken (41) Versions 0..2
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey DeleteGroups (42) Versions 0..2
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey ElectLeadersRequest (43) Versions 0..2
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey IncrementalAlterConfigsRequest (44) Versions 0..1
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey AlterPartitionReassignmentsRequest (45) Versions 0..0
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey ListPartitionReassignmentsRequest (46) Versions 0..0
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey OffsetDeleteRequest (47) Versions 0..0
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey DescribeClientQuotasRequest (48) Versions 0..1
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey AlterClientQuotasRequest (49) Versions 0..1
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey DescribeUserScramCredentialsRequest (50) Versions 0..0
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey AlterUserScramCredentialsRequest (51) Versions 0..0
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey AlterIsrRequest (56) Versions 0..0
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey UpdateFeaturesRequest (57) Versions 0..0
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey Unknown-60? (60) Versions 0..0
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey Unknown-61? (61) Versions 0..0
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature MsgVer1: Produce (2..2) supported by broker
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature MsgVer1: Fetch (2..2) supported by broker
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature MsgVer1
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature MsgVer2: Produce (3..3) supported by broker
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature MsgVer2: Fetch (4..4) supported by broker
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature MsgVer2
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature ApiVersion: ApiVersion (0..0) supported by broker
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature ApiVersion
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature BrokerGroupCoordinator: FindCoordinator (0..0) supported by broker
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature BrokerGroupCoordinator
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature BrokerBalancedConsumer: FindCoordinator (0..0) supported by broker
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature BrokerBalancedConsumer: OffsetCommit (1..2) supported by broker
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature BrokerBalancedConsumer: OffsetFetch (1..1) supported by broker
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature BrokerBalancedConsumer: JoinGroup (0..0) supported by broker
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature BrokerBalancedConsumer: SyncGroup (0..0) supported by broker
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature BrokerBalancedConsumer: Heartbeat (0..0) supported by broker
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature BrokerBalancedConsumer: LeaveGroup (0..0) supported by broker
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature BrokerBalancedConsumer
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature ThrottleTime: Produce (1..2) supported by broker
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature ThrottleTime: Fetch (1..2) supported by broker
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature ThrottleTime
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature Sasl: JoinGroup (0..0) supported by broker
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature Sasl
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature SaslHandshake: SaslHandshake (0..0) supported by broker
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature SaslHandshake
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature LZ4: FindCoordinator (0..0) supported by broker
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature LZ4
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature OffsetTime: ListOffsets (1..1) supported by broker
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature OffsetTime
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature IdempotentProducer: InitProducerId (0..0) supported by broker
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature IdempotentProducer
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature ZSTD: Produce (7..7) supported by broker
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature ZSTD: Fetch (10..10) supported by broker
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature ZSTD
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature SaslAuthReq: SaslHandshake (1..1) supported by broker
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature SaslAuthReq: SaslAuthenticate (0..0) supported by broker
%7|1651858165.905|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature SaslAuthReq
%7|1651858165.905|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|1651858165.905|STATE|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state APIVERSION_QUERY -> UP
%7|1651858165.905|BROADCAST|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
%7|1651858165.905|METADATA|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Request metadata for brokers only: connected
%7|1651858165.905|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: localhost:9092/bootstrap: Group "test_proxcon_0001": querying for coordinator: intervaled in state query-coord
%7|1651858165.905|SEND|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Sent MetadataRequest (v4, 26 bytes @ 0, CorrId 2)
%7|1651858165.905|CGRPSTATE|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001" changed state query-coord -> wait-coord (join-state init)
%7|1651858165.905|BROADCAST|rdkafka#consumer-1| [thrd:main]: Broadcasting state change
%7|1651858165.905|SEND|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Sent FindCoordinatorRequest (v2, 41 bytes @ 0, CorrId 3)
%7|1651858165.907|RECV|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received MetadataResponse (v4, 61 bytes, CorrId 2, rtt 2.02ms)
%7|1651858165.907|METADATA|rdkafka#consumer-1| [thrd:main]: localhost:9092/bootstrap: ===== Received metadata: connected =====
%7|1651858165.907|METADATA|rdkafka#consumer-1| [thrd:main]: localhost:9092/bootstrap: ClusterId: 2BG2-s6HTGqTZMfzAqbp0g, ControllerId: 1001
%7|1651858165.907|METADATA|rdkafka#consumer-1| [thrd:main]: localhost:9092/bootstrap: 1 brokers, 0 topics
%7|1651858165.907|METADATA|rdkafka#consumer-1| [thrd:main]: localhost:9092/bootstrap:   Broker #0/1: localhost:9092 NodeId 1001
%7|1651858165.907|UPDATE|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: NodeId changed from -1 to 1001
%7|1651858165.907|UPDATE|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Name changed from localhost:9092/bootstrap to localhost:9092/1001
%7|1651858165.907|LEADER|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Mapped 0 partition(s) to broker
%7|1651858165.907|STATE|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Broker changed state UP -> UPDATE
%7|1651858165.907|BROADCAST|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
%7|1651858165.907|BROADCAST|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
%7|1651858165.907|STATE|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Broker changed state UPDATE -> UP
%7|1651858165.907|BROADCAST|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
%7|1651858165.907|CLUSTERID|rdkafka#consumer-1| [thrd:main]: localhost:9092/1001: ClusterId update "" -> "2BG2-s6HTGqTZMfzAqbp0g"
%7|1651858165.907|CONTROLLERID|rdkafka#consumer-1| [thrd:main]: localhost:9092/1001: ControllerId update -1 -> 1001
%7|1651858165.907|BROADCAST|rdkafka#consumer-1| [thrd:main]: Broadcasting state change
%7|1651858165.908|RECV|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Received FindCoordinatorResponse (v2, 31 bytes, CorrId 3, rtt 2.67ms)
%7|1651858165.908|CGRPCOORD|rdkafka#consumer-1| [thrd:main]: localhost:9092/1001: Group "test_proxcon_0001" coordinator is localhost:9092 id 1001
%7|1651858165.908|CGRPCOORD|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001" changing coordinator -1 -> 1001
%7|1651858165.908|COORDSET|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001" coordinator set to broker localhost:9092/1001
%7|1651858165.908|CGRPSTATE|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001" changed state wait-coord -> wait-broker-transport (join-state init)
%7|1651858165.908|BROADCAST|rdkafka#consumer-1| [thrd:main]: Broadcasting state change
%7|1651858165.908|NODENAME|rdkafka#consumer-1| [thrd:main]: GroupCoordinator: Broker nodename changed from "" to "localhost:9092"
%7|1651858165.908|NODEID|rdkafka#consumer-1| [thrd:main]: GroupCoordinator: Broker nodeid changed from -1 to 1001
%7|1651858165.908|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: localhost:9092/1001: Group "test_proxcon_0001": querying for coordinator: intervaled in state wait-broker-transport
%7|1651858165.908|CONNECT|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Received CONNECT op
%7|1651858165.908|STATE|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Broker changed state INIT -> TRY_CONNECT
%7|1651858165.908|BROADCAST|rdkafka#consumer-1| [thrd:GroupCoordinator]: Broadcasting state change
%7|1651858165.908|CONNECT|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: broker in state TRY_CONNECT connecting
%7|1651858165.908|STATE|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Broker changed state TRY_CONNECT -> CONNECT
%7|1651858165.908|BROADCAST|rdkafka#consumer-1| [thrd:GroupCoordinator]: Broadcasting state change
%7|1651858165.908|SEND|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Sent FindCoordinatorRequest (v2, 41 bytes @ 0, CorrId 4)
%7|1651858165.908|CONNECT|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Connecting to ipv6#[::1]:9092 (plaintext) with socket 19
%7|1651858165.909|CONNECT|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Connected to ipv6#[::1]:9092
%7|1651858165.909|CONNECTED|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Connected (#1)
%7|1651858165.909|FEATURE|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Updated enabled protocol features +ApiVersion to ApiVersion
%7|1651858165.909|STATE|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Broker changed state CONNECT -> APIVERSION_QUERY
%7|1651858165.909|BROADCAST|rdkafka#consumer-1| [thrd:GroupCoordinator]: Broadcasting state change
%7|1651858165.909|SEND|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Sent ApiVersionRequest (v3, 48 bytes @ 0, CorrId 1)
%7|1651858165.910|RECV|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Received FindCoordinatorResponse (v2, 31 bytes, CorrId 4, rtt 2.27ms)
%7|1651858165.910|CGRPCOORD|rdkafka#consumer-1| [thrd:main]: localhost:9092/1001: Group "test_proxcon_0001" coordinator is localhost:9092 id 1001
%7|1651858165.911|RECV|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Received ApiVersionResponse (v3, 410 bytes, CorrId 1, rtt 2.79ms)
%7|1651858165.911|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Broker API support:
%7|1651858165.911|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey Produce (0) Versions 0..9
%7|1651858165.911|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey Fetch (1) Versions 0..12
%7|1651858165.911|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey ListOffsets (2) Versions 0..6
%7|1651858165.911|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey Metadata (3) Versions 0..11
%7|1651858165.911|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey LeaderAndIsr (4) Versions 0..5
%7|1651858165.911|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey StopReplica (5) Versions 0..3
%7|1651858165.911|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey UpdateMetadata (6) Versions 0..7
%7|1651858165.911|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey ControlledShutdown (7) Versions 0..3
%7|1651858165.911|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey OffsetCommit (8) Versions 0..8
%7|1651858165.911|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey OffsetFetch (9) Versions 0..7
%7|1651858165.911|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey FindCoordinator (10) Versions 0..3
%7|1651858165.911|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey JoinGroup (11) Versions 0..7
%7|1651858165.911|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey Heartbeat (12) Versions 0..4
%7|1651858165.911|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey LeaveGroup (13) Versions 0..4
%7|1651858165.911|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey SyncGroup (14) Versions 0..5
%7|1651858165.911|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey DescribeGroups (15) Versions 0..5
%7|1651858165.911|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey ListGroups (16) Versions 0..4
%7|1651858165.911|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey SaslHandshake (17) Versions 0..1
%7|1651858165.911|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey ApiVersion (18) Versions 0..3
%7|1651858165.911|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey CreateTopics (19) Versions 0..7
%7|1651858165.911|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey DeleteTopics (20) Versions 0..6
%7|1651858165.911|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey DeleteRecords (21) Versions 0..2
%7|1651858165.911|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey InitProducerId (22) Versions 0..4
%7|1651858165.911|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey OffsetForLeaderEpoch (23) Versions 0..4
%7|1651858165.911|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey AddPartitionsToTxn (24) Versions 0..3
%7|1651858165.911|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey AddOffsetsToTxn (25) Versions 0..3
%7|1651858165.911|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey EndTxn (26) Versions 0..3
%7|1651858165.912|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey WriteTxnMarkers (27) Versions 0..1
%7|1651858165.912|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey TxnOffsetCommit (28) Versions 0..3
%7|1651858165.912|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey DescribeAcls (29) Versions 0..2
%7|1651858165.912|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey CreateAcls (30) Versions 0..2
%7|1651858165.912|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey DeleteAcls (31) Versions 0..2
%7|1651858165.912|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey DescribeConfigs (32) Versions 0..4
%7|1651858165.912|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey AlterConfigs (33) Versions 0..2
%7|1651858165.912|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey AlterReplicaLogDirs (34) Versions 0..2
%7|1651858165.912|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey DescribeLogDirs (35) Versions 0..2
%7|1651858165.912|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey SaslAuthenticate (36) Versions 0..2
%7|1651858165.912|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey CreatePartitions (37) Versions 0..3
%7|1651858165.912|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey CreateDelegationToken (38) Versions 0..2
%7|1651858165.912|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey RenewDelegationToken (39) Versions 0..2
%7|1651858165.912|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey ExpireDelegationToken (40) Versions 0..2
%7|1651858165.912|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey DescribeDelegationToken (41) Versions 0..2
%7|1651858165.912|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey DeleteGroups (42) Versions 0..2
%7|1651858165.912|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey ElectLeadersRequest (43) Versions 0..2
%7|1651858165.912|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey IncrementalAlterConfigsRequest (44) Versions 0..1
%7|1651858165.912|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey AlterPartitionReassignmentsRequest (45) Versions 0..0
%7|1651858165.912|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey ListPartitionReassignmentsRequest (46) Versions 0..0
%7|1651858165.912|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey OffsetDeleteRequest (47) Versions 0..0
%7|1651858165.912|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey DescribeClientQuotasRequest (48) Versions 0..1
%7|1651858165.912|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey AlterClientQuotasRequest (49) Versions 0..1
%7|1651858165.912|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey DescribeUserScramCredentialsRequest (50) Versions 0..0
%7|1651858165.912|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey AlterUserScramCredentialsRequest (51) Versions 0..0
%7|1651858165.912|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey AlterIsrRequest (56) Versions 0..0
%7|1651858165.912|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey UpdateFeaturesRequest (57) Versions 0..0
%7|1651858165.912|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey Unknown-60? (60) Versions 0..0
%7|1651858165.912|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey Unknown-61? (61) Versions 0..0
%7|1651858165.912|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:  Feature MsgVer1: Produce (2..2) supported by broker
%7|1651858165.912|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:  Feature MsgVer1: Fetch (2..2) supported by broker
%7|1651858165.912|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Enabling feature MsgVer1
%7|1651858165.912|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:  Feature MsgVer2: Produce (3..3) supported by broker
%7|1651858165.912|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:  Feature MsgVer2: Fetch (4..4) supported by broker
%7|1651858165.912|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Enabling feature MsgVer2
%7|1651858165.912|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:  Feature ApiVersion: ApiVersion (0..0) supported by broker
%7|1651858165.912|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Enabling feature ApiVersion
%7|1651858165.912|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:  Feature BrokerGroupCoordinator: FindCoordinator (0..0) supported by broker
%7|1651858165.912|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Enabling feature BrokerGroupCoordinator
%7|1651858165.912|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:  Feature BrokerBalancedConsumer: FindCoordinator (0..0) supported by broker
%7|1651858165.912|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:  Feature BrokerBalancedConsumer: OffsetCommit (1..2) supported by broker
%7|1651858165.912|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:  Feature BrokerBalancedConsumer: OffsetFetch (1..1) supported by broker
%7|1651858165.912|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:  Feature BrokerBalancedConsumer: JoinGroup (0..0) supported by broker
%7|1651858165.912|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:  Feature BrokerBalancedConsumer: SyncGroup (0..0) supported by broker
%7|1651858165.912|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:  Feature BrokerBalancedConsumer: Heartbeat (0..0) supported by broker
%7|1651858165.912|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:  Feature BrokerBalancedConsumer: LeaveGroup (0..0) supported by broker
%7|1651858165.912|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Enabling feature BrokerBalancedConsumer
%7|1651858165.912|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:  Feature ThrottleTime: Produce (1..2) supported by broker
%7|1651858165.912|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:  Feature ThrottleTime: Fetch (1..2) supported by broker
%7|1651858165.912|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Enabling feature ThrottleTime
%7|1651858165.912|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:  Feature Sasl: JoinGroup (0..0) supported by broker
%7|1651858165.912|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Enabling feature Sasl
%7|1651858165.912|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:  Feature SaslHandshake: SaslHandshake (0..0) supported by broker
%7|1651858165.912|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Enabling feature SaslHandshake
%7|1651858165.912|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:  Feature LZ4: FindCoordinator (0..0) supported by broker
%7|1651858165.912|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Enabling feature LZ4
%7|1651858165.912|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:  Feature OffsetTime: ListOffsets (1..1) supported by broker
%7|1651858165.912|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Enabling feature OffsetTime
%7|1651858165.912|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:  Feature IdempotentProducer: InitProducerId (0..0) supported by broker
%7|1651858165.912|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Enabling feature IdempotentProducer
%7|1651858165.912|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:  Feature ZSTD: Produce (7..7) supported by broker
%7|1651858165.912|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:  Feature ZSTD: Fetch (10..10) supported by broker
%7|1651858165.912|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Enabling feature ZSTD
%7|1651858165.912|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:  Feature SaslAuthReq: SaslHandshake (1..1) supported by broker
%7|1651858165.912|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:  Feature SaslAuthReq: SaslAuthenticate (0..0) supported by broker
%7|1651858165.912|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Enabling feature SaslAuthReq
%7|1651858165.912|FEATURE|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Updated enabled protocol features to MsgVer1,ApiVersion,BrokerBalancedConsumer,ThrottleTime,Sasl,SaslHandshake,BrokerGroupCoordinator,LZ4,OffsetTime,MsgVer2,IdempotentProducer,ZSTD,SaslAuthReq
%7|1651858165.912|STATE|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Broker changed state APIVERSION_QUERY -> UP
%7|1651858165.912|BROADCAST|rdkafka#consumer-1| [thrd:GroupCoordinator]: Broadcasting state change
%7|1651858165.912|METADATA|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Request metadata for brokers only: connected
%7|1651858165.912|CGRPSTATE|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001" changed state wait-broker-transport -> up (join-state init)
%7|1651858165.912|BROADCAST|rdkafka#consumer-1| [thrd:main]: Broadcasting state change
%7|1651858165.912|JOIN|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001": join with 0 subscribed topic(s)
%7|1651858165.912|METADATA|rdkafka#consumer-1| [thrd:main]: Hinted cache of 1/1 topic(s) being queried
%7|1651858165.912|CGRPMETADATA|rdkafka#consumer-1| [thrd:main]: consumer join: metadata for subscription only available for 0/1 topics (-1ms old)
%7|1651858165.912|METADATA|rdkafka#consumer-1| [thrd:main]: localhost:9092/1001: Request metadata for 1 topic(s): consumer join
%7|1651858165.912|JOIN|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001": postponing join until up-to-date metadata is available
%7|1651858165.912|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001" changed join state init -> wait-metadata (state up)
%7|1651858165.912|DUMP|rdkafka#consumer-1| [thrd:main]: Assignment dump (started_cnt=0, wait_stop_cnt=0)
%7|1651858165.912|SEND|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Sent MetadataRequest (v4, 26 bytes @ 0, CorrId 2)
%7|1651858165.912|DUMP_ALL|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s):
%7|1651858165.912|DUMP_PND|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s):
%7|1651858165.912|DUMP_QRY|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s):
%7|1651858165.912|DUMP_REM|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s):
%7|1651858165.912|ASSIGNDONE|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001": assignment operations done in join-state wait-metadata (rebalance rejoin=false)
%7|1651858165.912|SEND|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Sent MetadataRequest (v4, 42 bytes @ 0, CorrId 5)
%7|1651858165.914|RECV|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Received MetadataResponse (v4, 162 bytes, CorrId 5, rtt 2.15ms)
%7|1651858165.914|RECV|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Received MetadataResponse (v4, 61 bytes, CorrId 2, rtt 2.19ms)
%7|1651858165.914|METADATA|rdkafka#consumer-1| [thrd:main]: localhost:9092/1001: ===== Received metadata (for 1 requested topics): consumer join =====
%7|1651858165.914|METADATA|rdkafka#consumer-1| [thrd:main]: localhost:9092/1001: ClusterId: 2BG2-s6HTGqTZMfzAqbp0g, ControllerId: 1001
%7|1651858165.914|METADATA|rdkafka#consumer-1| [thrd:main]: localhost:9092/1001: 1 brokers, 1 topics
%7|1651858165.914|METADATA|rdkafka#consumer-1| [thrd:main]: localhost:9092/1001:   Broker #0/1: localhost:9092 NodeId 1001
%7|1651858165.914|METADATA|rdkafka#consumer-1| [thrd:main]: localhost:9092/1001:   Topic #0/1: plain-text-log with 3 partitions
%7|1651858165.914|METADATA|rdkafka#consumer-1| [thrd:main]: localhost:9092/1001: 1/1 requested topic(s) seen in metadata
%7|1651858165.914|SUBSCRIPTION|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001": effective subscription list changed from 0 to 1 topic(s):
%7|1651858165.914|SUBSCRIPTION|rdkafka#consumer-1| [thrd:main]:  Topic plain-text-log with 3 partition(s)
%7|1651858165.914|REJOIN|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001": subscription updated from metadata change: rejoining group in state wait-metadata
%7|1651858165.914|GRPLEADER|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001": resetting group leader info: group (re)join
%7|1651858165.914|REJOIN|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001" (re)joining in join-state wait-metadata with 0 assigned partition(s): Metadata for subscribed topic(s) has changed
%7|1651858165.914|REBALANCE|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001" initiating rebalance (NONE) in state up (join-state wait-metadata) with 0 assigned partition(s): Metadata for subscribed topic(s) has changed
%7|1651858165.914|REJOIN|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001": Rejoining group without an assignment: Metadata for subscribed topic(s) has changed
%7|1651858165.914|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001" changed join state wait-metadata -> init (state up)
%7|1651858165.914|METADATA|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/1001: ===== Received metadata: connected =====
%7|1651858165.914|METADATA|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/1001: ClusterId: 2BG2-s6HTGqTZMfzAqbp0g, ControllerId: 1001
%7|1651858165.914|METADATA|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/1001: 1 brokers, 0 topics
%7|1651858165.914|METADATA|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/1001:   Broker #0/1: localhost:9092 NodeId 1001
%7|1651858165.914|JOIN|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001": join with 1 subscribed topic(s)
%7|1651858165.914|CGRPMETADATA|rdkafka#consumer-1| [thrd:main]: consumer join: metadata for subscription is up to date (0ms old)
%7|1651858165.914|JOIN|rdkafka#consumer-1| [thrd:main]: localhost:9092/1001: Joining group "test_proxcon_0001" with 1 subscribed topic(s) and member id ""
%7|1651858165.914|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001" changed join state init -> wait-join (state up)
%7|1651858165.914|SEND|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Sent JoinGroupRequest (v5, 153 bytes @ 0, CorrId 3)
%7|1651858165.914|BROADCAST|rdkafka#consumer-1| [thrd:GroupCoordinator]: Broadcasting state change
%7|1651858165.916|RECV|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Received JoinGroupResponse (v5, 64 bytes, CorrId 3, rtt 1.78ms)
%7|1651858165.916|JOINGROUP|rdkafka#consumer-1| [thrd:main]: JoinGroup response: GenerationId -1, Protocol , LeaderId , my MemberId rdkafka-b9a8234e-aeb3-487e-8472-d50ae1fa49f5, member metadata count 0: Broker: Group member needs a valid member ID
%7|1651858165.916|REQERR|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/1001: JoinGroupRequest failed: Broker: Group member needs a valid member ID: explicit actions Ignore
%7|1651858165.916|MEMBERID|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001": updating member id "" -> "rdkafka-b9a8234e-aeb3-487e-8472-d50ae1fa49f5"
%7|1651858165.916|REJOIN|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001": Rejoining group without an assignment: JoinGroup error: Broker: Group member needs a valid member ID
%7|1651858165.916|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001" changed join state wait-join -> init (state up)
%7|1651858165.916|JOIN|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001": join with 1 subscribed topic(s)
%7|1651858165.916|CGRPMETADATA|rdkafka#consumer-1| [thrd:main]: consumer join: metadata for subscription is up to date (1ms old)
%7|1651858165.916|JOIN|rdkafka#consumer-1| [thrd:main]: localhost:9092/1001: Joining group "test_proxcon_0001" with 1 subscribed topic(s) and member id "rdkafka-b9a8234e-aeb3-487e-8472-d50ae1fa49f5"
%7|1651858165.916|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001" changed join state init -> wait-join (state up)
%7|1651858165.916|SEND|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Sent JoinGroupRequest (v5, 197 bytes @ 0, CorrId 4)
%7|1651858165.916|BROADCAST|rdkafka#consumer-1| [thrd:GroupCoordinator]: Broadcasting state change
%7|1651858165.920|RECV|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Received JoinGroupResponse (v5, 195 bytes, CorrId 4, rtt 4.50ms)
%7|1651858165.921|JOINGROUP|rdkafka#consumer-1| [thrd:main]: JoinGroup response: GenerationId 23, Protocol range, LeaderId rdkafka-b9a8234e-aeb3-487e-8472-d50ae1fa49f5 (me), my MemberId rdkafka-b9a8234e-aeb3-487e-8472-d50ae1fa49f5, member metadata count 1: (no error)
%7|1651858165.921|JOINGROUP|rdkafka#consumer-1| [thrd:main]: I am elected leader for group "test_proxcon_0001" with 1 member(s)
%7|1651858165.921|GRPLEADER|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001": resetting group leader info: JoinGroup response clean-up
%7|1651858165.921|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001" changed join state wait-join -> wait-metadata (state up)
%7|1651858165.921|METADATA|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/1001: Request metadata for 1 topic(s): partition assignor
%7|1651858165.921|SEND|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Sent MetadataRequest (v4, 42 bytes @ 0, CorrId 5)
%7|1651858165.922|RECV|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Received MetadataResponse (v4, 162 bytes, CorrId 5, rtt 1.65ms)
%7|1651858165.922|METADATA|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/1001: ===== Received metadata (for 1 requested topics): partition assignor =====
%7|1651858165.922|METADATA|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/1001: ClusterId: 2BG2-s6HTGqTZMfzAqbp0g, ControllerId: 1001
%7|1651858165.922|METADATA|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/1001: 1 brokers, 1 topics
%7|1651858165.922|METADATA|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/1001:   Broker #0/1: localhost:9092 NodeId 1001
%7|1651858165.922|METADATA|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/1001:   Topic #0/1: plain-text-log with 3 partitions
%7|1651858165.922|METADATA|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/1001: 1/1 requested topic(s) seen in metadata
%7|1651858165.922|ASSIGN|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001" running range assignor for 1 member(s) and 1 eligible subscribed topic(s):
%7|1651858165.922|ASSIGN|rdkafka#consumer-1| [thrd:main]:  Member "rdkafka-b9a8234e-aeb3-487e-8472-d50ae1fa49f5" (me) with 0 owned partition(s) and 1 subscribed topic(s):
%7|1651858165.922|ASSIGN|rdkafka#consumer-1| [thrd:main]:   plain-text-log [-1]
%7|1651858165.922|ASSIGN|rdkafka#consumer-1| [thrd:main]: range: Topic plain-text-log with 3 partition(s) and 1 subscribing member(s)
%7|1651858165.922|ASSIGN|rdkafka#consumer-1| [thrd:main]: range: Member "rdkafka-b9a8234e-aeb3-487e-8472-d50ae1fa49f5": assigned topic plain-text-log partitions 0..2
%7|1651858165.922|ASSIGN|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001" range assignment for 1 member(s) finished in 0.015ms:
%7|1651858165.922|ASSIGN|rdkafka#consumer-1| [thrd:main]:  Member "rdkafka-b9a8234e-aeb3-487e-8472-d50ae1fa49f5" (me) assigned 3 partition(s):
%7|1651858165.922|ASSIGN|rdkafka#consumer-1| [thrd:main]:   plain-text-log [0]
%7|1651858165.922|ASSIGN|rdkafka#consumer-1| [thrd:main]:   plain-text-log [1]
%7|1651858165.922|ASSIGN|rdkafka#consumer-1| [thrd:main]:   plain-text-log [2]
%7|1651858165.922|ASSIGNOR|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001": "range" assignor run for 1 member(s)
%7|1651858165.922|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001" changed join state wait-metadata -> wait-sync (state up)
%7|1651858165.922|SEND|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Sent SyncGroupRequest (v3, 188 bytes @ 0, CorrId 6)
%7|1651858165.922|BROADCAST|rdkafka#consumer-1| [thrd:GroupCoordinator]: Broadcasting state change
%7|1651858165.927|RECV|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Received SyncGroupResponse (v3, 52 bytes, CorrId 6, rtt 4.60ms)
%7|1651858165.927|SYNCGROUP|rdkafka#consumer-1| [thrd:main]: SyncGroup response: Success (42 bytes of MemberState data)
%7|1651858165.927|ASSIGNMENT|rdkafka#consumer-1| [thrd:main]: List with 3 partition(s):
%7|1651858165.927|ASSIGNMENT|rdkafka#consumer-1| [thrd:main]:  plain-text-log [0] offset INVALID
%7|1651858165.927|ASSIGNMENT|rdkafka#consumer-1| [thrd:main]:  plain-text-log [1] offset INVALID
%7|1651858165.927|ASSIGNMENT|rdkafka#consumer-1| [thrd:main]:  plain-text-log [2] offset INVALID
%7|1651858165.927|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001" changed join state wait-sync -> wait-assign-call (state up)
%7|1651858165.927|ASSIGN|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001": delegating assign of 3 partition(s) to application on queue rd_kafka_cgrp_new: new assignment
%7|1651858165.927|ASSIGNMENT|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001": setting group assignment to 3 partition(s)
%7|1651858165.927|GRPASSIGNMENT|rdkafka#consumer-1| [thrd:main]: List with 3 partition(s):
%7|1651858165.927|GRPASSIGNMENT|rdkafka#consumer-1| [thrd:main]:  plain-text-log [0] offset INVALID
%7|1651858165.927|GRPASSIGNMENT|rdkafka#consumer-1| [thrd:main]:  plain-text-log [1] offset INVALID
%7|1651858165.927|GRPASSIGNMENT|rdkafka#consumer-1| [thrd:main]:  plain-text-log [2] offset INVALID
%7|1651858165.927|HEARTBEAT|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/1001: Heartbeat for group "test_proxcon_0001" generation id 23
%7|1651858165.927|SEND|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Sent HeartbeatRequest (v3, 92 bytes @ 0, CorrId 7)
2022/05/06 22:59:25 [rdkafka#consumer-1]:Rebalance AssignedPartitions: [plain-text-log[0]@unset plain-text-log[1]@unset plain-text-log[2]@unset]
ATP ===============  [plain-text-log[0]@2000 plain-text-log[1]@2000 plain-text-log[2]@2000]
%7|1651858165.927|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001" received op ASSIGN in state up (join-state wait-assign-call)
%7|1651858165.927|ASSIGN|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001": new assignment of 3 partition(s) in join-state wait-assign-call
%7|1651858165.928|CLEARASSIGN|rdkafka#consumer-1| [thrd:main]: No current assignment to clear
%7|1651858165.928|TOPIC|rdkafka#consumer-1| [thrd:main]: New local topic: plain-text-log
%7|1651858165.928|TOPPARNEW|rdkafka#consumer-1| [thrd:main]: NEW plain-text-log [-1] 0x900ac40 refcnt 0x900acd0 (at rd_kafka_topic_new0:465)
%7|1651858165.928|STATE|rdkafka#consumer-1| [thrd:main]: Topic plain-text-log changed state unknown -> exists
%7|1651858165.928|PARTCNT|rdkafka#consumer-1| [thrd:main]: Topic plain-text-log partition count changed from 0 to 3
%7|1651858165.928|TOPPARNEW|rdkafka#consumer-1| [thrd:main]: NEW plain-text-log [0] 0x900b100 refcnt 0x900b190 (at rd_kafka_topic_partition_cnt_update:798)
%7|1651858165.928|TOPPARNEW|rdkafka#consumer-1| [thrd:main]: NEW plain-text-log [1] 0x900b690 refcnt 0x900b720 (at rd_kafka_topic_partition_cnt_update:798)
%7|1651858165.928|TOPPARNEW|rdkafka#consumer-1| [thrd:main]: NEW plain-text-log [2] 0x900bc20 refcnt 0x900bcb0 (at rd_kafka_topic_partition_cnt_update:798)
%7|1651858165.928|METADATA|rdkafka#consumer-1| [thrd:main]:   Topic plain-text-log partition 0 Leader 1001
%7|1651858165.928|BRKDELGT|rdkafka#consumer-1| [thrd:main]: plain-text-log [0]: delegate to broker localhost:9092/1001 (rktp 0x900b100, term 0, ref 2)
%7|1651858165.928|BRKDELGT|rdkafka#consumer-1| [thrd:main]: plain-text-log [0]: delegating to broker localhost:9092/1001 for partition with 0 messages (0 bytes) queued
%7|1651858165.928|BRKMIGR|rdkafka#consumer-1| [thrd:main]: Migrating topic plain-text-log [0] 0x900b100 from (none) to localhost:9092/1001 (sending PARTITION_JOIN to localhost:9092/1001)
%7|1651858165.928|METADATA|rdkafka#consumer-1| [thrd:main]:   Topic plain-text-log partition 1 Leader 1001
%7|1651858165.928|BRKDELGT|rdkafka#consumer-1| [thrd:main]: plain-text-log [1]: delegate to broker localhost:9092/1001 (rktp 0x900b690, term 0, ref 2)
%7|1651858165.928|BRKDELGT|rdkafka#consumer-1| [thrd:main]: plain-text-log [1]: delegating to broker localhost:9092/1001 for partition with 0 messages (0 bytes) queued
%7|1651858165.928|BRKMIGR|rdkafka#consumer-1| [thrd:main]: Migrating topic plain-text-log [1] 0x900b690 from (none) to localhost:9092/1001 (sending PARTITION_JOIN to localhost:9092/1001)
%7|1651858165.928|METADATA|rdkafka#consumer-1| [thrd:main]:   Topic plain-text-log partition 2 Leader 1001
%7|1651858165.928|BRKDELGT|rdkafka#consumer-1| [thrd:main]: plain-text-log [2]: delegate to broker localhost:9092/1001 (rktp 0x900bc20, term 0, ref 2)
%7|1651858165.928|BRKDELGT|rdkafka#consumer-1| [thrd:main]: plain-text-log [2]: delegating to broker localhost:9092/1001 for partition with 0 messages (0 bytes) queued
%7|1651858165.928|BRKMIGR|rdkafka#consumer-1| [thrd:main]: Migrating topic plain-text-log [2] 0x900bc20 from (none) to localhost:9092/1001 (sending PARTITION_JOIN to localhost:9092/1001)
%7|1651858165.928|TOPBRK|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [0]: joining broker (rktp 0x900b100, 0 message(s) queued)
%7|1651858165.928|CONF|rdkafka#consumer-1| [thrd:main]: Topic "plain-text-log" configuration (default_topic_conf):
%7|1651858165.928|CONF|rdkafka#consumer-1| [thrd:main]:   auto.offset.reset = largest
%7|1651858165.928|BROADCAST|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
%7|1651858165.928|TOPBRK|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [1]: joining broker (rktp 0x900b690, 0 message(s) queued)
%7|1651858165.928|BROADCAST|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
%7|1651858165.928|TOPBRK|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [2]: joining broker (rktp 0x900bc20, 0 message(s) queued)
%7|1651858165.928|BROADCAST|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
%7|1651858165.928|DESIRED|rdkafka#consumer-1| [thrd:main]: plain-text-log [0]: marking as DESIRED
%7|1651858165.928|DESIRED|rdkafka#consumer-1| [thrd:main]: plain-text-log [1]: marking as DESIRED
%7|1651858165.928|DESIRED|rdkafka#consumer-1| [thrd:main]: plain-text-log [2]: marking as DESIRED
%7|1651858165.928|ASSIGNMENT|rdkafka#consumer-1| [thrd:main]: Added 3 partition(s) to assignment which now consists of 3 partition(s) where of 3 are in pending state and 0 are being queried
%7|1651858165.928|PAUSE|rdkafka#consumer-1| [thrd:main]: Resuming fetchers for 3 assigned partition(s): assign called
%7|1651858165.928|RESUME|rdkafka#consumer-1| [thrd:main]: Library resuming 3 partition(s)
%7|1651858165.928|BARRIER|rdkafka#consumer-1| [thrd:main]: plain-text-log [0]: rd_kafka_toppar_op_pause_resume:2449: new version barrier v2
%7|1651858165.928|RESUME|rdkafka#consumer-1| [thrd:main]: Resume plain-text-log [0] (v2)
%7|1651858165.928|BARRIER|rdkafka#consumer-1| [thrd:main]: plain-text-log [1]: rd_kafka_toppar_op_pause_resume:2449: new version barrier v2
%7|1651858165.928|RESUME|rdkafka#consumer-1| [thrd:main]: Resume plain-text-log [1] (v2)
%7|1651858165.928|BARRIER|rdkafka#consumer-1| [thrd:main]: plain-text-log [2]: rd_kafka_toppar_op_pause_resume:2449: new version barrier v2
%7|1651858165.928|RESUME|rdkafka#consumer-1| [thrd:main]: Resume plain-text-log [2] (v2)
%7|1651858165.928|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001" changed join state wait-assign-call -> steady (state up)
%7|1651858165.928|DUMP|rdkafka#consumer-1| [thrd:main]: Assignment dump (started_cnt=0, wait_stop_cnt=0)
%7|1651858165.928|DUMP_ALL|rdkafka#consumer-1| [thrd:main]: List with 3 partition(s):
%7|1651858165.928|DUMP_ALL|rdkafka#consumer-1| [thrd:main]:  plain-text-log [0] offset 2000
%7|1651858165.928|DUMP_ALL|rdkafka#consumer-1| [thrd:main]:  plain-text-log [1] offset 2000
%7|1651858165.928|DUMP_ALL|rdkafka#consumer-1| [thrd:main]:  plain-text-log [2] offset 2000
%7|1651858165.928|DUMP_PND|rdkafka#consumer-1| [thrd:main]: List with 3 partition(s):
%7|1651858165.928|DUMP_PND|rdkafka#consumer-1| [thrd:main]:  plain-text-log [0] offset 2000
%7|1651858165.928|DUMP_PND|rdkafka#consumer-1| [thrd:main]:  plain-text-log [1] offset 2000
%7|1651858165.928|DUMP_PND|rdkafka#consumer-1| [thrd:main]:  plain-text-log [2] offset 2000
%7|1651858165.928|DUMP_QRY|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s):
%7|1651858165.928|DUMP_REM|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s):
%7|1651858165.928|SRVPEND|rdkafka#consumer-1| [thrd:main]: Starting pending assigned partition plain-text-log [2] at offset 2000
%7|1651858165.928|BARRIER|rdkafka#consumer-1| [thrd:main]: plain-text-log [2]: rd_kafka_toppar_op_pause_resume:2449: new version barrier v3
%7|1651858165.928|RESUME|rdkafka#consumer-1| [thrd:main]: Resume plain-text-log [2] (v3)
%7|1651858165.928|BARRIER|rdkafka#consumer-1| [thrd:main]: plain-text-log [2]: rd_kafka_toppar_op_fetch_start:2363: new version barrier v4
%7|1651858165.928|CONSUMER|rdkafka#consumer-1| [thrd:main]: Start consuming plain-text-log [2] at offset 2000 (v4)
%7|1651858165.928|SRVPEND|rdkafka#consumer-1| [thrd:main]: Starting pending assigned partition plain-text-log [1] at offset 2000
%7|1651858165.928|BARRIER|rdkafka#consumer-1| [thrd:main]: plain-text-log [1]: rd_kafka_toppar_op_pause_resume:2449: new version barrier v3
%7|1651858165.928|RESUME|rdkafka#consumer-1| [thrd:main]: Resume plain-text-log [1] (v3)
%7|1651858165.928|BARRIER|rdkafka#consumer-1| [thrd:main]: plain-text-log [1]: rd_kafka_toppar_op_fetch_start:2363: new version barrier v4
%7|1651858165.928|CONSUMER|rdkafka#consumer-1| [thrd:main]: Start consuming plain-text-log [1] at offset 2000 (v4)
%7|1651858165.928|SRVPEND|rdkafka#consumer-1| [thrd:main]: Starting pending assigned partition plain-text-log [0] at offset 2000
%7|1651858165.928|BARRIER|rdkafka#consumer-1| [thrd:main]: plain-text-log [0]: rd_kafka_toppar_op_pause_resume:2449: new version barrier v3
%7|1651858165.928|RESUME|rdkafka#consumer-1| [thrd:main]: Resume plain-text-log [0] (v3)
%7|1651858165.928|BARRIER|rdkafka#consumer-1| [thrd:main]: plain-text-log [0]: rd_kafka_toppar_op_fetch_start:2363: new version barrier v4
%7|1651858165.928|CONSUMER|rdkafka#consumer-1| [thrd:main]: Start consuming plain-text-log [0] at offset 2000 (v4)
%7|1651858165.928|ASSIGNDONE|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001": assignment operations done in join-state steady (rebalance rejoin=false)
%7|1651858165.928|OP|rdkafka#consumer-1| [thrd:main]: plain-text-log [0] received op PAUSE (v2) in fetch-state none (opv1)
%7|1651858165.928|RESUME|rdkafka#consumer-1| [thrd:main]: Not resuming plain-text-log [0]: partition is not paused by library
%7|1651858165.928|OP|rdkafka#consumer-1| [thrd:main]: plain-text-log [1] received op PAUSE (v2) in fetch-state none (opv1)
%7|1651858165.928|RESUME|rdkafka#consumer-1| [thrd:main]: Not resuming plain-text-log [1]: partition is not paused by library
%7|1651858165.928|OP|rdkafka#consumer-1| [thrd:main]: plain-text-log [2] received op PAUSE (v2) in fetch-state none (opv1)
%7|1651858165.928|RESUME|rdkafka#consumer-1| [thrd:main]: Not resuming plain-text-log [2]: partition is not paused by library
%7|1651858165.928|OP|rdkafka#consumer-1| [thrd:main]: plain-text-log [2] received op PAUSE (v3) in fetch-state none (opv2)
%7|1651858165.928|RESUME|rdkafka#consumer-1| [thrd:main]: Not resuming plain-text-log [2]: partition is not paused by library
%7|1651858165.928|OP|rdkafka#consumer-1| [thrd:main]: plain-text-log [2] received op FETCH_START (v4) in fetch-state none (opv3)
%7|1651858165.928|FETCH|rdkafka#consumer-1| [thrd:main]: Start fetch for plain-text-log [2] in state none at offset 2000 (v4)
%7|1651858165.928|PARTSTATE|rdkafka#consumer-1| [thrd:main]: Partition plain-text-log [2] changed fetch state none -> active
%7|1651858165.928|FETCH|rdkafka#consumer-1| [thrd:main]: Partition plain-text-log [2] start fetching at offset 2000
%7|1651858165.928|WAKEUP|rdkafka#consumer-1| [thrd:main]: localhost:9092/1001: Wake-up
%7|1651858165.928|OP|rdkafka#consumer-1| [thrd:main]: plain-text-log [1] received op PAUSE (v3) in fetch-state none (opv2)
%7|1651858165.928|RESUME|rdkafka#consumer-1| [thrd:main]: Not resuming plain-text-log [1]: partition is not paused by library
%7|1651858165.928|OP|rdkafka#consumer-1| [thrd:main]: plain-text-log [1] received op FETCH_START (v4) in fetch-state none (opv3)
%7|1651858165.928|FETCH|rdkafka#consumer-1| [thrd:main]: Start fetch for plain-text-log [1] in state none at offset 2000 (v4)
%7|1651858165.928|PARTSTATE|rdkafka#consumer-1| [thrd:main]: Partition plain-text-log [1] changed fetch state none -> active
%7|1651858165.928|FETCH|rdkafka#consumer-1| [thrd:main]: Partition plain-text-log [1] start fetching at offset 2000
%7|1651858165.928|WAKEUP|rdkafka#consumer-1| [thrd:main]: localhost:9092/1001: Wake-up
%7|1651858165.928|OP|rdkafka#consumer-1| [thrd:main]: plain-text-log [0] received op PAUSE (v3) in fetch-state none (opv2)
%7|1651858165.928|FETCHDEC|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: Topic plain-text-log [1]: fetch decide: updating to version 4 (was 0) at offset 2000 (was 0)
%7|1651858165.928|RESUME|rdkafka#consumer-1| [thrd:main]: Not resuming plain-text-log [0]: partition is not paused by library
%7|1651858165.928|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [1] in state active at offset 2000 (0/100000 msgs, 0/65536 kb queued, opv 4) is fetchable
%7|1651858165.928|FETCHADD|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Added plain-text-log [1] to fetch list (1 entries, opv 4, 0 messages queued): fetchable
%7|1651858165.928|OP|rdkafka#consumer-1| [thrd:main]: plain-text-log [0] received op FETCH_START (v4) in fetch-state none (opv3)
%7|1651858165.928|FETCHDEC|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: Topic plain-text-log [2]: fetch decide: updating to version 4 (was 0) at offset 2000 (was 0)
%7|1651858165.928|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [2] in state active at offset 2000 (0/100000 msgs, 0/65536 kb queued, opv 4) is fetchable
%7|1651858165.928|FETCHADD|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Added plain-text-log [2] to fetch list (2 entries, opv 4, 0 messages queued): fetchable
%7|1651858165.928|FETCH|rdkafka#consumer-1| [thrd:main]: Start fetch for plain-text-log [0] in state none at offset 2000 (v4)
%7|1651858165.928|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [1] at offset 2000 (v4)
%7|1651858165.928|PARTSTATE|rdkafka#consumer-1| [thrd:main]: Partition plain-text-log [0] changed fetch state none -> active
%7|1651858165.928|FETCH|rdkafka#consumer-1| [thrd:main]: Partition plain-text-log [0] start fetching at offset 2000
%7|1651858165.928|WAKEUP|rdkafka#consumer-1| [thrd:main]: localhost:9092/1001: Wake-up
%7|1651858165.928|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001" received op PARTITION_JOIN in state up (join-state steady) for plain-text-log [2]
%7|1651858165.928|PARTADD|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001": add plain-text-log [2]
%7|1651858165.928|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001" received op PARTITION_JOIN in state up (join-state steady) for plain-text-log [1]
%7|1651858165.928|PARTADD|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001": add plain-text-log [1]
%7|1651858165.928|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [2] at offset 2000 (v4)
%7|1651858165.928|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch 2/2/3 toppar(s)
%7|1651858165.928|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001" received op PARTITION_JOIN in state up (join-state steady) for plain-text-log [0]
%7|1651858165.928|PARTADD|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001": add plain-text-log [0]
%7|1651858165.928|SEND|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Sent FetchRequest (v11, 132 bytes @ 0, CorrId 6)
%7|1651858165.928|FETCHDEC|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: Topic plain-text-log [0]: fetch decide: updating to version 4 (was 0) at offset 2000 (was 0)
%7|1651858165.928|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [0] in state active at offset 2000 (0/100000 msgs, 0/65536 kb queued, opv 4) is fetchable
%7|1651858165.928|FETCHADD|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Added plain-text-log [0] to fetch list (3 entries, opv 4, 0 messages queued): fetchable
%7|1651858165.930|RECV|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Received HeartbeatResponse (v3, 6 bytes, CorrId 7, rtt 2.51ms)
%7|1651858165.930|RECV|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Received FetchResponse (v11, 118 bytes, CorrId 6, rtt 1.87ms)
%7|1651858165.930|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [1] MessageSet size 0, error "Broker: Offset out of range", MaxOffset -1, LSO -1, Ver 4/4
%7|1651858165.930|BACKOFF|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: plain-text-log [1]: Fetch backoff for 500ms: Broker: Offset out of range
%7|1651858165.930|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [2] MessageSet size 0, error "Broker: Offset out of range", MaxOffset -1, LSO -1, Ver 4/4
%7|1651858165.930|PARTSTATE|rdkafka#consumer-1| [thrd:main]: Partition plain-text-log [1] changed fetch state active -> offset-query
%7|1651858165.930|BACKOFF|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: plain-text-log [2]: Fetch backoff for 500ms: Broker: Offset out of range
%4|1651858165.930|OFFSET|rdkafka#consumer-1| [thrd:main]: plain-text-log [1]: offset reset (at offset 2000) to END: fetch failed due to requested offset not available on the broker: Broker: Offset out of range
%7|1651858165.930|OFFSET|rdkafka#consumer-1| [thrd:main]: plain-text-log [1]: backoff: (re)starting offset query timer for offset END
%7|1651858165.930|PARTSTATE|rdkafka#consumer-1| [thrd:main]: Partition plain-text-log [2] changed fetch state active -> offset-query
%4|1651858165.930|OFFSET|rdkafka#consumer-1| [thrd:main]: plain-text-log [2]: offset reset (at offset 2000) to END: fetch failed due to requested offset not available on the broker: Broker: Offset out of range
%7|1651858165.930|OFFSET|rdkafka#consumer-1| [thrd:main]: plain-text-log [2]: backoff: (re)starting offset query timer for offset END
%7|1651858165.930|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [1] in state offset-query at offset 2000 (0/100000 msgs, 0/65536 kb queued, opv 4) is not fetchable: not in active fetch state
%7|1651858165.930|FETCHADD|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Removed plain-text-log [1] from fetch list (2 entries, opv 4): not in active fetch state
%7|1651858165.930|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [2] in state offset-query at offset 2000 (0/100000 msgs, 0/65536 kb queued, opv 4) is not fetchable: not in active fetch state
%7|1651858165.930|FETCHADD|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Removed plain-text-log [2] from fetch list (1 entries, opv 4): not in active fetch state
%7|1651858165.930|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [0] at offset 2000 (v4)
%7|1651858165.930|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch 1/1/3 toppar(s)
%7|1651858165.930|SEND|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Sent FetchRequest (v11, 104 bytes @ 0, CorrId 7)
%7|1651858165.932|RECV|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Received FetchResponse (v11, 76 bytes, CorrId 7, rtt 1.60ms)
%7|1651858165.932|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [0] MessageSet size 0, error "Broker: Offset out of range", MaxOffset -1, LSO -1, Ver 4/4
%7|1651858165.932|BACKOFF|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: plain-text-log [0]: Fetch backoff for 500ms: Broker: Offset out of range
%7|1651858165.932|PARTSTATE|rdkafka#consumer-1| [thrd:main]: Partition plain-text-log [0] changed fetch state active -> offset-query
%4|1651858165.932|OFFSET|rdkafka#consumer-1| [thrd:main]: plain-text-log [0]: offset reset (at offset 2000) to END: fetch failed due to requested offset not available on the broker: Broker: Offset out of range
%7|1651858165.932|OFFSET|rdkafka#consumer-1| [thrd:main]: plain-text-log [0]: backoff: (re)starting offset query timer for offset END
%7|1651858165.932|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [0] in state offset-query at offset 2000 (0/100000 msgs, 0/65536 kb queued, opv 4) is not fetchable: not in active fetch state
%7|1651858165.932|FETCHADD|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Removed plain-text-log [0] from fetch list (0 entries, opv 4): not in active fetch state
%7|1651858166.034|OFFSET|rdkafka#consumer-1| [thrd:main]: Topic plain-text-log [1]: timed offset query for END in state offset-query
%7|1651858166.034|OFFREQ|rdkafka#consumer-1| [thrd:main]: localhost:9092/1001: Partition plain-text-log [1]: querying for logical offset END (opv 4)
%7|1651858166.034|PARTSTATE|rdkafka#consumer-1| [thrd:main]: Partition plain-text-log [1] changed fetch state offset-query -> offset-wait
%7|1651858166.034|OFFSET|rdkafka#consumer-1| [thrd:main]: Topic plain-text-log [2]: timed offset query for END in state offset-query
%7|1651858166.034|OFFREQ|rdkafka#consumer-1| [thrd:main]: localhost:9092/1001: Partition plain-text-log [2]: querying for logical offset END (opv 4)
%7|1651858166.034|PARTSTATE|rdkafka#consumer-1| [thrd:main]: Partition plain-text-log [2] changed fetch state offset-query -> offset-wait
%7|1651858166.034|OFFSET|rdkafka#consumer-1| [thrd:main]: Topic plain-text-log [0]: timed offset query for END in state offset-query
%7|1651858166.034|OFFREQ|rdkafka#consumer-1| [thrd:main]: localhost:9092/1001: Partition plain-text-log [0]: querying for logical offset END (opv 4)
%7|1651858166.034|PARTSTATE|rdkafka#consumer-1| [thrd:main]: Partition plain-text-log [0] changed fetch state offset-query -> offset-wait
%7|1651858166.034|OFFSET|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: ListOffsetsRequest (v2, opv 4) for 1 topic(s) and 1 partition(s)
%7|1651858166.034|SEND|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Sent ListOffsetsRequest (v2, 62 bytes @ 0, CorrId 8)
%7|1651858166.034|OFFSET|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: ListOffsetsRequest (v2, opv 4) for 1 topic(s) and 1 partition(s)
%7|1651858166.034|SEND|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Sent ListOffsetsRequest (v2, 62 bytes @ 0, CorrId 9)
%7|1651858166.034|OFFSET|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: ListOffsetsRequest (v2, opv 4) for 1 topic(s) and 1 partition(s)
%7|1651858166.034|SEND|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Sent ListOffsetsRequest (v2, 62 bytes @ 0, CorrId 10)
%7|1651858166.036|RECV|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Received ListOffsetsResponse (v2, 50 bytes, CorrId 8, rtt 1.79ms)
%7|1651858166.036|OFFSET|rdkafka#consumer-1| [thrd:main]: localhost:9092/1001: Offset reply for topic plain-text-log [1] (v4 vs v4)
%7|1651858166.036|OFFSET|rdkafka#consumer-1| [thrd:main]: Offset END request for plain-text-log [1] returned offset 38 (38)
%7|1651858166.036|PARTSTATE|rdkafka#consumer-1| [thrd:main]: Partition plain-text-log [1] changed fetch state offset-wait -> active
%7|1651858166.036|FETCH|rdkafka#consumer-1| [thrd:main]: Partition plain-text-log [1] start fetching at offset 38
%7|1651858166.036|WAKEUP|rdkafka#consumer-1| [thrd:main]: localhost:9092/1001: Wake-up
%7|1651858166.036|FETCHDEC|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: Topic plain-text-log [1]: fetch decide: updating to version 4 (was 4) at offset 38 (was -1001)
%7|1651858166.036|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch backoff for 394ms
%7|1651858166.037|RECV|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Received ListOffsetsResponse (v2, 50 bytes, CorrId 9, rtt 2.64ms)
%7|1651858166.037|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch backoff for 393ms
%7|1651858166.037|OFFSET|rdkafka#consumer-1| [thrd:main]: localhost:9092/1001: Offset reply for topic plain-text-log [2] (v4 vs v4)
%7|1651858166.037|OFFSET|rdkafka#consumer-1| [thrd:main]: Offset END request for plain-text-log [2] returned offset 61 (61)
%7|1651858166.037|PARTSTATE|rdkafka#consumer-1| [thrd:main]: Partition plain-text-log [2] changed fetch state offset-wait -> active
%7|1651858166.037|FETCH|rdkafka#consumer-1| [thrd:main]: Partition plain-text-log [2] start fetching at offset 61
%7|1651858166.037|WAKEUP|rdkafka#consumer-1| [thrd:main]: localhost:9092/1001: Wake-up
%7|1651858166.037|FETCHDEC|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: Topic plain-text-log [2]: fetch decide: updating to version 4 (was 4) at offset 61 (was -1001)
%7|1651858166.037|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch backoff for 393ms
%7|1651858166.037|RECV|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Received ListOffsetsResponse (v2, 50 bytes, CorrId 10, rtt 3.46ms)
%7|1651858166.037|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch backoff for 392ms
%7|1651858166.037|OFFSET|rdkafka#consumer-1| [thrd:main]: localhost:9092/1001: Offset reply for topic plain-text-log [0] (v4 vs v4)
%7|1651858166.037|OFFSET|rdkafka#consumer-1| [thrd:main]: Offset END request for plain-text-log [0] returned offset 44 (44)
%7|1651858166.037|PARTSTATE|rdkafka#consumer-1| [thrd:main]: Partition plain-text-log [0] changed fetch state offset-wait -> active
%7|1651858166.037|FETCH|rdkafka#consumer-1| [thrd:main]: Partition plain-text-log [0] start fetching at offset 44
%7|1651858166.037|WAKEUP|rdkafka#consumer-1| [thrd:main]: localhost:9092/1001: Wake-up
%7|1651858166.037|FETCHDEC|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: Topic plain-text-log [0]: fetch decide: updating to version 4 (was 4) at offset 44 (was -1001)
%7|1651858166.037|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch backoff for 392ms
%7|1651858166.434|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [0] in state active at offset 44 (0/100000 msgs, 0/65536 kb queued, opv 4) is fetchable
%7|1651858166.434|FETCHADD|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Added plain-text-log [0] to fetch list (1 entries, opv 4, 0 messages queued): fetchable
%7|1651858166.434|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [1] in state active at offset 38 (0/100000 msgs, 0/65536 kb queued, opv 4) is fetchable
%7|1651858166.434|FETCHADD|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Added plain-text-log [1] to fetch list (2 entries, opv 4, 0 messages queued): fetchable
%7|1651858166.434|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [2] in state active at offset 61 (0/100000 msgs, 0/65536 kb queued, opv 4) is fetchable
%7|1651858166.434|FETCHADD|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Added plain-text-log [2] to fetch list (3 entries, opv 4, 0 messages queued): fetchable
%7|1651858166.434|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [0] at offset 44 (v4)
%7|1651858166.434|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [1] at offset 38 (v4)
%7|1651858166.434|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [2] at offset 61 (v4)
%7|1651858166.434|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch 3/3/3 toppar(s)
%7|1651858166.434|SEND|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Sent FetchRequest (v11, 160 bytes @ 0, CorrId 11)
%7|1651858166.936|RECV|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Received FetchResponse (v11, 160 bytes, CorrId 11, rtt 502.28ms)
%7|1651858166.936|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [0] MessageSet size 0, error "Success", MaxOffset 44, LSO 44, Ver 4/4
%7|1651858166.936|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [1] MessageSet size 0, error "Success", MaxOffset 38, LSO 38, Ver 4/4
%7|1651858166.936|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [2] MessageSet size 0, error "Success", MaxOffset 61, LSO 61, Ver 4/4
%7|1651858166.936|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [1] at offset 38 (v4)
%7|1651858166.936|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [2] at offset 61 (v4)
%7|1651858166.936|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [0] at offset 44 (v4)
%7|1651858166.936|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch 3/3/3 toppar(s)
%7|1651858166.936|SEND|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Sent FetchRequest (v11, 160 bytes @ 0, CorrId 12)
%7|1651858167.439|RECV|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Received FetchResponse (v11, 160 bytes, CorrId 12, rtt 502.70ms)
%7|1651858167.439|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [1] MessageSet size 0, error "Success", MaxOffset 38, LSO 38, Ver 4/4
%7|1651858167.439|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [2] MessageSet size 0, error "Success", MaxOffset 61, LSO 61, Ver 4/4
%7|1651858167.439|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [0] MessageSet size 0, error "Success", MaxOffset 44, LSO 44, Ver 4/4
%7|1651858167.439|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [2] at offset 61 (v4)
%7|1651858167.439|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [0] at offset 44 (v4)
%7|1651858167.439|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [1] at offset 38 (v4)
%7|1651858167.439|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch 3/3/3 toppar(s)
%7|1651858167.439|SEND|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Sent FetchRequest (v11, 160 bytes @ 0, CorrId 13)
%7|1651858167.942|RECV|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Received FetchResponse (v11, 160 bytes, CorrId 13, rtt 502.94ms)
%7|1651858167.942|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [2] MessageSet size 0, error "Success", MaxOffset 61, LSO 61, Ver 4/4
%7|1651858167.942|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [0] MessageSet size 0, error "Success", MaxOffset 44, LSO 44, Ver 4/4
%7|1651858167.942|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [1] MessageSet size 0, error "Success", MaxOffset 38, LSO 38, Ver 4/4
%7|1651858167.942|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [0] at offset 44 (v4)
%7|1651858167.942|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [1] at offset 38 (v4)
%7|1651858167.942|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [2] at offset 61 (v4)
%7|1651858167.942|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch 3/3/3 toppar(s)
%7|1651858167.942|SEND|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Sent FetchRequest (v11, 160 bytes @ 0, CorrId 14)
%7|1651858168.448|RECV|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Received FetchResponse (v11, 160 bytes, CorrId 14, rtt 506.45ms)
%7|1651858168.448|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [0] MessageSet size 0, error "Success", MaxOffset 44, LSO 44, Ver 4/4
%7|1651858168.448|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [1] MessageSet size 0, error "Success", MaxOffset 38, LSO 38, Ver 4/4
%7|1651858168.448|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [2] MessageSet size 0, error "Success", MaxOffset 61, LSO 61, Ver 4/4
%7|1651858168.448|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [1] at offset 38 (v4)
%7|1651858168.448|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [2] at offset 61 (v4)
%7|1651858168.448|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [0] at offset 44 (v4)
%7|1651858168.448|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch 3/3/3 toppar(s)
%7|1651858168.448|SEND|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Sent FetchRequest (v11, 160 bytes @ 0, CorrId 15)
%7|1651858168.938|HEARTBEAT|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/1001: Heartbeat for group "test_proxcon_0001" generation id 23
%7|1651858168.938|SEND|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Sent HeartbeatRequest (v3, 92 bytes @ 0, CorrId 8)
%7|1651858168.941|RECV|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Received HeartbeatResponse (v3, 6 bytes, CorrId 8, rtt 3.09ms)
%7|1651858168.952|RECV|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Received FetchResponse (v11, 160 bytes, CorrId 15, rtt 503.49ms)
%7|1651858168.952|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [1] MessageSet size 0, error "Success", MaxOffset 38, LSO 38, Ver 4/4
%7|1651858168.952|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [2] MessageSet size 0, error "Success", MaxOffset 61, LSO 61, Ver 4/4
%7|1651858168.952|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [0] MessageSet size 0, error "Success", MaxOffset 44, LSO 44, Ver 4/4
%7|1651858168.952|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [2] at offset 61 (v4)
%7|1651858168.952|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [0] at offset 44 (v4)
%7|1651858168.952|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [1] at offset 38 (v4)
%7|1651858168.952|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch 3/3/3 toppar(s)
%7|1651858168.952|SEND|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Sent FetchRequest (v11, 160 bytes @ 0, CorrId 16)
%7|1651858169.454|RECV|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Received FetchResponse (v11, 160 bytes, CorrId 16, rtt 501.85ms)
%7|1651858169.454|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [2] MessageSet size 0, error "Success", MaxOffset 61, LSO 61, Ver 4/4
%7|1651858169.454|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [0] MessageSet size 0, error "Success", MaxOffset 44, LSO 44, Ver 4/4
%7|1651858169.454|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [1] MessageSet size 0, error "Success", MaxOffset 38, LSO 38, Ver 4/4
%7|1651858169.454|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [0] at offset 44 (v4)
%7|1651858169.454|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [1] at offset 38 (v4)
%7|1651858169.454|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [2] at offset 61 (v4)
%7|1651858169.454|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch 3/3/3 toppar(s)
%7|1651858169.454|SEND|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Sent FetchRequest (v11, 160 bytes @ 0, CorrId 17)
%7|1651858169.957|RECV|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Received FetchResponse (v11, 160 bytes, CorrId 17, rtt 503.07ms)
%7|1651858169.957|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [0] MessageSet size 0, error "Success", MaxOffset 44, LSO 44, Ver 4/4
%7|1651858169.957|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [1] MessageSet size 0, error "Success", MaxOffset 38, LSO 38, Ver 4/4
%7|1651858169.957|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [2] MessageSet size 0, error "Success", MaxOffset 61, LSO 61, Ver 4/4
%7|1651858169.957|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [1] at offset 38 (v4)
%7|1651858169.957|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [2] at offset 61 (v4)
%7|1651858169.957|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [0] at offset 44 (v4)
%7|1651858169.957|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch 3/3/3 toppar(s)
%7|1651858169.957|SEND|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Sent FetchRequest (v11, 160 bytes @ 0, CorrId 18)
%7|1651858170.460|RECV|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Received FetchResponse (v11, 160 bytes, CorrId 18, rtt 502.67ms)
%7|1651858170.460|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [1] MessageSet size 0, error "Success", MaxOffset 38, LSO 38, Ver 4/4
%7|1651858170.460|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [2] MessageSet size 0, error "Success", MaxOffset 61, LSO 61, Ver 4/4
%7|1651858170.460|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [0] MessageSet size 0, error "Success", MaxOffset 44, LSO 44, Ver 4/4
%7|1651858170.460|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [2] at offset 61 (v4)
%7|1651858170.460|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [0] at offset 44 (v4)
%7|1651858170.460|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [1] at offset 38 (v4)
%7|1651858170.460|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch 3/3/3 toppar(s)
%7|1651858170.460|SEND|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Sent FetchRequest (v11, 160 bytes @ 0, CorrId 19)
%7|1651858170.905|OFFSET|rdkafka#consumer-1| [thrd:main]: Topic plain-text-log [0]: stored offset -1001, committed offset -1001: not including in commit
%7|1651858170.905|OFFSET|rdkafka#consumer-1| [thrd:main]: Topic plain-text-log [1]: stored offset -1001, committed offset -1001: not including in commit
%7|1651858170.905|OFFSET|rdkafka#consumer-1| [thrd:main]: Topic plain-text-log [2]: stored offset -1001, committed offset -1001: not including in commit
%7|1651858170.905|DUMP|rdkafka#consumer-1| [thrd:main]: Assignment dump (started_cnt=3, wait_stop_cnt=0)
%7|1651858170.905|DUMP_ALL|rdkafka#consumer-1| [thrd:main]: List with 3 partition(s):
%7|1651858170.905|DUMP_ALL|rdkafka#consumer-1| [thrd:main]:  plain-text-log [0] offset 2000
%7|1651858170.905|DUMP_ALL|rdkafka#consumer-1| [thrd:main]:  plain-text-log [1] offset 2000
%7|1651858170.905|DUMP_ALL|rdkafka#consumer-1| [thrd:main]:  plain-text-log [2] offset 2000
%7|1651858170.905|DUMP_PND|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s):
%7|1651858170.905|DUMP_QRY|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s):
%7|1651858170.905|DUMP_REM|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s):
%7|1651858170.905|ASSIGNDONE|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001": assignment operations done in join-state steady (rebalance rejoin=false)
%7|1651858170.964|RECV|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Received FetchResponse (v11, 160 bytes, CorrId 19, rtt 504.23ms)
%7|1651858170.964|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [2] MessageSet size 0, error "Success", MaxOffset 61, LSO 61, Ver 4/4
%7|1651858170.964|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [0] MessageSet size 0, error "Success", MaxOffset 44, LSO 44, Ver 4/4
%7|1651858170.964|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [1] MessageSet size 0, error "Success", MaxOffset 38, LSO 38, Ver 4/4
%7|1651858170.964|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [0] at offset 44 (v4)
%7|1651858170.964|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [1] at offset 38 (v4)
%7|1651858170.964|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [2] at offset 61 (v4)
%7|1651858170.964|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch 3/3/3 toppar(s)
%7|1651858170.964|SEND|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Sent FetchRequest (v11, 160 bytes @ 0, CorrId 20)
%7|1651858171.467|RECV|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Received FetchResponse (v11, 160 bytes, CorrId 20, rtt 502.97ms)
%7|1651858171.467|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [0] MessageSet size 0, error "Success", MaxOffset 44, LSO 44, Ver 4/4
%7|1651858171.467|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [1] MessageSet size 0, error "Success", MaxOffset 38, LSO 38, Ver 4/4
%7|1651858171.467|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [2] MessageSet size 0, error "Success", MaxOffset 61, LSO 61, Ver 4/4
%7|1651858171.467|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [1] at offset 38 (v4)
%7|1651858171.467|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [2] at offset 61 (v4)
%7|1651858171.467|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [0] at offset 44 (v4)
%7|1651858171.467|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch 3/3/3 toppar(s)
%7|1651858171.467|SEND|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Sent FetchRequest (v11, 160 bytes @ 0, CorrId 21)
%7|1651858171.959|HEARTBEAT|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/1001: Heartbeat for group "test_proxcon_0001" generation id 23
%7|1651858171.959|SEND|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Sent HeartbeatRequest (v3, 92 bytes @ 0, CorrId 9)
%7|1651858171.962|RECV|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Received HeartbeatResponse (v3, 6 bytes, CorrId 9, rtt 2.54ms)
%7|1651858171.970|RECV|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Received FetchResponse (v11, 160 bytes, CorrId 21, rtt 502.37ms)
%7|1651858171.970|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [1] MessageSet size 0, error "Success", MaxOffset 38, LSO 38, Ver 4/4
%7|1651858171.970|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [2] MessageSet size 0, error "Success", MaxOffset 61, LSO 61, Ver 4/4
%7|1651858171.970|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [0] MessageSet size 0, error "Success", MaxOffset 44, LSO 44, Ver 4/4
%7|1651858171.970|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [2] at offset 61 (v4)
%7|1651858171.970|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [0] at offset 44 (v4)
%7|1651858171.970|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [1] at offset 38 (v4)
%7|1651858171.970|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch 3/3/3 toppar(s)
%7|1651858171.970|SEND|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Sent FetchRequest (v11, 160 bytes @ 0, CorrId 22)
%7|1651858172.472|RECV|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Received FetchResponse (v11, 160 bytes, CorrId 22, rtt 502.15ms)
%7|1651858172.472|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [2] MessageSet size 0, error "Success", MaxOffset 61, LSO 61, Ver 4/4
%7|1651858172.472|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [0] MessageSet size 0, error "Success", MaxOffset 44, LSO 44, Ver 4/4
%7|1651858172.472|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [1] MessageSet size 0, error "Success", MaxOffset 38, LSO 38, Ver 4/4
%7|1651858172.472|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [0] at offset 44 (v4)
%7|1651858172.472|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [1] at offset 38 (v4)
%7|1651858172.472|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [2] at offset 61 (v4)
%7|1651858172.472|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch 3/3/3 toppar(s)
%7|1651858172.472|SEND|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Sent FetchRequest (v11, 160 bytes @ 0, CorrId 23)
%7|1651858172.975|RECV|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Received FetchResponse (v11, 160 bytes, CorrId 23, rtt 503.39ms)
%7|1651858172.975|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [0] MessageSet size 0, error "Success", MaxOffset 44, LSO 44, Ver 4/4
%7|1651858172.975|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [1] MessageSet size 0, error "Success", MaxOffset 38, LSO 38, Ver 4/4
%7|1651858172.975|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [2] MessageSet size 0, error "Success", MaxOffset 61, LSO 61, Ver 4/4
%7|1651858172.975|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [1] at offset 38 (v4)
%7|1651858172.975|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [2] at offset 61 (v4)
%7|1651858172.975|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [0] at offset 44 (v4)
%7|1651858172.975|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch 3/3/3 toppar(s)
%7|1651858172.975|SEND|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Sent FetchRequest (v11, 160 bytes @ 0, CorrId 24)
%7|1651858173.479|RECV|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Received FetchResponse (v11, 160 bytes, CorrId 24, rtt 503.76ms)
%7|1651858173.479|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [1] MessageSet size 0, error "Success", MaxOffset 38, LSO 38, Ver 4/4
%7|1651858173.479|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [2] MessageSet size 0, error "Success", MaxOffset 61, LSO 61, Ver 4/4
%7|1651858173.479|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [0] MessageSet size 0, error "Success", MaxOffset 44, LSO 44, Ver 4/4
%7|1651858173.479|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [2] at offset 61 (v4)
%7|1651858173.479|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [0] at offset 44 (v4)
%7|1651858173.479|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [1] at offset 38 (v4)
%7|1651858173.479|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch 3/3/3 toppar(s)
%7|1651858173.479|SEND|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Sent FetchRequest (v11, 160 bytes @ 0, CorrId 25)
%7|1651858173.983|RECV|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Received FetchResponse (v11, 160 bytes, CorrId 25, rtt 503.69ms)
%7|1651858173.983|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [2] MessageSet size 0, error "Success", MaxOffset 61, LSO 61, Ver 4/4
%7|1651858173.983|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [0] MessageSet size 0, error "Success", MaxOffset 44, LSO 44, Ver 4/4
%7|1651858173.983|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [1] MessageSet size 0, error "Success", MaxOffset 38, LSO 38, Ver 4/4
%7|1651858173.983|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [0] at offset 44 (v4)
%7|1651858173.983|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [1] at offset 38 (v4)
%7|1651858173.983|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [2] at offset 61 (v4)
%7|1651858173.983|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch 3/3/3 toppar(s)
%7|1651858173.983|SEND|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Sent FetchRequest (v11, 160 bytes @ 0, CorrId 26)
%7|1651858174.486|RECV|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Received FetchResponse (v11, 160 bytes, CorrId 26, rtt 502.96ms)
%7|1651858174.486|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [0] MessageSet size 0, error "Success", MaxOffset 44, LSO 44, Ver 4/4
%7|1651858174.486|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [1] MessageSet size 0, error "Success", MaxOffset 38, LSO 38, Ver 4/4
%7|1651858174.486|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [2] MessageSet size 0, error "Success", MaxOffset 61, LSO 61, Ver 4/4
%7|1651858174.486|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [1] at offset 38 (v4)
%7|1651858174.486|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [2] at offset 61 (v4)
%7|1651858174.486|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [0] at offset 44 (v4)
%7|1651858174.486|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch 3/3/3 toppar(s)
%7|1651858174.486|SEND|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Sent FetchRequest (v11, 160 bytes @ 0, CorrId 27)
%7|1651858174.975|HEARTBEAT|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/1001: Heartbeat for group "test_proxcon_0001" generation id 23
%7|1651858174.975|SEND|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Sent HeartbeatRequest (v3, 92 bytes @ 0, CorrId 10)
%7|1651858174.979|RECV|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Received HeartbeatResponse (v3, 6 bytes, CorrId 10, rtt 4.15ms)
%7|1651858174.989|RECV|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Received FetchResponse (v11, 160 bytes, CorrId 27, rtt 502.47ms)
%7|1651858174.989|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [1] MessageSet size 0, error "Success", MaxOffset 38, LSO 38, Ver 4/4
%7|1651858174.989|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [2] MessageSet size 0, error "Success", MaxOffset 61, LSO 61, Ver 4/4
%7|1651858174.989|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [0] MessageSet size 0, error "Success", MaxOffset 44, LSO 44, Ver 4/4
%7|1651858174.989|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [2] at offset 61 (v4)
%7|1651858174.989|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [0] at offset 44 (v4)
%7|1651858174.989|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [1] at offset 38 (v4)
%7|1651858174.989|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch 3/3/3 toppar(s)
%7|1651858174.989|SEND|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Sent FetchRequest (v11, 160 bytes @ 0, CorrId 28)
%7|1651858175.490|RECV|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Received FetchResponse (v11, 160 bytes, CorrId 28, rtt 501.85ms)
%7|1651858175.491|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [2] MessageSet size 0, error "Success", MaxOffset 61, LSO 61, Ver 4/4
%7|1651858175.491|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [0] MessageSet size 0, error "Success", MaxOffset 44, LSO 44, Ver 4/4
%7|1651858175.491|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [1] MessageSet size 0, error "Success", MaxOffset 38, LSO 38, Ver 4/4
%7|1651858175.491|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [0] at offset 44 (v4)
%7|1651858175.491|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [1] at offset 38 (v4)
%7|1651858175.491|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [2] at offset 61 (v4)
%7|1651858175.491|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch 3/3/3 toppar(s)
%7|1651858175.491|SEND|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Sent FetchRequest (v11, 160 bytes @ 0, CorrId 29)
%7|1651858175.908|OFFSET|rdkafka#consumer-1| [thrd:main]: Topic plain-text-log [0]: stored offset -1001, committed offset -1001: not including in commit
%7|1651858175.908|OFFSET|rdkafka#consumer-1| [thrd:main]: Topic plain-text-log [1]: stored offset -1001, committed offset -1001: not including in commit
%7|1651858175.908|OFFSET|rdkafka#consumer-1| [thrd:main]: Topic plain-text-log [2]: stored offset -1001, committed offset -1001: not including in commit
%7|1651858175.908|DUMP|rdkafka#consumer-1| [thrd:main]: Assignment dump (started_cnt=3, wait_stop_cnt=0)
%7|1651858175.908|DUMP_ALL|rdkafka#consumer-1| [thrd:main]: List with 3 partition(s):
%7|1651858175.908|DUMP_ALL|rdkafka#consumer-1| [thrd:main]:  plain-text-log [0] offset 2000
%7|1651858175.908|DUMP_ALL|rdkafka#consumer-1| [thrd:main]:  plain-text-log [1] offset 2000
%7|1651858175.908|DUMP_ALL|rdkafka#consumer-1| [thrd:main]:  plain-text-log [2] offset 2000
%7|1651858175.908|DUMP_PND|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s):
%7|1651858175.908|DUMP_QRY|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s):
%7|1651858175.908|DUMP_REM|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s):
%7|1651858175.908|ASSIGNDONE|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001": assignment operations done in join-state steady (rebalance rejoin=false)
%7|1651858175.995|RECV|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Received FetchResponse (v11, 160 bytes, CorrId 29, rtt 504.17ms)
%7|1651858175.995|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [0] MessageSet size 0, error "Success", MaxOffset 44, LSO 44, Ver 4/4
%7|1651858175.995|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [1] MessageSet size 0, error "Success", MaxOffset 38, LSO 38, Ver 4/4
%7|1651858175.995|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [2] MessageSet size 0, error "Success", MaxOffset 61, LSO 61, Ver 4/4
%7|1651858175.995|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [1] at offset 38 (v4)
%7|1651858175.995|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [2] at offset 61 (v4)
%7|1651858175.995|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [0] at offset 44 (v4)
%7|1651858175.995|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch 3/3/3 toppar(s)
%7|1651858175.995|SEND|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Sent FetchRequest (v11, 160 bytes @ 0, CorrId 30)
%7|1651858176.499|RECV|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Received FetchResponse (v11, 160 bytes, CorrId 30, rtt 504.08ms)
%7|1651858176.499|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [1] MessageSet size 0, error "Success", MaxOffset 38, LSO 38, Ver 4/4
%7|1651858176.499|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [2] MessageSet size 0, error "Success", MaxOffset 61, LSO 61, Ver 4/4
%7|1651858176.499|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [0] MessageSet size 0, error "Success", MaxOffset 44, LSO 44, Ver 4/4
%7|1651858176.499|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [2] at offset 61 (v4)
%7|1651858176.499|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [0] at offset 44 (v4)
%7|1651858176.499|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [1] at offset 38 (v4)
%7|1651858176.499|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch 3/3/3 toppar(s)
%7|1651858176.499|SEND|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Sent FetchRequest (v11, 160 bytes @ 0, CorrId 31)
%7|1651858177.002|RECV|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Received FetchResponse (v11, 160 bytes, CorrId 31, rtt 502.76ms)
%7|1651858177.002|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [2] MessageSet size 0, error "Success", MaxOffset 61, LSO 61, Ver 4/4
%7|1651858177.002|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [0] MessageSet size 0, error "Success", MaxOffset 44, LSO 44, Ver 4/4
%7|1651858177.002|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [1] MessageSet size 0, error "Success", MaxOffset 38, LSO 38, Ver 4/4
%7|1651858177.002|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [0] at offset 44 (v4)
%7|1651858177.002|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [1] at offset 38 (v4)
%7|1651858177.002|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [2] at offset 61 (v4)
%7|1651858177.002|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch 3/3/3 toppar(s)
%7|1651858177.002|SEND|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Sent FetchRequest (v11, 160 bytes @ 0, CorrId 32)
%7|1651858177.504|RECV|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Received FetchResponse (v11, 160 bytes, CorrId 32, rtt 502.08ms)
%7|1651858177.504|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [0] MessageSet size 0, error "Success", MaxOffset 44, LSO 44, Ver 4/4
%7|1651858177.504|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [1] MessageSet size 0, error "Success", MaxOffset 38, LSO 38, Ver 4/4
%7|1651858177.504|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [2] MessageSet size 0, error "Success", MaxOffset 61, LSO 61, Ver 4/4
%7|1651858177.504|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [1] at offset 38 (v4)
%7|1651858177.504|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [2] at offset 61 (v4)
%7|1651858177.504|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [0] at offset 44 (v4)
%7|1651858177.504|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch 3/3/3 toppar(s)
%7|1651858177.504|SEND|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Sent FetchRequest (v11, 160 bytes @ 0, CorrId 33)
%7|1651858177.987|HEARTBEAT|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/1001: Heartbeat for group "test_proxcon_0001" generation id 23
%7|1651858177.987|SEND|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Sent HeartbeatRequest (v3, 92 bytes @ 0, CorrId 11)
%7|1651858177.991|RECV|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Received HeartbeatResponse (v3, 6 bytes, CorrId 11, rtt 3.48ms)
%7|1651858178.007|RECV|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Received FetchResponse (v11, 160 bytes, CorrId 33, rtt 502.67ms)
%7|1651858178.007|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [1] MessageSet size 0, error "Success", MaxOffset 38, LSO 38, Ver 4/4
%7|1651858178.007|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [2] MessageSet size 0, error "Success", MaxOffset 61, LSO 61, Ver 4/4
%7|1651858178.007|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [0] MessageSet size 0, error "Success", MaxOffset 44, LSO 44, Ver 4/4
%7|1651858178.007|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [2] at offset 61 (v4)
%7|1651858178.007|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [0] at offset 44 (v4)
%7|1651858178.007|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [1] at offset 38 (v4)
%7|1651858178.007|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch 3/3/3 toppar(s)
%7|1651858178.007|SEND|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Sent FetchRequest (v11, 160 bytes @ 0, CorrId 34)

Broker snapshot after running the consumer

Every 1.0s: ./kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group test_proxcon_0001                          Shubhang-Balkundi: Fri May  6 23:00:43 2022

clients_lib_dir: /Users/shubhangbalkundi/kafka_2.12-2.4.0/bin/../clients/build/libs

Consumer group 'test_proxcon_0001' has no active members.

GROUP             TOPIC           PARTITION  CURRENT-OFFSET  LOG-END-OFFSET  LAG             CONSUMER-ID     HOST            CLIENT-ID
test_proxcon_0001 plain-text-log  0          0               44              44              -               -               -
test_proxcon_0001 plain-text-log  2          0               61              61              -               -               -
test_proxcon_0001 plain-text-log  1          0               38              38              -               -               -

Now running the consumer with auto.offset.reset = earliest. This works the consumer sets its offset to 0 and starts to consume hence the current offset is at 2

Every 1.0s: ./kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group test_proxcon_0001                          Shubhang-Balkundi: Fri May  6 23:03:16 2022

clients_lib_dir: /Users/shubhangbalkundi/kafka_2.12-2.4.0/bin/../clients/build/libs

Consumer group 'test_proxcon_0001' has no active members.

GROUP             TOPIC           PARTITION  CURRENT-OFFSET  LOG-END-OFFSET  LAG             CONSUMER-ID     HOST            CLIENT-ID
test_proxcon_0001 plain-text-log  0          2               44              42              -               -               -
test_proxcon_0001 plain-text-log  2          2               61              59              -               -               -
test_proxcon_0001 plain-text-log  1          2               38              36              -               -               -

Consumer logs for the same

%7|1651858311.304|MEMBERID|rdkafka#consumer-1| [thrd:app]: Group "test_proxcon_0001": updating member id "(not-set)" -> ""
%7|1651858311.304|WAKEUPFD|rdkafka#consumer-1| [thrd:app]: GroupCoordinator: Enabled low-latency ops queue wake-ups
%7|1651858311.304|BROKER|rdkafka#consumer-1| [thrd:app]: GroupCoordinator: Added new broker with NodeId -1
%7|1651858311.304|BRKMAIN|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Enter main broker thread
%7|1651858311.304|CGRPSTATE|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001" changed state init -> query-coord (join-state init)
%7|1651858311.304|BROADCAST|rdkafka#consumer-1| [thrd:main]: Broadcasting state change
%7|1651858311.304|WAKEUPFD|rdkafka#consumer-1| [thrd:app]: localhost:9092/bootstrap: Enabled low-latency ops queue wake-ups
%7|1651858311.304|BRKMAIN|rdkafka#consumer-1| [thrd::0/internal]: :0/internal: Enter main broker thread
%7|1651858311.304|BROKER|rdkafka#consumer-1| [thrd:app]: localhost:9092/bootstrap: Added new broker with NodeId -1
%7|1651858311.304|INIT|rdkafka#consumer-1| [thrd:app]: librdkafka v1.8.2 (0x10802ff) rdkafka#consumer-1 initialized (builtin.features gzip,snappy,ssl,sasl,regex,lz4,sasl_gssapi,sasl_plain,sasl_scram,plugins,zstd,sasl_oauthbearer, STRIP STATIC_LINKING CC GXX PKGCONFIG OSXLD LIBDL PLUGINS STATIC_LIB_zlib ZLIB STATIC_LIB_libcrypto STATIC_LIB_libssl SSL SASL_CYRUS STATIC_LIB_libzstd ZSTD HDRHISTOGRAM SYSLOG SNAPPY SOCKEM SASL_SCRAM SASL_OAUTHBEARER CRC32C_HW, debug 0xfffff)
%7|1651858311.304|CONNECT|rdkafka#consumer-1| [thrd:main]: localhost:9092/bootstrap: Selected for cluster connection: coordinator query (broker has 0 connection attempt(s))
%7|1651858311.304|BRKMAIN|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enter main broker thread
%7|1651858311.304|CONF|rdkafka#consumer-1| [thrd:app]: Client configuration:
%7|1651858311.304|CONF|rdkafka#consumer-1| [thrd:app]:   client.software.name = confluent-kafka-go
%7|1651858311.304|CONF|rdkafka#consumer-1| [thrd:app]:   client.software.version = 1.8.2
%7|1651858311.304|CONF|rdkafka#consumer-1| [thrd:app]:   metadata.broker.list = localhost:9092
%7|1651858311.304|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|1651858311.304|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001": no broker available for coordinator query: intervaled in state query-coord
%7|1651858311.304|CONNECT|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received CONNECT op
%7|1651858311.305|STATE|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state INIT -> TRY_CONNECT
%7|1651858311.305|BROADCAST|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
%7|1651858311.305|CONNECT|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: broker in state TRY_CONNECT connecting
%7|1651858311.304|CONF|rdkafka#consumer-1| [thrd:app]:   enabled_events = 376
%7|1651858311.305|CONF|rdkafka#consumer-1| [thrd:app]:   default_topic_conf = 0xcf042d0
%7|1651858311.305|CONF|rdkafka#consumer-1| [thrd:app]:   ssl.ca.location = probe
%7|1651858311.305|CONF|rdkafka#consumer-1| [thrd:app]:   group.id = test_proxcon_0001
%7|1651858311.305|STATE|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state TRY_CONNECT -> CONNECT
%7|1651858311.305|BROADCAST|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
%7|1651858311.305|CONF|rdkafka#consumer-1| [thrd:app]:   session.timeout.ms = 10000
%7|1651858311.305|CONF|rdkafka#consumer-1| [thrd:app]:   max.poll.interval.ms = 10000
%7|1651858311.305|CONF|rdkafka#consumer-1| [thrd:app]:   enable.auto.commit = true
%7|1651858311.305|CONF|rdkafka#consumer-1| [thrd:app]:   auto.commit.interval.ms = 5000
%7|1651858311.305|CONF|rdkafka#consumer-1| [thrd:app]:   enable.auto.offset.store = false
%7|1651858311.305|CONF|rdkafka#consumer-1| [thrd:app]: Default topic configuration:
%7|1651858311.305|CONF|rdkafka#consumer-1| [thrd:app]:   auto.offset.reset = smallest
%7|1651858311.305|CONNECT|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connecting to ipv6#[::1]:9092 (plaintext) with socket 18
%7|1651858311.306|CONNECT|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connected to ipv6#[::1]:9092
%7|1651858311.306|CONNECTED|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connected (#1)
%7|1651858311.306|FEATURE|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Updated enabled protocol features +ApiVersion to ApiVersion
%7|1651858311.306|STATE|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state CONNECT -> APIVERSION_QUERY
%7|1651858311.306|BROADCAST|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
%7|1651858311.306|SEND|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Sent ApiVersionRequest (v3, 48 bytes @ 0, CorrId 1)
2022/05/06 23:01:51 setting processing delay to 5000 millis
%7|1651858311.306|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001" received op SUBSCRIBE in state query-coord (join-state init)
%7|1651858311.306|SUBSCRIBE|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001": subscribe to new subscription of 1 topics (join-state init)
%7|1651858311.306|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 48ms: coordinator query
%7|1651858311.306|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001": no broker available for coordinator query: intervaled in state query-coord
%7|1651858311.308|RECV|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received ApiVersionResponse (v3, 410 bytes, CorrId 1, rtt 2.61ms)
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker API support:
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey Produce (0) Versions 0..9
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey Fetch (1) Versions 0..12
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey ListOffsets (2) Versions 0..6
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey Metadata (3) Versions 0..11
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey LeaderAndIsr (4) Versions 0..5
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey StopReplica (5) Versions 0..3
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey UpdateMetadata (6) Versions 0..7
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey ControlledShutdown (7) Versions 0..3
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey OffsetCommit (8) Versions 0..8
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey OffsetFetch (9) Versions 0..7
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey FindCoordinator (10) Versions 0..3
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey JoinGroup (11) Versions 0..7
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey Heartbeat (12) Versions 0..4
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey LeaveGroup (13) Versions 0..4
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey SyncGroup (14) Versions 0..5
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey DescribeGroups (15) Versions 0..5
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey ListGroups (16) Versions 0..4
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey SaslHandshake (17) Versions 0..1
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey ApiVersion (18) Versions 0..3
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey CreateTopics (19) Versions 0..7
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey DeleteTopics (20) Versions 0..6
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey DeleteRecords (21) Versions 0..2
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey InitProducerId (22) Versions 0..4
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey OffsetForLeaderEpoch (23) Versions 0..4
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey AddPartitionsToTxn (24) Versions 0..3
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey AddOffsetsToTxn (25) Versions 0..3
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey EndTxn (26) Versions 0..3
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey WriteTxnMarkers (27) Versions 0..1
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey TxnOffsetCommit (28) Versions 0..3
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey DescribeAcls (29) Versions 0..2
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey CreateAcls (30) Versions 0..2
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey DeleteAcls (31) Versions 0..2
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey DescribeConfigs (32) Versions 0..4
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey AlterConfigs (33) Versions 0..2
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey AlterReplicaLogDirs (34) Versions 0..2
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey DescribeLogDirs (35) Versions 0..2
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey SaslAuthenticate (36) Versions 0..2
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey CreatePartitions (37) Versions 0..3
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey CreateDelegationToken (38) Versions 0..2
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey RenewDelegationToken (39) Versions 0..2
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey ExpireDelegationToken (40) Versions 0..2
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey DescribeDelegationToken (41) Versions 0..2
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey DeleteGroups (42) Versions 0..2
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey ElectLeadersRequest (43) Versions 0..2
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey IncrementalAlterConfigsRequest (44) Versions 0..1
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey AlterPartitionReassignmentsRequest (45) Versions 0..0
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey ListPartitionReassignmentsRequest (46) Versions 0..0
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey OffsetDeleteRequest (47) Versions 0..0
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey DescribeClientQuotasRequest (48) Versions 0..1
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey AlterClientQuotasRequest (49) Versions 0..1
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey DescribeUserScramCredentialsRequest (50) Versions 0..0
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey AlterUserScramCredentialsRequest (51) Versions 0..0
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey AlterIsrRequest (56) Versions 0..0
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey UpdateFeaturesRequest (57) Versions 0..0
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey Unknown-60? (60) Versions 0..0
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey Unknown-61? (61) Versions 0..0
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature MsgVer1: Produce (2..2) supported by broker
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature MsgVer1: Fetch (2..2) supported by broker
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature MsgVer1
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature MsgVer2: Produce (3..3) supported by broker
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature MsgVer2: Fetch (4..4) supported by broker
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature MsgVer2
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature ApiVersion: ApiVersion (0..0) supported by broker
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature ApiVersion
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature BrokerGroupCoordinator: FindCoordinator (0..0) supported by broker
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature BrokerGroupCoordinator
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature BrokerBalancedConsumer: FindCoordinator (0..0) supported by broker
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature BrokerBalancedConsumer: OffsetCommit (1..2) supported by broker
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature BrokerBalancedConsumer: OffsetFetch (1..1) supported by broker
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature BrokerBalancedConsumer: JoinGroup (0..0) supported by broker
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature BrokerBalancedConsumer: SyncGroup (0..0) supported by broker
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature BrokerBalancedConsumer: Heartbeat (0..0) supported by broker
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature BrokerBalancedConsumer: LeaveGroup (0..0) supported by broker
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature BrokerBalancedConsumer
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature ThrottleTime: Produce (1..2) supported by broker
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature ThrottleTime: Fetch (1..2) supported by broker
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature ThrottleTime
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature Sasl: JoinGroup (0..0) supported by broker
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature Sasl
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature SaslHandshake: SaslHandshake (0..0) supported by broker
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature SaslHandshake
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature LZ4: FindCoordinator (0..0) supported by broker
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature LZ4
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature OffsetTime: ListOffsets (1..1) supported by broker
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature OffsetTime
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature IdempotentProducer: InitProducerId (0..0) supported by broker
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature IdempotentProducer
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature ZSTD: Produce (7..7) supported by broker
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature ZSTD: Fetch (10..10) supported by broker
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature ZSTD
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature SaslAuthReq: SaslHandshake (1..1) supported by broker
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature SaslAuthReq: SaslAuthenticate (0..0) supported by broker
%7|1651858311.308|APIVERSION|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature SaslAuthReq
%7|1651858311.308|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|1651858311.308|STATE|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state APIVERSION_QUERY -> UP
%7|1651858311.308|BROADCAST|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
%7|1651858311.308|METADATA|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Request metadata for brokers only: connected
%7|1651858311.308|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: localhost:9092/bootstrap: Group "test_proxcon_0001": querying for coordinator: intervaled in state query-coord
%7|1651858311.308|CGRPSTATE|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001" changed state query-coord -> wait-coord (join-state init)
%7|1651858311.308|BROADCAST|rdkafka#consumer-1| [thrd:main]: Broadcasting state change
%7|1651858311.308|SEND|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Sent MetadataRequest (v4, 26 bytes @ 0, CorrId 2)
%7|1651858311.309|SEND|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Sent FindCoordinatorRequest (v2, 41 bytes @ 0, CorrId 3)
%7|1651858311.310|RECV|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received MetadataResponse (v4, 61 bytes, CorrId 2, rtt 1.49ms)
%7|1651858311.310|METADATA|rdkafka#consumer-1| [thrd:main]: localhost:9092/bootstrap: ===== Received metadata: connected =====
%7|1651858311.310|METADATA|rdkafka#consumer-1| [thrd:main]: localhost:9092/bootstrap: ClusterId: 2BG2-s6HTGqTZMfzAqbp0g, ControllerId: 1001
%7|1651858311.310|METADATA|rdkafka#consumer-1| [thrd:main]: localhost:9092/bootstrap: 1 brokers, 0 topics
%7|1651858311.310|METADATA|rdkafka#consumer-1| [thrd:main]: localhost:9092/bootstrap:   Broker #0/1: localhost:9092 NodeId 1001
%7|1651858311.310|UPDATE|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: NodeId changed from -1 to 1001
%7|1651858311.310|UPDATE|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Name changed from localhost:9092/bootstrap to localhost:9092/1001
%7|1651858311.310|LEADER|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Mapped 0 partition(s) to broker
%7|1651858311.310|STATE|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Broker changed state UP -> UPDATE
%7|1651858311.310|BROADCAST|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
%7|1651858311.310|BROADCAST|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
%7|1651858311.310|STATE|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Broker changed state UPDATE -> UP
%7|1651858311.310|BROADCAST|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
%7|1651858311.310|CLUSTERID|rdkafka#consumer-1| [thrd:main]: localhost:9092/1001: ClusterId update "" -> "2BG2-s6HTGqTZMfzAqbp0g"
%7|1651858311.310|CONTROLLERID|rdkafka#consumer-1| [thrd:main]: localhost:9092/1001: ControllerId update -1 -> 1001
%7|1651858311.310|BROADCAST|rdkafka#consumer-1| [thrd:main]: Broadcasting state change
%7|1651858311.311|RECV|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Received FindCoordinatorResponse (v2, 31 bytes, CorrId 3, rtt 2.25ms)
%7|1651858311.311|CGRPCOORD|rdkafka#consumer-1| [thrd:main]: localhost:9092/1001: Group "test_proxcon_0001" coordinator is localhost:9092 id 1001
%7|1651858311.311|CGRPCOORD|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001" changing coordinator -1 -> 1001
%7|1651858311.311|COORDSET|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001" coordinator set to broker localhost:9092/1001
%7|1651858311.311|CGRPSTATE|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001" changed state wait-coord -> wait-broker-transport (join-state init)
%7|1651858311.311|BROADCAST|rdkafka#consumer-1| [thrd:main]: Broadcasting state change
%7|1651858311.311|NODENAME|rdkafka#consumer-1| [thrd:main]: GroupCoordinator: Broker nodename changed from "" to "localhost:9092"
%7|1651858311.311|NODEID|rdkafka#consumer-1| [thrd:main]: GroupCoordinator: Broker nodeid changed from -1 to 1001
%7|1651858311.311|CONNECT|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Received CONNECT op
%7|1651858311.311|STATE|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Broker changed state INIT -> TRY_CONNECT
%7|1651858311.311|BROADCAST|rdkafka#consumer-1| [thrd:GroupCoordinator]: Broadcasting state change
%7|1651858311.311|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: localhost:9092/1001: Group "test_proxcon_0001": querying for coordinator: intervaled in state wait-broker-transport
%7|1651858311.311|CONNECT|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: broker in state TRY_CONNECT connecting
%7|1651858311.311|STATE|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Broker changed state TRY_CONNECT -> CONNECT
%7|1651858311.311|BROADCAST|rdkafka#consumer-1| [thrd:GroupCoordinator]: Broadcasting state change
%7|1651858311.311|SEND|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Sent FindCoordinatorRequest (v2, 41 bytes @ 0, CorrId 4)
%7|1651858311.311|CONNECT|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Connecting to ipv6#[::1]:9092 (plaintext) with socket 19
%7|1651858311.311|CONNECT|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Connected to ipv6#[::1]:9092
%7|1651858311.311|CONNECTED|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Connected (#1)
%7|1651858311.311|FEATURE|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Updated enabled protocol features +ApiVersion to ApiVersion
%7|1651858311.311|STATE|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Broker changed state CONNECT -> APIVERSION_QUERY
%7|1651858311.311|BROADCAST|rdkafka#consumer-1| [thrd:GroupCoordinator]: Broadcasting state change
%7|1651858311.312|SEND|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Sent ApiVersionRequest (v3, 48 bytes @ 0, CorrId 1)
%7|1651858311.313|RECV|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Received FindCoordinatorResponse (v2, 31 bytes, CorrId 4, rtt 1.88ms)
%7|1651858311.313|CGRPCOORD|rdkafka#consumer-1| [thrd:main]: localhost:9092/1001: Group "test_proxcon_0001" coordinator is localhost:9092 id 1001
%7|1651858311.314|RECV|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Received ApiVersionResponse (v3, 410 bytes, CorrId 1, rtt 1.99ms)
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Broker API support:
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey Produce (0) Versions 0..9
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey Fetch (1) Versions 0..12
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey ListOffsets (2) Versions 0..6
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey Metadata (3) Versions 0..11
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey LeaderAndIsr (4) Versions 0..5
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey StopReplica (5) Versions 0..3
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey UpdateMetadata (6) Versions 0..7
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey ControlledShutdown (7) Versions 0..3
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey OffsetCommit (8) Versions 0..8
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey OffsetFetch (9) Versions 0..7
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey FindCoordinator (10) Versions 0..3
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey JoinGroup (11) Versions 0..7
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey Heartbeat (12) Versions 0..4
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey LeaveGroup (13) Versions 0..4
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey SyncGroup (14) Versions 0..5
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey DescribeGroups (15) Versions 0..5
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey ListGroups (16) Versions 0..4
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey SaslHandshake (17) Versions 0..1
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey ApiVersion (18) Versions 0..3
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey CreateTopics (19) Versions 0..7
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey DeleteTopics (20) Versions 0..6
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey DeleteRecords (21) Versions 0..2
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey InitProducerId (22) Versions 0..4
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey OffsetForLeaderEpoch (23) Versions 0..4
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey AddPartitionsToTxn (24) Versions 0..3
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey AddOffsetsToTxn (25) Versions 0..3
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey EndTxn (26) Versions 0..3
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey WriteTxnMarkers (27) Versions 0..1
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey TxnOffsetCommit (28) Versions 0..3
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey DescribeAcls (29) Versions 0..2
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey CreateAcls (30) Versions 0..2
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey DeleteAcls (31) Versions 0..2
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey DescribeConfigs (32) Versions 0..4
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey AlterConfigs (33) Versions 0..2
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey AlterReplicaLogDirs (34) Versions 0..2
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey DescribeLogDirs (35) Versions 0..2
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey SaslAuthenticate (36) Versions 0..2
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey CreatePartitions (37) Versions 0..3
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey CreateDelegationToken (38) Versions 0..2
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey RenewDelegationToken (39) Versions 0..2
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey ExpireDelegationToken (40) Versions 0..2
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey DescribeDelegationToken (41) Versions 0..2
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey DeleteGroups (42) Versions 0..2
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey ElectLeadersRequest (43) Versions 0..2
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey IncrementalAlterConfigsRequest (44) Versions 0..1
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey AlterPartitionReassignmentsRequest (45) Versions 0..0
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey ListPartitionReassignmentsRequest (46) Versions 0..0
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey OffsetDeleteRequest (47) Versions 0..0
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey DescribeClientQuotasRequest (48) Versions 0..1
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey AlterClientQuotasRequest (49) Versions 0..1
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey DescribeUserScramCredentialsRequest (50) Versions 0..0
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey AlterUserScramCredentialsRequest (51) Versions 0..0
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey AlterIsrRequest (56) Versions 0..0
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey UpdateFeaturesRequest (57) Versions 0..0
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey Unknown-60? (60) Versions 0..0
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:   ApiKey Unknown-61? (61) Versions 0..0
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:  Feature MsgVer1: Produce (2..2) supported by broker
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:  Feature MsgVer1: Fetch (2..2) supported by broker
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Enabling feature MsgVer1
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:  Feature MsgVer2: Produce (3..3) supported by broker
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:  Feature MsgVer2: Fetch (4..4) supported by broker
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Enabling feature MsgVer2
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:  Feature ApiVersion: ApiVersion (0..0) supported by broker
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Enabling feature ApiVersion
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:  Feature BrokerGroupCoordinator: FindCoordinator (0..0) supported by broker
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Enabling feature BrokerGroupCoordinator
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:  Feature BrokerBalancedConsumer: FindCoordinator (0..0) supported by broker
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:  Feature BrokerBalancedConsumer: OffsetCommit (1..2) supported by broker
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:  Feature BrokerBalancedConsumer: OffsetFetch (1..1) supported by broker
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:  Feature BrokerBalancedConsumer: JoinGroup (0..0) supported by broker
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:  Feature BrokerBalancedConsumer: SyncGroup (0..0) supported by broker
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:  Feature BrokerBalancedConsumer: Heartbeat (0..0) supported by broker
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:  Feature BrokerBalancedConsumer: LeaveGroup (0..0) supported by broker
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Enabling feature BrokerBalancedConsumer
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:  Feature ThrottleTime: Produce (1..2) supported by broker
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:  Feature ThrottleTime: Fetch (1..2) supported by broker
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Enabling feature ThrottleTime
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:  Feature Sasl: JoinGroup (0..0) supported by broker
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Enabling feature Sasl
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:  Feature SaslHandshake: SaslHandshake (0..0) supported by broker
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Enabling feature SaslHandshake
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:  Feature LZ4: FindCoordinator (0..0) supported by broker
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Enabling feature LZ4
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:  Feature OffsetTime: ListOffsets (1..1) supported by broker
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Enabling feature OffsetTime
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:  Feature IdempotentProducer: InitProducerId (0..0) supported by broker
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Enabling feature IdempotentProducer
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:  Feature ZSTD: Produce (7..7) supported by broker
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:  Feature ZSTD: Fetch (10..10) supported by broker
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Enabling feature ZSTD
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:  Feature SaslAuthReq: SaslHandshake (1..1) supported by broker
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001:  Feature SaslAuthReq: SaslAuthenticate (0..0) supported by broker
%7|1651858311.314|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Enabling feature SaslAuthReq
%7|1651858311.314|FEATURE|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Updated enabled protocol features to MsgVer1,ApiVersion,BrokerBalancedConsumer,ThrottleTime,Sasl,SaslHandshake,BrokerGroupCoordinator,LZ4,OffsetTime,MsgVer2,IdempotentProducer,ZSTD,SaslAuthReq
%7|1651858311.314|STATE|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Broker changed state APIVERSION_QUERY -> UP
%7|1651858311.314|BROADCAST|rdkafka#consumer-1| [thrd:GroupCoordinator]: Broadcasting state change
%7|1651858311.314|METADATA|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Request metadata for brokers only: connected
%7|1651858311.314|CGRPSTATE|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001" changed state wait-broker-transport -> up (join-state init)
%7|1651858311.314|BROADCAST|rdkafka#consumer-1| [thrd:main]: Broadcasting state change
%7|1651858311.314|JOIN|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001": join with 0 subscribed topic(s)
%7|1651858311.314|METADATA|rdkafka#consumer-1| [thrd:main]: Hinted cache of 1/1 topic(s) being queried
%7|1651858311.314|CGRPMETADATA|rdkafka#consumer-1| [thrd:main]: consumer join: metadata for subscription only available for 0/1 topics (-1ms old)
%7|1651858311.314|METADATA|rdkafka#consumer-1| [thrd:main]: localhost:9092/1001: Request metadata for 1 topic(s): consumer join
%7|1651858311.314|JOIN|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001": postponing join until up-to-date metadata is available
%7|1651858311.314|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001" changed join state init -> wait-metadata (state up)
%7|1651858311.314|DUMP|rdkafka#consumer-1| [thrd:main]: Assignment dump (started_cnt=0, wait_stop_cnt=0)
%7|1651858311.314|DUMP_ALL|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s):
%7|1651858311.314|DUMP_PND|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s):
%7|1651858311.314|DUMP_QRY|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s):
%7|1651858311.314|DUMP_REM|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s):
%7|1651858311.314|SEND|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Sent MetadataRequest (v4, 26 bytes @ 0, CorrId 2)
%7|1651858311.314|SEND|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Sent MetadataRequest (v4, 42 bytes @ 0, CorrId 5)
%7|1651858311.314|ASSIGNDONE|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001": assignment operations done in join-state wait-metadata (rebalance rejoin=false)
%7|1651858311.315|RECV|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Received MetadataResponse (v4, 61 bytes, CorrId 2, rtt 1.41ms)
%7|1651858311.315|METADATA|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/1001: ===== Received metadata: connected =====
%7|1651858311.315|RECV|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Received MetadataResponse (v4, 162 bytes, CorrId 5, rtt 1.41ms)
%7|1651858311.315|METADATA|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/1001: ClusterId: 2BG2-s6HTGqTZMfzAqbp0g, ControllerId: 1001
%7|1651858311.315|METADATA|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/1001: 1 brokers, 0 topics
%7|1651858311.315|METADATA|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/1001:   Broker #0/1: localhost:9092 NodeId 1001
%7|1651858311.315|METADATA|rdkafka#consumer-1| [thrd:main]: localhost:9092/1001: ===== Received metadata (for 1 requested topics): consumer join =====
%7|1651858311.315|METADATA|rdkafka#consumer-1| [thrd:main]: localhost:9092/1001: ClusterId: 2BG2-s6HTGqTZMfzAqbp0g, ControllerId: 1001
%7|1651858311.315|METADATA|rdkafka#consumer-1| [thrd:main]: localhost:9092/1001: 1 brokers, 1 topics
%7|1651858311.315|METADATA|rdkafka#consumer-1| [thrd:main]: localhost:9092/1001:   Broker #0/1: localhost:9092 NodeId 1001
%7|1651858311.315|METADATA|rdkafka#consumer-1| [thrd:main]: localhost:9092/1001:   Topic #0/1: plain-text-log with 3 partitions
%7|1651858311.315|METADATA|rdkafka#consumer-1| [thrd:main]: localhost:9092/1001: 1/1 requested topic(s) seen in metadata
%7|1651858311.315|SUBSCRIPTION|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001": effective subscription list changed from 0 to 1 topic(s):
%7|1651858311.315|SUBSCRIPTION|rdkafka#consumer-1| [thrd:main]:  Topic plain-text-log with 3 partition(s)
%7|1651858311.315|REJOIN|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001": subscription updated from metadata change: rejoining group in state wait-metadata
%7|1651858311.315|GRPLEADER|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001": resetting group leader info: group (re)join
%7|1651858311.315|REJOIN|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001" (re)joining in join-state wait-metadata with 0 assigned partition(s): Metadata for subscribed topic(s) has changed
%7|1651858311.315|REBALANCE|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001" initiating rebalance (NONE) in state up (join-state wait-metadata) with 0 assigned partition(s): Metadata for subscribed topic(s) has changed
%7|1651858311.315|REJOIN|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001": Rejoining group without an assignment: Metadata for subscribed topic(s) has changed
%7|1651858311.315|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001" changed join state wait-metadata -> init (state up)
%7|1651858311.315|JOIN|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001": join with 1 subscribed topic(s)
%7|1651858311.315|CGRPMETADATA|rdkafka#consumer-1| [thrd:main]: consumer join: metadata for subscription is up to date (0ms old)
%7|1651858311.315|JOIN|rdkafka#consumer-1| [thrd:main]: localhost:9092/1001: Joining group "test_proxcon_0001" with 1 subscribed topic(s) and member id ""
%7|1651858311.315|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001" changed join state init -> wait-join (state up)
%7|1651858311.315|SEND|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Sent JoinGroupRequest (v5, 153 bytes @ 0, CorrId 3)
%7|1651858311.315|BROADCAST|rdkafka#consumer-1| [thrd:GroupCoordinator]: Broadcasting state change
%7|1651858311.317|RECV|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Received JoinGroupResponse (v5, 64 bytes, CorrId 3, rtt 1.67ms)
%7|1651858311.317|JOINGROUP|rdkafka#consumer-1| [thrd:main]: JoinGroup response: GenerationId -1, Protocol , LeaderId , my MemberId rdkafka-6ebc7576-3dc7-437d-8dd6-665450eec399, member metadata count 0: Broker: Group member needs a valid member ID
%7|1651858311.317|REQERR|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/1001: JoinGroupRequest failed: Broker: Group member needs a valid member ID: explicit actions Ignore
%7|1651858311.317|MEMBERID|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001": updating member id "" -> "rdkafka-6ebc7576-3dc7-437d-8dd6-665450eec399"
%7|1651858311.317|REJOIN|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001": Rejoining group without an assignment: JoinGroup error: Broker: Group member needs a valid member ID
%7|1651858311.317|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001" changed join state wait-join -> init (state up)
%7|1651858311.317|JOIN|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001": join with 1 subscribed topic(s)
%7|1651858311.317|CGRPMETADATA|rdkafka#consumer-1| [thrd:main]: consumer join: metadata for subscription is up to date (1ms old)
%7|1651858311.317|JOIN|rdkafka#consumer-1| [thrd:main]: localhost:9092/1001: Joining group "test_proxcon_0001" with 1 subscribed topic(s) and member id "rdkafka-6ebc7576-3dc7-437d-8dd6-665450eec399"
%7|1651858311.317|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001" changed join state init -> wait-join (state up)
%7|1651858311.317|SEND|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Sent JoinGroupRequest (v5, 197 bytes @ 0, CorrId 4)
%7|1651858311.317|BROADCAST|rdkafka#consumer-1| [thrd:GroupCoordinator]: Broadcasting state change
%7|1651858311.321|RECV|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Received JoinGroupResponse (v5, 195 bytes, CorrId 4, rtt 3.61ms)
%7|1651858311.321|JOINGROUP|rdkafka#consumer-1| [thrd:main]: JoinGroup response: GenerationId 25, Protocol range, LeaderId rdkafka-6ebc7576-3dc7-437d-8dd6-665450eec399 (me), my MemberId rdkafka-6ebc7576-3dc7-437d-8dd6-665450eec399, member metadata count 1: (no error)
%7|1651858311.321|JOINGROUP|rdkafka#consumer-1| [thrd:main]: I am elected leader for group "test_proxcon_0001" with 1 member(s)
%7|1651858311.321|GRPLEADER|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001": resetting group leader info: JoinGroup response clean-up
%7|1651858311.321|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001" changed join state wait-join -> wait-metadata (state up)
%7|1651858311.321|METADATA|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/1001: Request metadata for 1 topic(s): partition assignor
%7|1651858311.321|SEND|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Sent MetadataRequest (v4, 42 bytes @ 0, CorrId 5)
%7|1651858311.322|RECV|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Received MetadataResponse (v4, 162 bytes, CorrId 5, rtt 1.63ms)
%7|1651858311.322|METADATA|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/1001: ===== Received metadata (for 1 requested topics): partition assignor =====
%7|1651858311.322|METADATA|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/1001: ClusterId: 2BG2-s6HTGqTZMfzAqbp0g, ControllerId: 1001
%7|1651858311.322|METADATA|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/1001: 1 brokers, 1 topics
%7|1651858311.322|METADATA|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/1001:   Broker #0/1: localhost:9092 NodeId 1001
%7|1651858311.322|METADATA|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/1001:   Topic #0/1: plain-text-log with 3 partitions
%7|1651858311.322|METADATA|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/1001: 1/1 requested topic(s) seen in metadata
%7|1651858311.322|ASSIGN|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001" running range assignor for 1 member(s) and 1 eligible subscribed topic(s):
%7|1651858311.322|ASSIGN|rdkafka#consumer-1| [thrd:main]:  Member "rdkafka-6ebc7576-3dc7-437d-8dd6-665450eec399" (me) with 0 owned partition(s) and 1 subscribed topic(s):
%7|1651858311.322|ASSIGN|rdkafka#consumer-1| [thrd:main]:   plain-text-log [-1]
%7|1651858311.322|ASSIGN|rdkafka#consumer-1| [thrd:main]: range: Topic plain-text-log with 3 partition(s) and 1 subscribing member(s)
%7|1651858311.322|ASSIGN|rdkafka#consumer-1| [thrd:main]: range: Member "rdkafka-6ebc7576-3dc7-437d-8dd6-665450eec399": assigned topic plain-text-log partitions 0..2
%7|1651858311.322|ASSIGN|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001" range assignment for 1 member(s) finished in 0.014ms:
%7|1651858311.322|ASSIGN|rdkafka#consumer-1| [thrd:main]:  Member "rdkafka-6ebc7576-3dc7-437d-8dd6-665450eec399" (me) assigned 3 partition(s):
%7|1651858311.322|ASSIGN|rdkafka#consumer-1| [thrd:main]:   plain-text-log [0]
%7|1651858311.322|ASSIGN|rdkafka#consumer-1| [thrd:main]:   plain-text-log [1]
%7|1651858311.322|ASSIGN|rdkafka#consumer-1| [thrd:main]:   plain-text-log [2]
%7|1651858311.322|ASSIGNOR|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001": "range" assignor run for 1 member(s)
%7|1651858311.322|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001" changed join state wait-metadata -> wait-sync (state up)
%7|1651858311.323|SEND|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Sent SyncGroupRequest (v3, 188 bytes @ 0, CorrId 6)
%7|1651858311.323|BROADCAST|rdkafka#consumer-1| [thrd:GroupCoordinator]: Broadcasting state change
%7|1651858311.326|RECV|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Received SyncGroupResponse (v3, 52 bytes, CorrId 6, rtt 3.14ms)
%7|1651858311.326|SYNCGROUP|rdkafka#consumer-1| [thrd:main]: SyncGroup response: Success (42 bytes of MemberState data)
%7|1651858311.326|ASSIGNMENT|rdkafka#consumer-1| [thrd:main]: List with 3 partition(s):
%7|1651858311.326|ASSIGNMENT|rdkafka#consumer-1| [thrd:main]:  plain-text-log [0] offset INVALID
%7|1651858311.326|ASSIGNMENT|rdkafka#consumer-1| [thrd:main]:  plain-text-log [1] offset INVALID
%7|1651858311.326|ASSIGNMENT|rdkafka#consumer-1| [thrd:main]:  plain-text-log [2] offset INVALID
%7|1651858311.326|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001" changed join state wait-sync -> wait-assign-call (state up)
%7|1651858311.326|ASSIGN|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001": delegating assign of 3 partition(s) to application on queue rd_kafka_cgrp_new: new assignment
%7|1651858311.326|ASSIGNMENT|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001": setting group assignment to 3 partition(s)
%7|1651858311.326|GRPASSIGNMENT|rdkafka#consumer-1| [thrd:main]: List with 3 partition(s):
%7|1651858311.326|GRPASSIGNMENT|rdkafka#consumer-1| [thrd:main]:  plain-text-log [0] offset INVALID
%7|1651858311.326|GRPASSIGNMENT|rdkafka#consumer-1| [thrd:main]:  plain-text-log [1] offset INVALID
%7|1651858311.326|GRPASSIGNMENT|rdkafka#consumer-1| [thrd:main]:  plain-text-log [2] offset INVALID
%7|1651858311.326|HEARTBEAT|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/1001: Heartbeat for group "test_proxcon_0001" generation id 25
%7|1651858311.326|SEND|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Sent HeartbeatRequest (v3, 92 bytes @ 0, CorrId 7)
2022/05/06 23:01:51 [rdkafka#consumer-1]:Rebalance AssignedPartitions: [plain-text-log[0]@unset plain-text-log[1]@unset plain-text-log[2]@unset]
ATP ===============  [plain-text-log[0]@2000 plain-text-log[1]@2000 plain-text-log[2]@2000]
%7|1651858311.326|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001" received op ASSIGN in state up (join-state wait-assign-call)
%7|1651858311.326|ASSIGN|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001": new assignment of 3 partition(s) in join-state wait-assign-call
%7|1651858311.326|CLEARASSIGN|rdkafka#consumer-1| [thrd:main]: No current assignment to clear
%7|1651858311.326|TOPIC|rdkafka#consumer-1| [thrd:main]: New local topic: plain-text-log
%7|1651858311.326|TOPPARNEW|rdkafka#consumer-1| [thrd:main]: NEW plain-text-log [-1] 0xd304d80 refcnt 0xd304e10 (at rd_kafka_topic_new0:465)
%7|1651858311.326|STATE|rdkafka#consumer-1| [thrd:main]: Topic plain-text-log changed state unknown -> exists
%7|1651858311.326|PARTCNT|rdkafka#consumer-1| [thrd:main]: Topic plain-text-log partition count changed from 0 to 3
%7|1651858311.326|TOPPARNEW|rdkafka#consumer-1| [thrd:main]: NEW plain-text-log [0] 0xd3053f0 refcnt 0xd305480 (at rd_kafka_topic_partition_cnt_update:798)
%7|1651858311.326|TOPPARNEW|rdkafka#consumer-1| [thrd:main]: NEW plain-text-log [1] 0xd3058b0 refcnt 0xd305940 (at rd_kafka_topic_partition_cnt_update:798)
%7|1651858311.326|TOPPARNEW|rdkafka#consumer-1| [thrd:main]: NEW plain-text-log [2] 0xd305e40 refcnt 0xd305ed0 (at rd_kafka_topic_partition_cnt_update:798)
%7|1651858311.326|METADATA|rdkafka#consumer-1| [thrd:main]:   Topic plain-text-log partition 0 Leader 1001
%7|1651858311.326|BRKDELGT|rdkafka#consumer-1| [thrd:main]: plain-text-log [0]: delegate to broker localhost:9092/1001 (rktp 0xd3053f0, term 0, ref 2)
%7|1651858311.326|BRKDELGT|rdkafka#consumer-1| [thrd:main]: plain-text-log [0]: delegating to broker localhost:9092/1001 for partition with 0 messages (0 bytes) queued
%7|1651858311.326|BRKMIGR|rdkafka#consumer-1| [thrd:main]: Migrating topic plain-text-log [0] 0xd3053f0 from (none) to localhost:9092/1001 (sending PARTITION_JOIN to localhost:9092/1001)
%7|1651858311.326|METADATA|rdkafka#consumer-1| [thrd:main]:   Topic plain-text-log partition 1 Leader 1001
%7|1651858311.326|BRKDELGT|rdkafka#consumer-1| [thrd:main]: plain-text-log [1]: delegate to broker localhost:9092/1001 (rktp 0xd3058b0, term 0, ref 2)
%7|1651858311.326|BRKDELGT|rdkafka#consumer-1| [thrd:main]: plain-text-log [1]: delegating to broker localhost:9092/1001 for partition with 0 messages (0 bytes) queued
%7|1651858311.326|BRKMIGR|rdkafka#consumer-1| [thrd:main]: Migrating topic plain-text-log [1] 0xd3058b0 from (none) to localhost:9092/1001 (sending PARTITION_JOIN to localhost:9092/1001)
%7|1651858311.326|METADATA|rdkafka#consumer-1| [thrd:main]:   Topic plain-text-log partition 2 Leader 1001
%7|1651858311.326|BRKDELGT|rdkafka#consumer-1| [thrd:main]: plain-text-log [2]: delegate to broker localhost:9092/1001 (rktp 0xd305e40, term 0, ref 2)
%7|1651858311.326|BRKDELGT|rdkafka#consumer-1| [thrd:main]: plain-text-log [2]: delegating to broker localhost:9092/1001 for partition with 0 messages (0 bytes) queued
%7|1651858311.326|TOPBRK|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [0]: joining broker (rktp 0xd3053f0, 0 message(s) queued)
%7|1651858311.326|BRKMIGR|rdkafka#consumer-1| [thrd:main]: Migrating topic plain-text-log [2] 0xd305e40 from (none) to localhost:9092/1001 (sending PARTITION_JOIN to localhost:9092/1001)
%7|1651858311.326|BROADCAST|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
%7|1651858311.326|CONF|rdkafka#consumer-1| [thrd:main]: Topic "plain-text-log" configuration (default_topic_conf):
%7|1651858311.326|CONF|rdkafka#consumer-1| [thrd:main]:   auto.offset.reset = smallest
%7|1651858311.326|TOPBRK|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [1]: joining broker (rktp 0xd3058b0, 0 message(s) queued)
%7|1651858311.326|BROADCAST|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
%7|1651858311.326|TOPBRK|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [2]: joining broker (rktp 0xd305e40, 0 message(s) queued)
%7|1651858311.326|BROADCAST|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
%7|1651858311.326|DESIRED|rdkafka#consumer-1| [thrd:main]: plain-text-log [0]: marking as DESIRED
%7|1651858311.326|DESIRED|rdkafka#consumer-1| [thrd:main]: plain-text-log [1]: marking as DESIRED
%7|1651858311.326|DESIRED|rdkafka#consumer-1| [thrd:main]: plain-text-log [2]: marking as DESIRED
%7|1651858311.326|ASSIGNMENT|rdkafka#consumer-1| [thrd:main]: Added 3 partition(s) to assignment which now consists of 3 partition(s) where of 3 are in pending state and 0 are being queried
%7|1651858311.326|PAUSE|rdkafka#consumer-1| [thrd:main]: Resuming fetchers for 3 assigned partition(s): assign called
%7|1651858311.326|RESUME|rdkafka#consumer-1| [thrd:main]: Library resuming 3 partition(s)
%7|1651858311.326|BARRIER|rdkafka#consumer-1| [thrd:main]: plain-text-log [0]: rd_kafka_toppar_op_pause_resume:2449: new version barrier v2
%7|1651858311.326|RESUME|rdkafka#consumer-1| [thrd:main]: Resume plain-text-log [0] (v2)
%7|1651858311.326|BARRIER|rdkafka#consumer-1| [thrd:main]: plain-text-log [1]: rd_kafka_toppar_op_pause_resume:2449: new version barrier v2
%7|1651858311.326|RESUME|rdkafka#consumer-1| [thrd:main]: Resume plain-text-log [1] (v2)
%7|1651858311.326|BARRIER|rdkafka#consumer-1| [thrd:main]: plain-text-log [2]: rd_kafka_toppar_op_pause_resume:2449: new version barrier v2
%7|1651858311.326|RESUME|rdkafka#consumer-1| [thrd:main]: Resume plain-text-log [2] (v2)
%7|1651858311.326|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001" changed join state wait-assign-call -> steady (state up)
%7|1651858311.326|DUMP|rdkafka#consumer-1| [thrd:main]: Assignment dump (started_cnt=0, wait_stop_cnt=0)
%7|1651858311.326|DUMP_ALL|rdkafka#consumer-1| [thrd:main]: List with 3 partition(s):
%7|1651858311.326|DUMP_ALL|rdkafka#consumer-1| [thrd:main]:  plain-text-log [0] offset 2000
%7|1651858311.326|DUMP_ALL|rdkafka#consumer-1| [thrd:main]:  plain-text-log [1] offset 2000
%7|1651858311.326|DUMP_ALL|rdkafka#consumer-1| [thrd:main]:  plain-text-log [2] offset 2000
%7|1651858311.326|DUMP_PND|rdkafka#consumer-1| [thrd:main]: List with 3 partition(s):
%7|1651858311.326|DUMP_PND|rdkafka#consumer-1| [thrd:main]:  plain-text-log [0] offset 2000
%7|1651858311.326|DUMP_PND|rdkafka#consumer-1| [thrd:main]:  plain-text-log [1] offset 2000
%7|1651858311.326|DUMP_PND|rdkafka#consumer-1| [thrd:main]:  plain-text-log [2] offset 2000
%7|1651858311.326|DUMP_QRY|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s):
%7|1651858311.326|DUMP_REM|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s):
%7|1651858311.326|SRVPEND|rdkafka#consumer-1| [thrd:main]: Starting pending assigned partition plain-text-log [2] at offset 2000
%7|1651858311.327|BARRIER|rdkafka#consumer-1| [thrd:main]: plain-text-log [2]: rd_kafka_toppar_op_pause_resume:2449: new version barrier v3
%7|1651858311.327|RESUME|rdkafka#consumer-1| [thrd:main]: Resume plain-text-log [2] (v3)
%7|1651858311.327|BARRIER|rdkafka#consumer-1| [thrd:main]: plain-text-log [2]: rd_kafka_toppar_op_fetch_start:2363: new version barrier v4
%7|1651858311.327|CONSUMER|rdkafka#consumer-1| [thrd:main]: Start consuming plain-text-log [2] at offset 2000 (v4)
%7|1651858311.327|SRVPEND|rdkafka#consumer-1| [thrd:main]: Starting pending assigned partition plain-text-log [1] at offset 2000
%7|1651858311.327|BARRIER|rdkafka#consumer-1| [thrd:main]: plain-text-log [1]: rd_kafka_toppar_op_pause_resume:2449: new version barrier v3
%7|1651858311.327|RESUME|rdkafka#consumer-1| [thrd:main]: Resume plain-text-log [1] (v3)
%7|1651858311.327|BARRIER|rdkafka#consumer-1| [thrd:main]: plain-text-log [1]: rd_kafka_toppar_op_fetch_start:2363: new version barrier v4
%7|1651858311.327|CONSUMER|rdkafka#consumer-1| [thrd:main]: Start consuming plain-text-log [1] at offset 2000 (v4)
%7|1651858311.327|SRVPEND|rdkafka#consumer-1| [thrd:main]: Starting pending assigned partition plain-text-log [0] at offset 2000
%7|1651858311.327|BARRIER|rdkafka#consumer-1| [thrd:main]: plain-text-log [0]: rd_kafka_toppar_op_pause_resume:2449: new version barrier v3
%7|1651858311.327|RESUME|rdkafka#consumer-1| [thrd:main]: Resume plain-text-log [0] (v3)
%7|1651858311.327|BARRIER|rdkafka#consumer-1| [thrd:main]: plain-text-log [0]: rd_kafka_toppar_op_fetch_start:2363: new version barrier v4
%7|1651858311.327|CONSUMER|rdkafka#consumer-1| [thrd:main]: Start consuming plain-text-log [0] at offset 2000 (v4)
%7|1651858311.327|ASSIGNDONE|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001": assignment operations done in join-state steady (rebalance rejoin=false)
%7|1651858311.327|OP|rdkafka#consumer-1| [thrd:main]: plain-text-log [0] received op PAUSE (v2) in fetch-state none (opv1)
%7|1651858311.327|RESUME|rdkafka#consumer-1| [thrd:main]: Not resuming plain-text-log [0]: partition is not paused by library
%7|1651858311.327|OP|rdkafka#consumer-1| [thrd:main]: plain-text-log [1] received op PAUSE (v2) in fetch-state none (opv1)
%7|1651858311.327|RESUME|rdkafka#consumer-1| [thrd:main]: Not resuming plain-text-log [1]: partition is not paused by library
%7|1651858311.327|OP|rdkafka#consumer-1| [thrd:main]: plain-text-log [2] received op PAUSE (v2) in fetch-state none (opv1)
%7|1651858311.327|RESUME|rdkafka#consumer-1| [thrd:main]: Not resuming plain-text-log [2]: partition is not paused by library
%7|1651858311.327|OP|rdkafka#consumer-1| [thrd:main]: plain-text-log [2] received op PAUSE (v3) in fetch-state none (opv2)
%7|1651858311.327|RESUME|rdkafka#consumer-1| [thrd:main]: Not resuming plain-text-log [2]: partition is not paused by library
%7|1651858311.327|OP|rdkafka#consumer-1| [thrd:main]: plain-text-log [2] received op FETCH_START (v4) in fetch-state none (opv3)
%7|1651858311.327|FETCH|rdkafka#consumer-1| [thrd:main]: Start fetch for plain-text-log [2] in state none at offset 2000 (v4)
%7|1651858311.327|PARTSTATE|rdkafka#consumer-1| [thrd:main]: Partition plain-text-log [2] changed fetch state none -> active
%7|1651858311.327|FETCH|rdkafka#consumer-1| [thrd:main]: Partition plain-text-log [2] start fetching at offset 2000
%7|1651858311.327|WAKEUP|rdkafka#consumer-1| [thrd:main]: localhost:9092/1001: Wake-up
%7|1651858311.327|OP|rdkafka#consumer-1| [thrd:main]: plain-text-log [1] received op PAUSE (v3) in fetch-state none (opv2)
%7|1651858311.327|RESUME|rdkafka#consumer-1| [thrd:main]: Not resuming plain-text-log [1]: partition is not paused by library
%7|1651858311.327|OP|rdkafka#consumer-1| [thrd:main]: plain-text-log [1] received op FETCH_START (v4) in fetch-state none (opv3)
%7|1651858311.327|FETCH|rdkafka#consumer-1| [thrd:main]: Start fetch for plain-text-log [1] in state none at offset 2000 (v4)
%7|1651858311.327|PARTSTATE|rdkafka#consumer-1| [thrd:main]: Partition plain-text-log [1] changed fetch state none -> active
%7|1651858311.327|FETCH|rdkafka#consumer-1| [thrd:main]: Partition plain-text-log [1] start fetching at offset 2000
%7|1651858311.327|WAKEUP|rdkafka#consumer-1| [thrd:main]: localhost:9092/1001: Wake-up
%7|1651858311.327|OP|rdkafka#consumer-1| [thrd:main]: plain-text-log [0] received op PAUSE (v3) in fetch-state none (opv2)
%7|1651858311.327|RESUME|rdkafka#consumer-1| [thrd:main]: Not resuming plain-text-log [0]: partition is not paused by library
%7|1651858311.327|OP|rdkafka#consumer-1| [thrd:main]: plain-text-log [0] received op FETCH_START (v4) in fetch-state none (opv3)
%7|1651858311.327|FETCH|rdkafka#consumer-1| [thrd:main]: Start fetch for plain-text-log [0] in state none at offset 2000 (v4)
%7|1651858311.327|PARTSTATE|rdkafka#consumer-1| [thrd:main]: Partition plain-text-log [0] changed fetch state none -> active
%7|1651858311.327|FETCH|rdkafka#consumer-1| [thrd:main]: Partition plain-text-log [0] start fetching at offset 2000
%7|1651858311.327|WAKEUP|rdkafka#consumer-1| [thrd:main]: localhost:9092/1001: Wake-up
%7|1651858311.327|FETCHDEC|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: Topic plain-text-log [1]: fetch decide: updating to version 4 (was 0) at offset 2000 (was 0)
%7|1651858311.327|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001" received op PARTITION_JOIN in state up (join-state steady) for plain-text-log [2]
%7|1651858311.327|PARTADD|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001": add plain-text-log [2]
%7|1651858311.327|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [1] in state active at offset 2000 (0/100000 msgs, 0/65536 kb queued, opv 4) is fetchable
%7|1651858311.327|FETCHADD|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Added plain-text-log [1] to fetch list (1 entries, opv 4, 0 messages queued): fetchable
%7|1651858311.327|FETCHDEC|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: Topic plain-text-log [2]: fetch decide: updating to version 4 (was 0) at offset 2000 (was 0)
%7|1651858311.327|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001" received op PARTITION_JOIN in state up (join-state steady) for plain-text-log [1]
%7|1651858311.327|PARTADD|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001": add plain-text-log [1]
%7|1651858311.327|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001" received op PARTITION_JOIN in state up (join-state steady) for plain-text-log [0]
%7|1651858311.327|PARTADD|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001": add plain-text-log [0]
%7|1651858311.327|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [2] in state active at offset 2000 (0/100000 msgs, 0/65536 kb queued, opv 4) is fetchable
%7|1651858311.327|FETCHADD|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Added plain-text-log [2] to fetch list (2 entries, opv 4, 0 messages queued): fetchable
%7|1651858311.327|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [1] at offset 2000 (v4)
%7|1651858311.327|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [2] at offset 2000 (v4)
%7|1651858311.327|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch 2/2/3 toppar(s)
%7|1651858311.327|SEND|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Sent FetchRequest (v11, 132 bytes @ 0, CorrId 6)
%7|1651858311.327|FETCHDEC|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: Topic plain-text-log [0]: fetch decide: updating to version 4 (was 0) at offset 2000 (was 0)
%7|1651858311.327|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [0] in state active at offset 2000 (0/100000 msgs, 0/65536 kb queued, opv 4) is fetchable
%7|1651858311.327|FETCHADD|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Added plain-text-log [0] to fetch list (3 entries, opv 4, 0 messages queued): fetchable
%7|1651858311.330|RECV|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Received HeartbeatResponse (v3, 6 bytes, CorrId 7, rtt 4.31ms)
%7|1651858311.330|RECV|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Received FetchResponse (v11, 118 bytes, CorrId 6, rtt 3.43ms)
%7|1651858311.330|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [1] MessageSet size 0, error "Broker: Offset out of range", MaxOffset -1, LSO -1, Ver 4/4
%7|1651858311.330|BACKOFF|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: plain-text-log [1]: Fetch backoff for 500ms: Broker: Offset out of range
%7|1651858311.330|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [2] MessageSet size 0, error "Broker: Offset out of range", MaxOffset -1, LSO -1, Ver 4/4
%7|1651858311.330|BACKOFF|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: plain-text-log [2]: Fetch backoff for 500ms: Broker: Offset out of range
%7|1651858311.330|PARTSTATE|rdkafka#consumer-1| [thrd:main]: Partition plain-text-log [1] changed fetch state active -> offset-query
%4|1651858311.330|OFFSET|rdkafka#consumer-1| [thrd:main]: plain-text-log [1]: offset reset (at offset 2000) to BEGINNING: fetch failed due to requested offset not available on the broker: Broker: Offset out of range
%7|1651858311.330|OFFSET|rdkafka#consumer-1| [thrd:main]: plain-text-log [1]: backoff: (re)starting offset query timer for offset BEGINNING
%7|1651858311.330|PARTSTATE|rdkafka#consumer-1| [thrd:main]: Partition plain-text-log [2] changed fetch state active -> offset-query
%4|1651858311.330|OFFSET|rdkafka#consumer-1| [thrd:main]: plain-text-log [2]: offset reset (at offset 2000) to BEGINNING: fetch failed due to requested offset not available on the broker: Broker: Offset out of range
%7|1651858311.330|OFFSET|rdkafka#consumer-1| [thrd:main]: plain-text-log [2]: backoff: (re)starting offset query timer for offset BEGINNING
%7|1651858311.330|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [1] in state offset-query at offset 2000 (0/100000 msgs, 0/65536 kb queued, opv 4) is not fetchable: not in active fetch state
%7|1651858311.330|FETCHADD|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Removed plain-text-log [1] from fetch list (2 entries, opv 4): not in active fetch state
%7|1651858311.330|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [2] in state offset-query at offset 2000 (0/100000 msgs, 0/65536 kb queued, opv 4) is not fetchable: not in active fetch state
%7|1651858311.330|FETCHADD|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Removed plain-text-log [2] from fetch list (1 entries, opv 4): not in active fetch state
%7|1651858311.330|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [0] at offset 2000 (v4)
%7|1651858311.330|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch 1/1/3 toppar(s)
%7|1651858311.330|SEND|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Sent FetchRequest (v11, 104 bytes @ 0, CorrId 7)
%7|1651858311.332|RECV|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Received FetchResponse (v11, 76 bytes, CorrId 7, rtt 1.30ms)
%7|1651858311.332|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [0] MessageSet size 0, error "Broker: Offset out of range", MaxOffset -1, LSO -1, Ver 4/4
%7|1651858311.332|BACKOFF|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: plain-text-log [0]: Fetch backoff for 500ms: Broker: Offset out of range
%7|1651858311.332|PARTSTATE|rdkafka#consumer-1| [thrd:main]: Partition plain-text-log [0] changed fetch state active -> offset-query
%4|1651858311.332|OFFSET|rdkafka#consumer-1| [thrd:main]: plain-text-log [0]: offset reset (at offset 2000) to BEGINNING: fetch failed due to requested offset not available on the broker: Broker: Offset out of range
%7|1651858311.332|OFFSET|rdkafka#consumer-1| [thrd:main]: plain-text-log [0]: backoff: (re)starting offset query timer for offset BEGINNING
%7|1651858311.332|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [0] in state offset-query at offset 2000 (0/100000 msgs, 0/65536 kb queued, opv 4) is not fetchable: not in active fetch state
%7|1651858311.332|FETCHADD|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Removed plain-text-log [0] from fetch list (0 entries, opv 4): not in active fetch state
%7|1651858311.433|OFFSET|rdkafka#consumer-1| [thrd:main]: Topic plain-text-log [1]: timed offset query for BEGINNING in state offset-query
%7|1651858311.433|OFFREQ|rdkafka#consumer-1| [thrd:main]: localhost:9092/1001: Partition plain-text-log [1]: querying for logical offset BEGINNING (opv 4)
%7|1651858311.433|PARTSTATE|rdkafka#consumer-1| [thrd:main]: Partition plain-text-log [1] changed fetch state offset-query -> offset-wait
%7|1651858311.433|OFFSET|rdkafka#consumer-1| [thrd:main]: Topic plain-text-log [2]: timed offset query for BEGINNING in state offset-query
%7|1651858311.433|OFFREQ|rdkafka#consumer-1| [thrd:main]: localhost:9092/1001: Partition plain-text-log [2]: querying for logical offset BEGINNING (opv 4)
%7|1651858311.433|PARTSTATE|rdkafka#consumer-1| [thrd:main]: Partition plain-text-log [2] changed fetch state offset-query -> offset-wait
%7|1651858311.433|OFFSET|rdkafka#consumer-1| [thrd:main]: Topic plain-text-log [0]: timed offset query for BEGINNING in state offset-query
%7|1651858311.433|OFFREQ|rdkafka#consumer-1| [thrd:main]: localhost:9092/1001: Partition plain-text-log [0]: querying for logical offset BEGINNING (opv 4)
%7|1651858311.433|PARTSTATE|rdkafka#consumer-1| [thrd:main]: Partition plain-text-log [0] changed fetch state offset-query -> offset-wait
%7|1651858311.433|OFFSET|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: ListOffsetsRequest (v2, opv 4) for 1 topic(s) and 1 partition(s)
%7|1651858311.433|SEND|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Sent ListOffsetsRequest (v2, 62 bytes @ 0, CorrId 8)
%7|1651858311.433|OFFSET|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: ListOffsetsRequest (v2, opv 4) for 1 topic(s) and 1 partition(s)
%7|1651858311.433|SEND|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Sent ListOffsetsRequest (v2, 62 bytes @ 0, CorrId 9)
%7|1651858311.433|OFFSET|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: ListOffsetsRequest (v2, opv 4) for 1 topic(s) and 1 partition(s)
%7|1651858311.433|SEND|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Sent ListOffsetsRequest (v2, 62 bytes @ 0, CorrId 10)
%7|1651858311.436|RECV|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Received ListOffsetsResponse (v2, 50 bytes, CorrId 8, rtt 3.24ms)
%7|1651858311.436|OFFSET|rdkafka#consumer-1| [thrd:main]: localhost:9092/1001: Offset reply for topic plain-text-log [1] (v4 vs v4)
%7|1651858311.436|OFFSET|rdkafka#consumer-1| [thrd:main]: Offset BEGINNING request for plain-text-log [1] returned offset 0 (0)
%7|1651858311.436|PARTSTATE|rdkafka#consumer-1| [thrd:main]: Partition plain-text-log [1] changed fetch state offset-wait -> active
%7|1651858311.436|FETCH|rdkafka#consumer-1| [thrd:main]: Partition plain-text-log [1] start fetching at offset 0
%7|1651858311.436|WAKEUP|rdkafka#consumer-1| [thrd:main]: localhost:9092/1001: Wake-up
%7|1651858311.436|FETCHDEC|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: Topic plain-text-log [1]: fetch decide: updating to version 4 (was 4) at offset 0 (was -1001)
%7|1651858311.436|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch backoff for 393ms
%7|1651858311.438|RECV|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Received ListOffsetsResponse (v2, 50 bytes, CorrId 9, rtt 4.52ms)
%7|1651858311.438|OFFSET|rdkafka#consumer-1| [thrd:main]: localhost:9092/1001: Offset reply for topic plain-text-log [2] (v4 vs v4)
%7|1651858311.438|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch backoff for 392ms
%7|1651858311.438|OFFSET|rdkafka#consumer-1| [thrd:main]: Offset BEGINNING request for plain-text-log [2] returned offset 0 (0)
%7|1651858311.438|PARTSTATE|rdkafka#consumer-1| [thrd:main]: Partition plain-text-log [2] changed fetch state offset-wait -> active
%7|1651858311.438|FETCH|rdkafka#consumer-1| [thrd:main]: Partition plain-text-log [2] start fetching at offset 0
%7|1651858311.438|WAKEUP|rdkafka#consumer-1| [thrd:main]: localhost:9092/1001: Wake-up
%7|1651858311.438|FETCHDEC|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: Topic plain-text-log [2]: fetch decide: updating to version 4 (was 4) at offset 0 (was -1001)
%7|1651858311.438|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch backoff for 392ms
%7|1651858311.439|RECV|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Received ListOffsetsResponse (v2, 50 bytes, CorrId 10, rtt 5.55ms)
%7|1651858311.439|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch backoff for 391ms
%7|1651858311.439|OFFSET|rdkafka#consumer-1| [thrd:main]: localhost:9092/1001: Offset reply for topic plain-text-log [0] (v4 vs v4)
%7|1651858311.439|OFFSET|rdkafka#consumer-1| [thrd:main]: Offset BEGINNING request for plain-text-log [0] returned offset 0 (0)
%7|1651858311.439|PARTSTATE|rdkafka#consumer-1| [thrd:main]: Partition plain-text-log [0] changed fetch state offset-wait -> active
%7|1651858311.439|FETCH|rdkafka#consumer-1| [thrd:main]: Partition plain-text-log [0] start fetching at offset 0
%7|1651858311.439|WAKEUP|rdkafka#consumer-1| [thrd:main]: localhost:9092/1001: Wake-up
%7|1651858311.439|FETCHDEC|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: Topic plain-text-log [0]: fetch decide: updating to version 4 (was 4) at offset 0 (was -1001)
%7|1651858311.439|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch backoff for 391ms
%7|1651858311.833|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [0] in state active at offset 0 (0/100000 msgs, 0/65536 kb queued, opv 4) is fetchable
%7|1651858311.833|FETCHADD|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Added plain-text-log [0] to fetch list (1 entries, opv 4, 0 messages queued): fetchable
%7|1651858311.833|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [1] in state active at offset 0 (0/100000 msgs, 0/65536 kb queued, opv 4) is fetchable
%7|1651858311.833|FETCHADD|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Added plain-text-log [1] to fetch list (2 entries, opv 4, 0 messages queued): fetchable
%7|1651858311.833|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [2] in state active at offset 0 (0/100000 msgs, 0/65536 kb queued, opv 4) is fetchable
%7|1651858311.833|FETCHADD|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Added plain-text-log [2] to fetch list (3 entries, opv 4, 0 messages queued): fetchable
%7|1651858311.833|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [0] at offset 0 (v4)
%7|1651858311.833|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [1] at offset 0 (v4)
%7|1651858311.833|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [2] at offset 0 (v4)
%7|1651858311.833|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch 3/3/3 toppar(s)
%7|1651858311.833|SEND|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Sent FetchRequest (v11, 160 bytes @ 0, CorrId 11)
%7|1651858311.838|RECV|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Received FetchResponse (v11, 11806 bytes, CorrId 11, rtt 5.30ms)
%7|1651858311.838|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [0] MessageSet size 3584, error "Success", MaxOffset 44, LSO 44, Ver 4/4
%7|1651858311.838|CONSUME|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Enqueue 44 message(s) (592 bytes, 44 ops) on plain-text-log [0] fetch queue (qlen 0, v4, last_offset 43, 0 ctrl msgs, uncompressed)
%7|1651858311.838|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [1] MessageSet size 3100, error "Success", MaxOffset 38, LSO 38, Ver 4/4
%7|1651858311.838|CONSUME|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Enqueue 38 message(s) (516 bytes, 38 ops) on plain-text-log [1] fetch queue (qlen 44, v4, last_offset 37, 0 ctrl msgs, uncompressed)
%7|1651858311.838|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [2] MessageSet size 4962, error "Success", MaxOffset 61, LSO 61, Ver 4/4
%7|1651858311.838|CONSUME|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Enqueue 61 message(s) (814 bytes, 61 ops) on plain-text-log [2] fetch queue (qlen 81, v4, last_offset 60, 0 ctrl msgs, uncompressed)
%7|1651858311.838|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [1] at offset 38 (v4)
%7|1651858311.838|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [2] at offset 61 (v4)
%7|1651858311.838|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch topic plain-text-log [0] at offset 44 (v4)
%7|1651858311.838|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Fetch 3/3/3 toppar(s)
%7|1651858311.838|SEND|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Sent FetchRequest (v11, 160 bytes @ 0, CorrId 12)
2022/05/06 23:01:51 [rdkafka#consumer-1] received 100 records
2022/05/06 23:01:51 [rdkafka#consumer-1-plain-text-log#0]: starting job
2022/05/06 23:01:51 [rdkafka#consumer-1-plain-text-log#0]: processing message
2022/05/06 23:01:51 [rdkafka#consumer-1-plain-text-log#1]: starting job
2022/05/06 23:01:51 [rdkafka#consumer-1-plain-text-log#1]: processing message
2022/05/06 23:01:51 [rdkafka#consumer-1] pausing parititions for [plain-text-log[0]@unset plain-text-log[1]@unset plain-text-log[2]@unset]
2022/05/06 23:01:51 [rdkafka#consumer-1-plain-text-log#2]: starting job
2022/05/06 23:01:51 [rdkafka#consumer-1-plain-text-log#2]: processing message
%7|1651858311.840|PAUSE|rdkafka#consumer-1| [thrd:app]: Application pausing 3 partition(s)
%7|1651858311.840|BARRIER|rdkafka#consumer-1| [thrd:app]: plain-text-log [0]: rd_kafka_toppar_op_pause_resume:2449: new version barrier v5
%7|1651858311.840|PAUSE|rdkafka#consumer-1| [thrd:app]: Pause plain-text-log [0] (v5)
%7|1651858311.840|BARRIER|rdkafka#consumer-1| [thrd:app]: plain-text-log [1]: rd_kafka_toppar_op_pause_resume:2449: new version barrier v5
%7|1651858311.840|PAUSE|rdkafka#consumer-1| [thrd:app]: Pause plain-text-log [1] (v5)
%7|1651858311.840|BARRIER|rdkafka#consumer-1| [thrd:app]: plain-text-log [2]: rd_kafka_toppar_op_pause_resume:2449: new version barrier v5
%7|1651858311.840|PAUSE|rdkafka#consumer-1| [thrd:app]: Pause plain-text-log [2] (v5)
%7|1651858311.840|OP|rdkafka#consumer-1| [thrd:main]: plain-text-log [0] received op PAUSE (v5) in fetch-state active (opv4)
%7|1651858311.840|PAUSE|rdkafka#consumer-1| [thrd:main]: Pause plain-text-log [0]: at offset 44 (state active, v5)
%7|1651858311.840|OP|rdkafka#consumer-1| [thrd:main]: plain-text-log [1] received op PAUSE (v5) in fetch-state active (opv4)
%7|1651858311.840|PAUSE|rdkafka#consumer-1| [thrd:main]: Pause plain-text-log [1]: at offset 38 (state active, v5)
%7|1651858311.840|OP|rdkafka#consumer-1| [thrd:main]: plain-text-log [2] received op PAUSE (v5) in fetch-state active (opv4)
%7|1651858311.840|PAUSE|rdkafka#consumer-1| [thrd:main]: Pause plain-text-log [2]: at offset 18 (state active, v5)
%7|1651858312.342|RECV|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Received FetchResponse (v11, 160 bytes, CorrId 12, rtt 503.13ms)
%7|1651858312.342|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [1] MessageSet size 0, error "Success", MaxOffset 38, LSO 38, Ver 4/4
%7|1651858312.342|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [2] MessageSet size 0, error "Success", MaxOffset 61, LSO 61, Ver 4/4
%7|1651858312.342|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [0] MessageSet size 0, error "Success", MaxOffset 44, LSO 44, Ver 4/4
%7|1651858312.342|FETCHDEC|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: Topic plain-text-log [0]: fetch decide: updating to version 5 (was 4) at offset 44 (was 44)
%7|1651858312.342|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [0] in state active at offset 44 (0/100000 msgs, 0/65536 kb queued, opv 5) is not fetchable: paused
%7|1651858312.342|FETCHADD|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Removed plain-text-log [0] from fetch list (2 entries, opv 5): paused
%7|1651858312.342|FETCHDEC|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: Topic plain-text-log [1]: fetch decide: updating to version 5 (was 4) at offset 38 (was 38)
%7|1651858312.342|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [1] in state active at offset 38 (0/100000 msgs, 0/65536 kb queued, opv 5) is not fetchable: paused
%7|1651858312.342|FETCHADD|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Removed plain-text-log [1] from fetch list (1 entries, opv 5): paused
%7|1651858312.342|FETCHDEC|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: Topic plain-text-log [2]: fetch decide: updating to version 5 (was 4) at offset 18 (was 61)
%7|1651858312.342|FETCH|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Topic plain-text-log [2] in state active at offset 18 (0/100000 msgs, 0/65536 kb queued, opv 5) is not fetchable: paused
%7|1651858312.342|FETCHADD|rdkafka#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/1001: Removed plain-text-log [2] from fetch list (0 entries, opv 5): paused
%7|1651858314.341|HEARTBEAT|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/1001: Heartbeat for group "test_proxcon_0001" generation id 25
%7|1651858314.342|SEND|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Sent HeartbeatRequest (v3, 92 bytes @ 0, CorrId 8)
%7|1651858314.346|RECV|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Received HeartbeatResponse (v3, 6 bytes, CorrId 8, rtt 4.03ms)
%7|1651858316.307|OFFSET|rdkafka#consumer-1| [thrd:main]: Topic plain-text-log [0]: stored offset -1001, committed offset -1001: not including in commit
%7|1651858316.307|OFFSET|rdkafka#consumer-1| [thrd:main]: Topic plain-text-log [1]: stored offset -1001, committed offset -1001: not including in commit
%7|1651858316.307|OFFSET|rdkafka#consumer-1| [thrd:main]: Topic plain-text-log [2]: stored offset -1001, committed offset -1001: not including in commit
%7|1651858316.307|DUMP|rdkafka#consumer-1| [thrd:main]: Assignment dump (started_cnt=3, wait_stop_cnt=0)
%7|1651858316.307|DUMP_ALL|rdkafka#consumer-1| [thrd:main]: List with 3 partition(s):
%7|1651858316.307|DUMP_ALL|rdkafka#consumer-1| [thrd:main]:  plain-text-log [0] offset 2000
%7|1651858316.307|DUMP_ALL|rdkafka#consumer-1| [thrd:main]:  plain-text-log [1] offset 2000
%7|1651858316.307|DUMP_ALL|rdkafka#consumer-1| [thrd:main]:  plain-text-log [2] offset 2000
%7|1651858316.307|DUMP_PND|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s):
%7|1651858316.307|DUMP_QRY|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s):
%7|1651858316.307|DUMP_REM|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s):
%7|1651858316.307|ASSIGNDONE|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001": assignment operations done in join-state steady (rebalance rejoin=false)
2022/05/06 23:01:56 [rdkafka#consumer-1-plain-text-log#1] updating offset:0
2022/05/06 23:01:56 [rdkafka#consumer-1-plain-text-log#2] updating offset:0
2022/05/06 23:01:56 [rdkafka#consumer-1-plain-text-log#1]: processing message
2022/05/06 23:01:56 [rdkafka#consumer-1-plain-text-log#2]: processing message
2022/05/06 23:01:56 [rdkafka#consumer-1-plain-text-log#0] updating offset:0
2022/05/06 23:01:56 [rdkafka#consumer-1-plain-text-log#0]: processing message
%7|1651858317.365|HEARTBEAT|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/1001: Heartbeat for group "test_proxcon_0001" generation id 25
%7|1651858317.365|SEND|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Sent HeartbeatRequest (v3, 92 bytes @ 0, CorrId 9)
%7|1651858317.370|RECV|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Received HeartbeatResponse (v3, 6 bytes, CorrId 9, rtt 4.56ms)
%7|1651858320.379|HEARTBEAT|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/1001: Heartbeat for group "test_proxcon_0001" generation id 25
%7|1651858320.379|SEND|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Sent HeartbeatRequest (v3, 92 bytes @ 0, CorrId 10)
%7|1651858320.381|RECV|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Received HeartbeatResponse (v3, 6 bytes, CorrId 10, rtt 2.55ms)
%7|1651858321.310|OFFSET|rdkafka#consumer-1| [thrd:main]: Topic plain-text-log [0]: stored offset -1001, committed offset -1001: not including in commit
%7|1651858321.310|OFFSET|rdkafka#consumer-1| [thrd:main]: Topic plain-text-log [1]: stored offset -1001, committed offset -1001: not including in commit
%7|1651858321.310|OFFSET|rdkafka#consumer-1| [thrd:main]: Topic plain-text-log [2]: stored offset -1001, committed offset -1001: not including in commit
%7|1651858321.310|DUMP|rdkafka#consumer-1| [thrd:main]: Assignment dump (started_cnt=3, wait_stop_cnt=0)
%7|1651858321.310|DUMP_ALL|rdkafka#consumer-1| [thrd:main]: List with 3 partition(s):
%7|1651858321.310|DUMP_ALL|rdkafka#consumer-1| [thrd:main]:  plain-text-log [0] offset 2000
%7|1651858321.310|DUMP_ALL|rdkafka#consumer-1| [thrd:main]:  plain-text-log [1] offset 2000
%7|1651858321.310|DUMP_ALL|rdkafka#consumer-1| [thrd:main]:  plain-text-log [2] offset 2000
%7|1651858321.310|DUMP_PND|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s):
%7|1651858321.310|DUMP_QRY|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s):
%7|1651858321.310|DUMP_REM|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s):
%7|1651858321.310|ASSIGNDONE|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001": assignment operations done in join-state steady (rebalance rejoin=false)
2022/05/06 23:02:01 [rdkafka#consumer-1-plain-text-log#2] updating offset:1
2022/05/06 23:02:01 [rdkafka#consumer-1-plain-text-log#0] updating offset:1
2022/05/06 23:02:01 [rdkafka#consumer-1-plain-text-log#2]: processing message
2022/05/06 23:02:01 [rdkafka#consumer-1-plain-text-log#0]: processing message
2022/05/06 23:02:01 [rdkafka#consumer-1-plain-text-log#1] updating offset:1
2022/05/06 23:02:01 [rdkafka#consumer-1-plain-text-log#1]: processing message
2022/05/06 23:02:01 [rdkafka#consumer-1]: storing offset: plain-text-log[0]@2
2022/05/06 23:02:01 [rdkafka#consumer-1]: storing offset: plain-text-log[1]@2
2022/05/06 23:02:01 [rdkafka#consumer-1]: storing offset: plain-text-log[2]@2
%7|1651858323.392|HEARTBEAT|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/1001: Heartbeat for group "test_proxcon_0001" generation id 25
%7|1651858323.393|SEND|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Sent HeartbeatRequest (v3, 92 bytes @ 0, CorrId 11)
%7|1651858323.395|RECV|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Received HeartbeatResponse (v3, 6 bytes, CorrId 11, rtt 2.44ms)
%7|1651858326.311|OFFSET|rdkafka#consumer-1| [thrd:main]: Topic plain-text-log [0]: stored offset 2, committed offset -1001: setting stored offset 2 for commit
%7|1651858326.311|OFFSET|rdkafka#consumer-1| [thrd:main]: Topic plain-text-log [1]: stored offset 2, committed offset -1001: setting stored offset 2 for commit
%7|1651858326.311|OFFSET|rdkafka#consumer-1| [thrd:main]: Topic plain-text-log [2]: stored offset 2, committed offset -1001: setting stored offset 2 for commit
%7|1651858326.311|COMMIT|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/1001: Committing offsets for 3 partition(s) with generation-id 25 in join-state steady: cgrp auto commit timer
%7|1651858326.311|OFFSET|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/1001: Enqueue OffsetCommitRequest(v7, 3/3 partition(s))): cgrp auto commit timer
%7|1651858326.311|SEND|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Sent OffsetCommitRequest (v7, 170 bytes @ 0, CorrId 12)
%7|1651858326.316|RECV|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Received OffsetCommitResponse (v7, 46 bytes, CorrId 12, rtt 4.96ms)
%7|1651858326.316|COMMIT|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/1001: OffsetCommit for 3 partition(s) in join-state steady: cgrp auto commit timer: returned: Success
%7|1651858326.316|DUMP|rdkafka#consumer-1| [thrd:main]: Assignment dump (started_cnt=3, wait_stop_cnt=0)
%7|1651858326.316|DUMP_ALL|rdkafka#consumer-1| [thrd:main]: List with 3 partition(s):
%7|1651858326.316|DUMP_ALL|rdkafka#consumer-1| [thrd:main]:  plain-text-log [0] offset 2000
%7|1651858326.316|DUMP_ALL|rdkafka#consumer-1| [thrd:main]:  plain-text-log [1] offset 2000
%7|1651858326.316|DUMP_ALL|rdkafka#consumer-1| [thrd:main]:  plain-text-log [2] offset 2000
%7|1651858326.316|DUMP_PND|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s):
%7|1651858326.316|DUMP_QRY|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s):
%7|1651858326.316|DUMP_REM|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s):
%7|1651858326.316|ASSIGNDONE|rdkafka#consumer-1| [thrd:main]: Group "test_proxcon_0001": assignment operations done in join-state steady (rebalance rejoin=false)
%7|1651858326.412|HEARTBEAT|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/1001: Heartbeat for group "test_proxcon_0001" generation id 25
%7|1651858326.412|SEND|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Sent HeartbeatRequest (v3, 92 bytes @ 0, CorrId 13)
%7|1651858326.415|RECV|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Received HeartbeatResponse (v3, 6 bytes, CorrId 13, rtt 2.42ms)
2022/05/06 23:02:06 [rdkafka#consumer-1-plain-text-log#2] updating offset:2
2022/05/06 23:02:06 [rdkafka#consumer-1-plain-text-log#2]: processing message
2022/05/06 23:02:06 [rdkafka#consumer-1-plain-text-log#1] updating offset:2
2022/05/06 23:02:06 [rdkafka#consumer-1-plain-text-log#1]: processing message
2022/05/06 23:02:06 [rdkafka#consumer-1-plain-text-log#0] updating offset:2
2022/05/06 23:02:06 [rdkafka#consumer-1-plain-text-log#0]: processing message
2022/05/06 23:02:06 [rdkafka#consumer-1]: storing offset: plain-text-log[0]@3
2022/05/06 23:02:06 [rdkafka#consumer-1]: storing offset: plain-text-log[1]@3
2022/05/06 23:02:06 [rdkafka#consumer-1]: storing offset: plain-text-log[2]@3
%7|1651858329.428|HEARTBEAT|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/1001: Heartbeat for group "test_proxcon_0001" generation id 25
%7|1651858329.428|SEND|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Sent HeartbeatRequest (v3, 92 bytes @ 0, CorrId 14)
%7|1651858329.430|RECV|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Received HeartbeatResponse (v3, 6 bytes, CorrId 14, rtt 2.25ms)

[shubhang93]

@jliunyu Hey do you need any more inputs / logs from my end?. I'd be happy to provide them This issue is present on the librdkafka C lib as well. https://github.com/edenhill/librdkafka/issues/3401

[jliunyu]

@shubhang93 , thanks for your response.

Since you simulated an invalid offset, so the Broker: Offset out of range is expected, right?

%4|1651858165.930|OFFSET|rdkafka#consumer-1| [thrd:main]: plain-text-log [2]: offset reset (at offset 2000) to END: fetch failed due to requested offset not available on the broker: Broker: Offset out of range

[shubhang93]

Yes but since my auto offset was set to latest i expected my current offsets to reset to the latest ones 44,61 and 38 in the above example. It doesn’t reset to those offsets and once i start producing messages the consumer doesn’t seem to consume them.

[shubhang93]

The same thing doesn’t happen when the auto offset reset is set to earliest

[shubhang93]

Can you try simulating on your end @jliunyu

[jliunyu]

Looks related to https://github.com/edenhill/librdkafka/pull/3774

[shubhang93]

Thanks. Let me try out v1.9.0-RC5

[mhowlett]

Yes but since my auto offset was set to latest i expected my current offsets to reset to the latest ones 44,61 and 38 in the above example. It doesn’t reset to those offsets and once i start producing messages the consumer doesn’t seem to consume them

@shubhang93 - i just tried to reproduce this. behavior for me was as i/you were expecting. I'm using librdkafka 1.9.2-RC2, the dotnet client. i'm not using consumer groups, but it should't matter.

[mhowlett]

@shubhang93 - did moving to 1.9.0 resolve this?

[mhowlett]

FWIW: I think your attempt to reproduce isn't relevant / isn't an issue, however your initial report likely reflects a real problem (we are seeing other similar reports elsewhere).

I'm trying to track this down.

[shubhang93]

FWIW: I think your attempt to reproduce isn't relevant / isn't an issue, however your initial report likely reflects a real problem (we are seeing other similar reports elsewhere).

I'm trying to track this down.

I haven't tried this with 1.90 yet. I believe @jliunyu mentioned that this issue was related to a librdkafka issue

[mhowlett]

i'm also interested in how you're committing offsets - enable.auto.commit true of false? enable.auto.offset.store true of false?

[shubhang93]

enable.auto.commit is true and enable.auto.offset.store is false

[AndreasBergmeier6176]

We have the same error with 1.9.2 and config:

        "enable.auto.commit":       "true",
        "enable.auto.offset.store": "false",

[GpsLypy]

We have the same error with 1.9.2

[GpsLypy]

%4|1663804986.957|OFFSET|rdkafka#consumer-1| [thrd:main]: TEDB024013035.dbo.AP_ExternalPayment [0]: offset reset (at offset 4241814745, broker 102) to BEGINNING: fetch failed due to requested offset not available on the broker: Broker: Offset out of range

[GpsLypy]

[GpsLypy]

what is the reason for this? and debug log is here:

[GpsLypy]

[GpsLypy]

[GpsLypy]

我们对 1.9.2 和配置有同样的错误：

      "enable.auto.commit":       "true",
      "enable.auto.offset.store": "false",

how do you solve?

[nik-hil]

Any idea how to solve this ?

[shubhang93]

Still having this issue on 1.9.2, i have covered the topic names as it is company related stuff. The thing is for all those partitions the low end and high end offsets are completely different. Even when commit is called for those paritions, the commit call returns the out of range offset.

[shubhang93]

I think there seems to be an issue with the offset store. The committed offsets for a partition is not getting reset when the messages on the partition are getting cleaned up. stored offset 684715, committed offset 2707875: not including in commit. Offset 2707875 was cleaned up on the broker and the current offset is 684715 which is what I am trying to store using the consumer.StoreOffsets method. This is preventing me from committing the offset and this increases the lag on the consumer side. As you can see from the log

%7|1669262819.750|OFFSET|rdkafka#consumer-1| [thrd:main]: Topic Topic_XXXX [2]: stored offset 684715, committed offset 2707875: not including in commit

I am attaching a Kafka minion dashboard screent shot for the same partition on the broker's side

As you can see when I try to commit that offset for parition 2 the stored offset for it is greater than the high watermark, hence I am unable to commit the offset itself. @jliunyu

It gets fixed when the consumer is restarted

[edenhill]

If the committed offset is higher than the hwmark it means the topic (or partition) was removed and re-created, which also means that any committed offsets are invalid (even if their offsets exist they refer to the wrong message).

Your best bet when deleting and re-creating topics is to also delete all committed offsets for that topic, across all groups, using the (java) Admin API.

[shubhang93]

@edenhill What if we are not re-creating the topic and this is happening due to the broker's retention policy. How would we commit offsets in such a case? Is there a way to seek the consumer to the new low watermark?

[edenhill]

I don't think retention should make offsets reset back, afaik they're monotonical and always increase.

[shubhang93]

@edenhill Consumer is not able to fetch the next offset even though it exists on the broker. I am manually committing my offsets and when I start my consumer again, for one of the partitions the offset is invalid

Client's stored offsets

Broker's offsets

Why is not able to fetch the next offset for partition 0. This increases the lag on that partition until I restart the consumer

EDIT: This was a mistake from my end, I was comitting the wrong offsets.

[ORESoftware]

I believe I am experiencing this issue, not sure what my server version is, but client versions are:

    github.com/confluentinc/confluent-kafka-go/v2 v2.3.0

[shade8881]

Do you have any updates? is there a conf to work around the problem?

[luongs3]

Still got this issue today with v1.9.2 Should I update the newest version?