confluent-kafka-go
confluent-kafka-go copied to clipboard
confluentinc
Consumer disconnected after X ms in state UP
Hi,
I am getting this warning constantly in the consumer service.
{"application":"kafka-oplog-consumer","consumer":"rdkafka#consumer-2","elastic-region":"EU1","error":"sasl_ssl://<kafka_url>:9094/0: Disconnected (after 119000ms in state UP)","host":"kafka-oplog-consumer-7dd495c99b-8xvfs","kafka-region":"EU1","level":"warning","msg":"error received, error code: -195","time":"2020-11-03T08:56:26Z","version":"1.1.1"}
Right now, the consumer is not consuming messages and just printing this error message. I am restarting the service and sometimes it work fine and later after 5-10 mins, the consuming stops and I get the above warning message. I first thought it is connection issue but the producer is connecting to same Kafka and is able to produce properly. I don't know what the above warning means and how to debug it.
This is my consumer init code:
func (c *Consumer) checkMsg(ev kafka.Event, messagesChannel chan *kafka.Message) {
switch e := ev.(type) {
case kafka.AssignedPartitions:
partitionsToAssign := e.Partitions
var perr error
if len(partitionsToAssign) == 0 {
logging.Entry.WithFields(logrus.Fields{}).Warn("No partitions assigned")
break
}
if config.Config.ReplayMode {
switch config.Config.ReplayType {
case "beginning":
partitionsToAssign, perr = resetPartitionOffsetsToBeginning(c.kC, e.Partitions)
if perr != nil {
logging.Entry.WithFields(logrus.Fields{
"error": perr.Error(),
"consumer": fmt.Sprintf("%s", c.kC),
}).Fatal("error trying to reset offsets to beginning")
}
case "offset":
offset := config.Config.ReplayOffset
if offset == "" {
panic("Starting offset number cannot be empty in case replay mode is enabled and type is offset")
}
o, _ := strconv.Atoi(offset)
offValue := int64(o)
partitionsToAssign, perr = resetPartitionOffsetsToOffset(c.kC, e.Partitions, offValue)
if perr != nil {
logging.Entry.WithFields(logrus.Fields{
"error": perr.Error(),
"consumer": fmt.Sprintf("%s", c.kC),
}).Fatalf("error trying to reset offsets to: %v\n", offset)
}
}
}
c.kC.Assign(partitionsToAssign)
c.assignedPartition = partitionsToAssign
case kafka.RevokedPartitions:
c.kC.Unassign()
case *kafka.Message:
messagesChannel <- e
case kafka.Error:
logging.Entry.WithFields(logrus.Fields{
"error": e.Error(),
"consumer": fmt.Sprintf("%s", c.kC),
}).Warnf("error received, error code: %d", e.Code())
default:
logging.Entry.Infof("Ignored event: %s\n", e)
}
}
I am not sure if there is anything wrong with the consumer logic also. Need help in this.
Checklist
Please provide the following information:
- [x] confluent-kafka-go and librdkafka version (
LibraryVersion()): 1.1.0 - [ ] Apache Kafka broker version:
- [x] Client configuration:
ConfigMap{"bootstrap.servers": config.Config.KafkaBrokerURL, "broker.address.family": "v4", "group.id": config.Config.ConsumerGroup, "session.timeout.ms": 10000, "enable.auto.commit": "false", "auto.offset.reset": config.Config.KafkaOffsetReset, "go.application.rebalance.enable": true, "sasl.mechanisms": "SCRAM-SHA-512", "security.protocol": "SASL_SSL", "sasl.username": config.Config.KafkaUser, "sasl.password": config.Config.KafkaPassword,} - [ ] Operating system:
- [ ] Provide client logs (with
"debug": ".."as necessary) - [ ] Provide broker log excerpts
- [ ] Critical issue
Run with "debug": "cgrp,broker" and provide the logs, might give some insight into what is going on.
@edenhill Ok. I will add those configs. Can you tell me what those warning actually represents and in which scenarios we got this warning?
Thanks
The broker (or immediate load balancer) disconnected the client for some reason, usually because of idle timeout. https://github.com/edenhill/librdkafka/wiki/FAQ#why-am-i-seeing-receive-failed-disconnected
I have the same problem when i run my consumer application in ECS task, the application logs this error "%6|1629836068.968|rdkafka#consumer-1| [thrd:ssl://kafka-events:11101/12101]:ssl://kafka-events:11101/12101: Disconnected (after 684744ms in state UP)"
I cant achived resolve yet it
Disconnects are not necessarily a problem, the client will automatically reconnect as needed. Disconnects are typically triggered by broker or load balancer idle connection reapers.
In my case I have the consumer in a receive loop:
go func() {
for {
msg, err := consumer.ReadMessage(-1)
if err != nil {
log.Println("Error getting new messages", err)
continue
}
// Other message handling code
the consumer last logged:
Error getting new messages sasl_ssl://xxx.eu-west-1.aws.confluent.cloud:9092/3: Disconnected (after 345600074ms in state UP, 1 identical error(s) suppressed)
%4|1630313388.173|MAXPOLL|rdkafka#consumer-2| [thrd:main]: Application maximum poll interval (300000ms) exceeded by 350ms (adjust max.poll.interval.ms for long-running message processing): leaving group
and then no logs or retries to get new messages
In my case I have the consumer in a receive loop:
go func() { for { msg, err := consumer.ReadMessage(-1) if err != nil { log.Println("Error getting new messages", err) continue } // Other message handling codethe consumer last logged:
Error getting new messages sasl_ssl://xxx.eu-west-1.aws.confluent.cloud:9092/3: Disconnected (after 345600074ms in state UP, 1 identical error(s) suppressed) %4|1630313388.173|MAXPOLL|rdkafka#consumer-2| [thrd:main]: Application maximum poll interval (300000ms) exceeded by 350ms (adjust max.poll.interval.ms for long-running message processing): leaving groupand then no logs or retries to get new messages
hello, do you solved this problem, i have this question too. %6|1642348020.379|FAIL|rdkafka#consumer-1| [thrd:sasl_plaintext://{server:port}]: sasl_plaintext://{server:port}]: Disconnected (after 2ms in state UP, 8 identical error(s) suppressed) %3|1642348020.379|ERROR|rdkafka#consumer-1| [thrd:app]: rdkafka#consumer-1: sasl_plaintext://{server:port}]: Disconnected (after 2ms in state UP, 8 identical error(s) suppressed)
Disconnects are not necessarily a problem, the client will automatically reconnect as needed. Disconnects are typically triggered by broker or load balancer idle connection reapers.
Hi, sorry to bother you. But now i have the same question, and i have not solve it after two days, can you give me some advice. I'm using librdkafka consume client to consume messages, but i can't acquire any message from producers and recevied the errors: %6|1642348020.379|FAIL|rdkafka#consumer-1| [thrd:sasl_plaintext://{server:port}]: sasl_plaintext://{server:port}]: Disconnected (after 2ms in state UP, 8 identical error(s) suppressed) %3|1642348020.379|ERROR|rdkafka#consumer-1| [thrd:app]: rdkafka#consumer-1: sasl_plaintext://{server:port}]: Disconnected (after 2ms in state UP, 8 identical error(s) suppressed)
rdkafka version: 1.6.2RC system: centos 7, used debug option client configuration: { "bootstrap.servers": my server "group.id": my group name "enable.auto.commit": false "auto.offset.reset": "earliest" "security.protocol":"sasl_plaintext" "debug":"cgrp,protocol,broker" "sasl.mechanism": "sasl.username": "sasl.password": }
This is a on going issue, I have been able to simulate it using docker containers https://github.com/confluentinc/confluent-kafka-go/issues/747
@Leorfk did you find a solution to this issue? %6|1674804678.385|FAIL|rdkafka#consumer-4| [thrd:GroupCoordinator]: GroupCoordinator: ###.aws.confluent.cloud:9092: Disconnected (after 6283468ms in state UP)
Also running this in an ECS container
I am getting this issue daily now, the go application doesnt crash, it just hangs, and the consumer drops off the topic. I am running the latest version v2.0.2
hi @edenhill
I enabled logging "Cgrp, broker", I changed our cluster name to just kafka.eu-west-1.aws.confluent.cloud:9092) in the logs below
I included the logs a minute or so before the failure started, after this the golang process does not shut down, but just hangs indefinitely....
to me things seem to start failing after thus output, but I am hoping you will see something more...
1674849917.784|NODENAME|rdkafka#consumer-4| [thrd:main]: GroupCoordinator/30: Broker nodename changed from "b30-kafka.eu-west-1.aws.confluent.cloud:9092" to ""
here are the logs
1674849911.190|ASSIGNDONE|rdkafka#consumer-4| [thrd:main]: Group "cgroup.ravendb.loads": assignment operations done in join-state steady (rebalance rejoin=false) 1674849911.843|HEARTBEAT|rdkafka#consumer-4| [thrd:main]: GroupCoordinator/30: Heartbeat for group "cgroup.ravendb.loads" generation id 801 1674849914.075|TOPBRK|rdkafka#consumer-4| [thrd:sasl_ssl://b29-kafka.eu-west-1.aws.confluent.cloud:9092/29]: sasl_ssl://b29-kafka.eu-west-1.aws.confluent.cloud:9092/29: Topic stream.loads [0]: leaving broker (0 messages in xmitq, next broker sasl_ssl://b0-kafka.eu-west-1.aws.confluent.cloud:9092/0, rktp 0x7fd100007260) 1674849914.075|TOPBRK|rdkafka#consumer-4| [thrd:sasl_ssl://b0-kafka.eu-west-1.aws.confluent.cloud:9092/0]: sasl_ssl://b0-kafka.eu-west-1.aws.confluent.cloud:9092/0: Topic stream.loads [0]: joining broker (rktp 0x7fd100007260, 0 message(s) queued) 1674849914.075|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b0-kafka.eu-west-1.aws.confluent.cloud:9092/0]: sasl_ssl://b0-kafka.eu-west-1.aws.confluent.cloud:9092/0: Broker changed state INIT -> TRY_CONNECT 1674849914.076|CONNECT|rdkafka#consumer-4| [thrd:sasl_ssl://b0-kafka.eu-west-1.aws.confluent.cloud:9092/0]: sasl_ssl://b0-kafka.eu-west-1.aws.confluent.cloud:9092/0: broker in state TRY_CONNECT connecting 1674849914.076|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b0-kafka.eu-west-1.aws.confluent.cloud:9092/0]: sasl_ssl://b0-kafka.eu-west-1.aws.confluent.cloud:9092/0: Broker changed state TRY_CONNECT -> CONNECT 1674849914.078|CONNECT|rdkafka#consumer-4| [thrd:sasl_ssl://b0-kafka.eu-west-1.aws.confluent.cloud:9092/0]: sasl_ssl://b0-kafka.eu-west-1.aws.confluent.cloud:9092/0: Connecting to ipv4#34.246.147.64:9092 (sasl_ssl) with socket 419 1674849914.080|CONNECT|rdkafka#consumer-4| [thrd:sasl_ssl://b0-kafka.eu-west-1.aws.confluent.cloud:9092/0]: sasl_ssl://b0-kafka.eu-west-1.aws.confluent.cloud:9092/0: Connected to ipv4#34.246.147.64:9092 1674849914.080|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b0-kafka.eu-west-1.aws.confluent.cloud:9092/0]: sasl_ssl://b0-kafka.eu-west-1.aws.confluent.cloud:9092/0: Broker changed state CONNECT -> SSL_HANDSHAKE 1674849914.092|CONNECTED|rdkafka#consumer-4| [thrd:sasl_ssl://b0-kafka.eu-west-1.aws.confluent.cloud:9092/0]: sasl_ssl://b0-kafka.eu-west-1.aws.confluent.cloud:9092/0: Connected (#1) 1674849914.093|FEATURE|rdkafka#consumer-4| [thrd:sasl_ssl://b0-kafka.eu-west-1.aws.confluent.cloud:9092/0]: sasl_ssl://b0-kafka.eu-west-1.aws.confluent.cloud:9092/0: Updated enabled protocol features +ApiVersion to ApiVersion 1674849914.093|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b0-kafka.eu-west-1.aws.confluent.cloud:9092/0]: sasl_ssl://b0-kafka.eu-west-1.aws.confluent.cloud:9092/0: Broker changed state SSL_HANDSHAKE -> APIVERSION_QUERY 1674849914.095|FEATURE|rdkafka#consumer-4| [thrd:sasl_ssl://b0-kafka.eu-west-1.aws.confluent.cloud:9092/0]: sasl_ssl://b0-kafka.eu-west-1.aws.confluent.cloud:9092/0: Updated enabled protocol features to MsgVer1,ApiVersion,BrokerBalancedConsumer,ThrottleTime,Sasl,SaslHandshake,BrokerGroupCoordinator,LZ4,OffsetTime,MsgVer2,IdempotentProducer,ZSTD,SaslAuthReq 1674849914.095|AUTH|rdkafka#consumer-4| [thrd:sasl_ssl://b0-kafka.eu-west-1.aws.confluent.cloud:9092/0]: sasl_ssl://b0-kafka.eu-west-1.aws.confluent.cloud:9092/0: Auth in state APIVERSION_QUERY (handshake supported) 1674849914.095|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b0-kafka.eu-west-1.aws.confluent.cloud:9092/0]: sasl_ssl://b0-kafka.eu-west-1.aws.confluent.cloud:9092/0: Broker changed state APIVERSION_QUERY -> AUTH_HANDSHAKE 1674849914.098|SASLMECHS|rdkafka#consumer-4| [thrd:sasl_ssl://b0-kafka.eu-west-1.aws.confluent.cloud:9092/0]: sasl_ssl://b0-kafka.eu-west-1.aws.confluent.cloud:9092/0: Broker supported SASL mechanisms: PLAIN,OAUTHBEARER 1674849914.098|AUTH|rdkafka#consumer-4| [thrd:sasl_ssl://b0-kafka.eu-west-1.aws.confluent.cloud:9092/0]: sasl_ssl://b0-kafka.eu-west-1.aws.confluent.cloud:9092/0: Auth in state AUTH_HANDSHAKE (handshake supported) 1674849914.098|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b0-kafka.eu-west-1.aws.confluent.cloud:9092/0]: sasl_ssl://b0-kafka.eu-west-1.aws.confluent.cloud:9092/0: Broker changed state AUTH_HANDSHAKE -> AUTH_REQ 1674849914.193|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b0-kafka.eu-west-1.aws.confluent.cloud:9092/0]: sasl_ssl://b0-kafka.eu-west-1.aws.confluent.cloud:9092/0: Broker changed state AUTH_REQ -> UP 1674849914.843|HEARTBEAT|rdkafka#consumer-4| [thrd:main]: GroupCoordinator/30: Heartbeat for group "cgroup.ravendb.loads" generation id 801 1674849916.190|OFFSET|rdkafka#consumer-4| [thrd:main]: Topic stream.loads [0]: stored offset 41225, committed offset 41225: not including in commit 1674849916.190|DUMP|rdkafka#consumer-4| [thrd:main]: Assignment dump (started_cnt=1, wait_stop_cnt=0) 1674849916.190|DUMP_ALL|rdkafka#consumer-4| [thrd:main]: List with 1 partition(s): 1674849916.190|DUMP_ALL|rdkafka#consumer-4| [thrd:main]: stream.loads [0] offset STORED 1674849916.190|DUMP_PND|rdkafka#consumer-4| [thrd:main]: List with 0 partition(s): 1674849916.190|DUMP_QRY|rdkafka#consumer-4| [thrd:main]: List with 0 partition(s): 1674849916.190|DUMP_REM|rdkafka#consumer-4| [thrd:main]: List with 0 partition(s): 1674849916.190|ASSIGNDONE|rdkafka#consumer-4| [thrd:main]: Group "cgroup.ravendb.loads": assignment operations done in join-state steady (rebalance rejoin=false) 1674849917.450|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b29-kafka.eu-west-1.aws.confluent.cloud:9092/29]: sasl_ssl://b29-kafka.eu-west-1.aws.confluent.cloud:9092/29: Disconnected (after 23394203ms in state UP) (_TRANSPORT) %6|1674849917.450|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b29-kafka.eu-west-1.aws.confluent.cloud:9092/29]: sasl_ssl://b29-kafka.eu-west-1.aws.confluent.cloud:9092/29: Disconnected (after 23394203ms in state UP) 1674849917.450|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b29-kafka.eu-west-1.aws.confluent.cloud:9092/29]: sasl_ssl://b29-kafka.eu-west-1.aws.confluent.cloud:9092/29: Broker changed state UP -> DOWN 1674849917.450|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b29-kafka.eu-west-1.aws.confluent.cloud:9092/29]: sasl_ssl://b29-kafka.eu-west-1.aws.confluent.cloud:9092/29: Broker changed state DOWN -> INIT 1674849917.650|CLOSE|rdkafka#consumer-4| [thrd:app]: Closing consumer 1674849917.650|CGRPOP|rdkafka#consumer-4| [thrd:main]: Group "cgroup.ravendb.loads" received op TERMINATE in state up (join-state steady) 1674849917.650|CGRPTERM|rdkafka#consumer-4| [thrd:main]: Terminating group "cgroup.ravendb.loads" in state up with 1 partition(s) 1674849917.650|UNSUBSCRIBE|rdkafka#consumer-4| [thrd:main]: Group "cgroup.ravendb.loads": unsubscribe from current subscription of size 1 (leave group=true, has joined=true, rdkafka-7b0ee73e-def8-4251-a3e0-8520c81cd4bb, join-state steady) 1674849917.650|SUBSCRIPTION|rdkafka#consumer-4| [thrd:main]: Group "cgroup.ravendb.loads": clearing subscribed topics list (1) 1674849917.650|SUBSCRIPTION|rdkafka#consumer-4| [thrd:main]: Group "cgroup.ravendb.loads": effective subscription list changed from 1 to 0 topic(s): 1674849917.650|GRPLEADER|rdkafka#consumer-4| [thrd:main]: Group "cgroup.ravendb.loads": resetting group leader info: unsubscribe 1674849917.650|REBALANCE|rdkafka#consumer-4| [thrd:main]: Group "cgroup.ravendb.loads" initiating rebalance (EAGER) in state up (join-state steady) with 1 assigned partition(s): unsubscribe 1674849917.650|CGRPJOINSTATE|rdkafka#consumer-4| [thrd:main]: Group "cgroup.ravendb.loads" changed join state steady -> wait-unassign-call (state up) 1674849917.650|ASSIGN|rdkafka#consumer-4| [thrd:main]: Group "cgroup.ravendb.loads": delegating revoke of 1 partition(s) to application on queue rd_kafka_cgrp_new: unsubscribe 1674849917.650|PAUSE|rdkafka#consumer-4| [thrd:main]: Pausing fetchers for 1 assigned partition(s): rebalance 1674849917.650|ASSIGNMENT|rdkafka#consumer-4| [thrd:main]: Group "cgroup.ravendb.loads": clearing group assignment 1674849917.650|DUMP|rdkafka#consumer-4| [thrd:main]: Assignment dump (started_cnt=1, wait_stop_cnt=0) 1674849917.650|DUMP_ALL|rdkafka#consumer-4| [thrd:main]: List with 1 partition(s): 1674849917.651|DUMP_ALL|rdkafka#consumer-4| [thrd:main]: stream.loads [0] offset STORED 1674849917.651|DUMP_PND|rdkafka#consumer-4| [thrd:main]: List with 0 partition(s): 1674849917.651|DUMP_QRY|rdkafka#consumer-4| [thrd:main]: List with 0 partition(s): 1674849917.651|DUMP_REM|rdkafka#consumer-4| [thrd:main]: List with 0 partition(s): 1674849917.651|ASSIGNDONE|rdkafka#consumer-4| [thrd:main]: Group "cgroup.ravendb.loads": assignment operations done in join-state wait-unassign-call (rebalance rejoin=false) 1674849917.651|CGRPTERM|rdkafka#consumer-4| [thrd:main]: Group "cgroup.ravendb.loads": waiting for assign call, 1 toppar(s), 0 commit(s) (state up, join-state wait-unassign-call) before terminating 1674849917.651|CGRPTERM|rdkafka#consumer-4| [thrd:main]: Group "cgroup.ravendb.loads": waiting for assign call, 1 toppar(s), 0 commit(s) (state up, join-state wait-unassign-call) before terminating 1674849917.651|CGRPOP|rdkafka#consumer-4| [thrd:main]: Group "cgroup.ravendb.loads" received op GET_REBALANCE_PROTOCOL in state up (join-state wait-unassign-call) 1674849917.651|CGRPTERM|rdkafka#consumer-4| [thrd:main]: Group "cgroup.ravendb.loads": waiting for assign call, 1 toppar(s), 0 commit(s) (state up, join-state wait-unassign-call) before terminating 1674849917.651|CGRPOP|rdkafka#consumer-4| [thrd:main]: Group "cgroup.ravendb.loads" received op ASSIGN in state up (join-state wait-unassign-call) 1674849917.651|ASSIGN|rdkafka#consumer-4| [thrd:main]: Group "cgroup.ravendb.loads": Consumer is terminating: treating assign as unassign 1674849917.651|CLEARASSIGN|rdkafka#consumer-4| [thrd:main]: Clearing current assignment of 1 partition(s) 1674849917.651|CGRPJOINSTATE|rdkafka#consumer-4| [thrd:main]: Group "cgroup.ravendb.loads" changed join state wait-unassign-call -> wait-unassign-to-complete (state up) 1674849917.651|DUMP|rdkafka#consumer-4| [thrd:main]: Assignment dump (started_cnt=1, wait_stop_cnt=0) 1674849917.651|DUMP_ALL|rdkafka#consumer-4| [thrd:main]: List with 0 partition(s): 1674849917.651|DUMP_PND|rdkafka#consumer-4| [thrd:main]: List with 0 partition(s): 1674849917.651|DUMP_QRY|rdkafka#consumer-4| [thrd:main]: List with 0 partition(s): 1674849917.651|DUMP_REM|rdkafka#consumer-4| [thrd:main]: List with 1 partition(s): 1674849917.651|DUMP_REM|rdkafka#consumer-4| [thrd:main]: stream.loads [0] offset STORED 1674849917.651|REMOVE|rdkafka#consumer-4| [thrd:main]: Removing stream.loads [0] from assignment (started=true, pending=false, queried=false, stored offset=41225) 1674849917.651|REMOVE|rdkafka#consumer-4| [thrd:main]: Served 1 removed partition(s), with 1 offset(s) to commit 1674849917.651|COMMIT|rdkafka#consumer-4| [thrd:main]: GroupCoordinator/30: Committing offsets for 1 partition(s) with generation-id 801 in join-state wait-unassign-to-complete: unassigned partitions 1674849917.651|ASSIGNMENT|rdkafka#consumer-4| [thrd:main]: Current assignment of 0 partition(s) with 0 pending adds, 0 offset queries, 1 partitions awaiting stop and 1 offset commits in progress 1674849917.651|CGRPTERM|rdkafka#consumer-4| [thrd:main]: Group "cgroup.ravendb.loads": waiting for 1 toppar(s), assignment in progress, 1 commit(s) (state up, join-state wait-unassign-to-complete) before terminating 1674849917.651|CGRPTERM|rdkafka#consumer-4| [thrd:main]: Group "cgroup.ravendb.loads": waiting for 1 toppar(s), assignment in progress, 1 commit(s) (state up, join-state wait-unassign-to-complete) before terminating 1674849917.651|CGRPOP|rdkafka#consumer-4| [thrd:main]: Group "cgroup.ravendb.loads" received op PARTITION_LEAVE in state up (join-state wait-unassign-to-complete) for stream.loads [0] 1674849917.651|PARTDEL|rdkafka#consumer-4| [thrd:main]: Group "cgroup.ravendb.loads": delete stream.loads [0] 1674849917.651|CGRPTERM|rdkafka#consumer-4| [thrd:main]: Group "cgroup.ravendb.loads": waiting for 0 toppar(s), assignment in progress, 1 commit(s) (state up, join-state wait-unassign-to-complete) before terminating 1674849917.651|STOPSERVE|rdkafka#consumer-4| [thrd:main]: All partitions awaiting stop are now stopped: serving assignment 1674849917.651|DUMP|rdkafka#consumer-4| [thrd:main]: Assignment dump (started_cnt=0, wait_stop_cnt=0) 1674849917.651|DUMP_ALL|rdkafka#consumer-4| [thrd:main]: List with 0 partition(s): 1674849917.651|DUMP_PND|rdkafka#consumer-4| [thrd:main]: List with 0 partition(s): 1674849917.651|DUMP_QRY|rdkafka#consumer-4| [thrd:main]: List with 0 partition(s): 1674849917.652|DUMP_REM|rdkafka#consumer-4| [thrd:main]: List with 0 partition(s): 1674849917.652|ASSIGNMENT|rdkafka#consumer-4| [thrd:main]: Current assignment of 0 partition(s) with 0 pending adds, 0 offset queries, 0 partitions awaiting stop and 1 offset commits in progress 1674849917.652|CGRPTERM|rdkafka#consumer-4| [thrd:main]: Group "cgroup.ravendb.loads": waiting for 0 toppar(s), assignment in progress, 1 commit(s) (state up, join-state wait-unassign-to-complete) before terminating 1674849917.657|CGRPTERM|rdkafka#consumer-4| [thrd:main]: Group "cgroup.ravendb.loads": waiting for 0 toppar(s), assignment in progress, 1 commit(s) (state up, join-state wait-unassign-to-complete) before terminating 1674849917.657|CGRPTERM|rdkafka#consumer-4| [thrd:main]: Group "cgroup.ravendb.loads": waiting for 0 toppar(s), assignment in progress, 1 commit(s) (state up, join-state wait-unassign-to-complete) before terminating 1674849917.657|CGRPTERM|rdkafka#consumer-4| [thrd:main]: Group "cgroup.ravendb.loads": waiting for 0 toppar(s), assignment in progress, 1 commit(s) (state up, join-state wait-unassign-to-complete) before terminating 1674849917.657|CGRPTERM|rdkafka#consumer-4| [thrd:main]: Group "cgroup.ravendb.loads": waiting for 0 toppar(s), assignment in progress, 1 commit(s) (state up, join-state wait-unassign-to-complete) before terminating 1674849917.657|CGRPTERM|rdkafka#consumer-4| [thrd:main]: Group "cgroup.ravendb.loads": waiting for 0 toppar(s), assignment in progress, 1 commit(s) (state up, join-state wait-unassign-to-complete) before terminating 1674849917.657|CGRPTERM|rdkafka#consumer-4| [thrd:main]: Group "cgroup.ravendb.loads": waiting for 0 toppar(s), assignment in progress, 1 commit(s) (state up, join-state wait-unassign-to-complete) before terminating 1674849917.657|CGRPTERM|rdkafka#consumer-4| [thrd:main]: Group "cgroup.ravendb.loads": waiting for 0 toppar(s), assignment in progress, 1 commit(s) (state up, join-state wait-unassign-to-complete) before terminating 1674849917.657|CGRPTERM|rdkafka#consumer-4| [thrd:main]: Group "cgroup.ravendb.loads": waiting for 0 toppar(s), assignment in progress, 1 commit(s) (state up, join-state wait-unassign-to-complete) before terminating 1674849917.657|CGRPTERM|rdkafka#consumer-4| [thrd:main]: Group "cgroup.ravendb.loads": waiting for 0 toppar(s), assignment in progress, 1 commit(s) (state up, join-state wait-unassign-to-complete) before terminating 1674849917.657|CGRPTERM|rdkafka#consumer-4| [thrd:main]: Group "cgroup.ravendb.loads": waiting for 0 toppar(s), assignment in progress, 1 commit(s) (state up, join-state wait-unassign-to-complete) before terminating 1674849917.657|CGRPTERM|rdkafka#consumer-4| [thrd:main]: Group "cgroup.ravendb.loads": waiting for 0 toppar(s), assignment in progress, 1 commit(s) (state up, join-state wait-unassign-to-complete) before terminating 1674849917.657|CGRPTERM|rdkafka#consumer-4| [thrd:main]: Group "cgroup.ravendb.loads": waiting for 0 toppar(s), assignment in progress, 1 commit(s) (state up, join-state wait-unassign-to-complete) before terminating 1674849917.657|CGRPTERM|rdkafka#consumer-4| [thrd:main]: Group "cgroup.ravendb.loads": waiting for 0 toppar(s), assignment in progress, 1 commit(s) (state up, join-state wait-unassign-to-complete) before terminating 1674849917.757|COMMIT|rdkafka#consumer-4| [thrd:main]: GroupCoordinator/30: OffsetCommit for 1 partition(s) in join-state wait-unassign-to-complete: unassigned partitions: returned: Success 1674849917.757|DUMP|rdkafka#consumer-4| [thrd:main]: Assignment dump (started_cnt=0, wait_stop_cnt=0) 1674849917.757|DUMP_ALL|rdkafka#consumer-4| [thrd:main]: List with 0 partition(s): 1674849917.757|DUMP_PND|rdkafka#consumer-4| [thrd:main]: List with 0 partition(s): 1674849917.757|DUMP_QRY|rdkafka#consumer-4| [thrd:main]: List with 0 partition(s): 1674849917.757|DUMP_REM|rdkafka#consumer-4| [thrd:main]: List with 0 partition(s): 1674849917.757|ASSIGNDONE|rdkafka#consumer-4| [thrd:main]: Group "cgroup.ravendb.loads": assignment operations done in join-state wait-unassign-to-complete (rebalance rejoin=false) 1674849917.757|UNASSIGN|rdkafka#consumer-4| [thrd:main]: Group "cgroup.ravendb.loads": unassign done in state up (join-state wait-unassign-to-complete) 1674849917.757|MEMBERID|rdkafka#consumer-4| [thrd:main]: Group "cgroup.ravendb.loads": updating member id "rdkafka-7b0ee73e-def8-4251-a3e0-8520c81cd4bb" -> "" 1674849917.757|LEAVE|rdkafka#consumer-4| [thrd:main]: Group "cgroup.ravendb.loads": leave (in state up) 1674849917.757|NOREJOIN|rdkafka#consumer-4| [thrd:main]: Group "cgroup.ravendb.loads": Not rejoining group without an assignment: Unassignment done: no subscribed topics 1674849917.757|CGRPJOINSTATE|rdkafka#consumer-4| [thrd:main]: Group "cgroup.ravendb.loads" changed join state wait-unassign-to-complete -> init (state up) 1674849917.757|CGRPTERM|rdkafka#consumer-4| [thrd:main]: Group "cgroup.ravendb.loads": waiting for 0 toppar(s), 0 commit(s), wait-leave, (state up, join-state init) before terminating 1674849917.784|LEAVEGROUP|rdkafka#consumer-4| [thrd:main]: LeaveGroup response received in state up 1674849917.784|CGRPSTATE|rdkafka#consumer-4| [thrd:main]: Group "cgroup.ravendb.loads" changed state up -> term (join-state init) 1674849917.784|ASSIGNMENT|rdkafka#consumer-4| [thrd:main]: Group "cgroup.ravendb.loads": clearing group assignment 1674849917.784|COORDCLEAR|rdkafka#consumer-4| [thrd:main]: Group "cgroup.ravendb.loads" broker sasl_ssl://b30-kafka.eu-west-1.aws.confluent.cloud:9092/30 is no longer coordinator 1674849917.784|NODENAME|rdkafka#consumer-4| [thrd:main]: GroupCoordinator/30: Broker nodename changed from "b30-kafka.eu-west-1.aws.confluent.cloud:9092" to "" 1674849917.784|NODEID|rdkafka#consumer-4| [thrd:main]: GroupCoordinator/30: Broker nodeid changed from 30 to -1 1674849917.784|CGRPTERM|rdkafka#consumer-4| [thrd:main]: Consumer group sub-system terminated (will enqueue reply) 1674849917.784|DESTROY|rdkafka#consumer-4| [thrd:app]: Terminating instance (destroy flags none (0x0)) 1674849917.784|DESTROY|rdkafka#consumer-4| [thrd:main]: Destroy internal 1674849917.784|DESTROY|rdkafka#consumer-4| [thrd:main]: Removing all topics 1674849917.784|DESTROY|rdkafka#consumer-4| [thrd:main]: Sending TERMINATE to sasl_ssl://b21-kafka.eu-west-1.aws.confluent.cloud:9092/21 1674849917.784|TERM|rdkafka#consumer-4| [thrd:sasl_ssl://b21-kafka.eu-west-1.aws.confluent.cloud:9092/21]: sasl_ssl://b21-kafka.eu-west-1.aws.confluent.cloud:9092/21: Received TERMINATE op in state INIT: 3 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs 1674849917.784|TOPBRK|rdkafka#consumer-4| [thrd:sasl_ssl://b0-kafka.eu-west-1.aws.confluent.cloud:9092/0]: sasl_ssl://b0-kafka.eu-west-1.aws.confluent.cloud:9092/0: Topic stream.loads [0]: leaving broker (0 messages in xmitq, next broker (none), rktp 0x7fd100007260) 1674849917.785|TOPBRK|rdkafka#consumer-4| [thrd:sasl_ssl://b0-kafka.eu-west-1.aws.confluent.cloud:9092/0]: sasl_ssl://b0-kafka.eu-west-1.aws.confluent.cloud:9092/0: Topic stream.loads [0]: no next broker, failing 0 message(s) in partition queue 1674849917.785|TERMINATE|rdkafka#consumer-4| [thrd:sasl_ssl://b0-kafka.eu-west-1.aws.confluent.cloud:9092/0]: sasl_ssl://b0-kafka.eu-west-1.aws.confluent.cloud:9092/0: Handle is terminating in state UP: 5 refcnts (0x7fd100007cc8), 0 toppar(s), 0 active toppar(s), 0 outbufs, 1 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.784|FAIL|rdkafka#consumer-4| [thrd:GroupCoordinator]: GroupCoordinator: Closing connection due to nodename change (after 23397056ms in state UP) (_TRANSPORT) 1674849917.785|STATE|rdkafka#consumer-4| [thrd:GroupCoordinator]: GroupCoordinator: Broker changed state UP -> DOWN 1674849917.785|BRKTERM|rdkafka#consumer-4| [thrd:GroupCoordinator]: GroupCoordinator: terminating: broker still has 3 refcnt(s), 0 buffer(s), 0 partition(s) 1674849917.785|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b21-kafka.eu-west-1.aws.confluent.cloud:9092/21]: sasl_ssl://b21-kafka.eu-west-1.aws.confluent.cloud:9092/21: Client is terminating (after 23397097ms in state INIT) (_DESTROY) 1674849917.785|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b21-kafka.eu-west-1.aws.confluent.cloud:9092/21]: sasl_ssl://b21-kafka.eu-west-1.aws.confluent.cloud:9092/21: Broker changed state INIT -> DOWN 1674849917.785|BRKTERM|rdkafka#consumer-4| [thrd:sasl_ssl://b21-kafka.eu-west-1.aws.confluent.cloud:9092/21]: sasl_ssl://b21-kafka.eu-west-1.aws.confluent.cloud:9092/21: terminating: broker still has 3 refcnt(s), 0 buffer(s), 0 partition(s) 1674849917.785|TERMINATE|rdkafka#consumer-4| [thrd:sasl_ssl://b21-kafka.eu-west-1.aws.confluent.cloud:9092/21]: sasl_ssl://b21-kafka.eu-west-1.aws.confluent.cloud:9092/21: Handle is terminating in state DOWN: 2 refcnts (0x7fd10004c3d8), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.785|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b21-kafka.eu-west-1.aws.confluent.cloud:9092/21]: sasl_ssl://b21-kafka.eu-west-1.aws.confluent.cloud:9092/21: Broker changed state DOWN -> INIT 1674849917.785|TERMINATE|rdkafka#consumer-4| [thrd:GroupCoordinator]: GroupCoordinator: Handle is terminating in state DOWN: 3 refcnts (0x7fd11017f0c8), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.785|STATE|rdkafka#consumer-4| [thrd:GroupCoordinator]: GroupCoordinator: Broker changed state DOWN -> INIT 1674849917.785|DESTROY|rdkafka#consumer-4| [thrd:main]: Sending TERMINATE to sasl_ssl://b7-kafka.eu-west-1.aws.confluent.cloud:9092/7 1674849917.785|DESTROY|rdkafka#consumer-4| [thrd:main]: Sending TERMINATE to sasl_ssl://b42-kafka.eu-west-1.aws.confluent.cloud:9092/42 1674849917.785|TERM|rdkafka#consumer-4| [thrd:sasl_ssl://b7-kafka.eu-west-1.aws.confluent.cloud:9092/7]: sasl_ssl://b7-kafka.eu-west-1.aws.confluent.cloud:9092/7: Received TERMINATE op in state INIT: 2 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs 1674849917.785|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b7-kafka.eu-west-1.aws.confluent.cloud:9092/7]: sasl_ssl://b7-kafka.eu-west-1.aws.confluent.cloud:9092/7: Client is terminating (after 23397097ms in state INIT) (_DESTROY) 1674849917.785|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b7-kafka.eu-west-1.aws.confluent.cloud:9092/7]: sasl_ssl://b7-kafka.eu-west-1.aws.confluent.cloud:9092/7: Broker changed state INIT -> DOWN 1674849917.785|BRKTERM|rdkafka#consumer-4| [thrd:sasl_ssl://b7-kafka.eu-west-1.aws.confluent.cloud:9092/7]: sasl_ssl://b7-kafka.eu-west-1.aws.confluent.cloud:9092/7: terminating: broker still has 2 refcnt(s), 0 buffer(s), 0 partition(s) 1674849917.785|TERMINATE|rdkafka#consumer-4| [thrd:sasl_ssl://b7-kafka.eu-west-1.aws.confluent.cloud:9092/7]: sasl_ssl://b7-kafka.eu-west-1.aws.confluent.cloud:9092/7: Handle is terminating in state DOWN: 1 refcnts (0x7fd10004b508), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.785|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b7-kafka.eu-west-1.aws.confluent.cloud:9092/7]: sasl_ssl://b7-kafka.eu-west-1.aws.confluent.cloud:9092/7: Broker handle is terminating (after 0ms in state DOWN) (_DESTROY) 1674849917.785|TERM|rdkafka#consumer-4| [thrd:sasl_ssl://b42-kafka.eu-west-1.aws.confluent.cloud:9092/42]: sasl_ssl://b42-kafka.eu-west-1.aws.confluent.cloud:9092/42: Received TERMINATE op in state INIT: 3 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs 1674849917.785|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b42-kafka.eu-west-1.aws.confluent.cloud:9092/42]: sasl_ssl://b42-kafka.eu-west-1.aws.confluent.cloud:9092/42: Client is terminating (after 23397098ms in state INIT) (_DESTROY) 1674849917.785|TERMINATE|rdkafka#consumer-4| [thrd:sasl_ssl://b0-kafka.eu-west-1.aws.confluent.cloud:9092/0]: sasl_ssl://b0-kafka.eu-west-1.aws.confluent.cloud:9092/0: Handle is terminating in state UP: 5 refcnts (0x7fd100007cc8), 0 toppar(s), 0 active toppar(s), 0 outbufs, 1 waitresps, 0 retrybufs: failed 1 request(s) in retry+outbuf 1674849917.785|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b42-kafka.eu-west-1.aws.confluent.cloud:9092/42]: sasl_ssl://b42-kafka.eu-west-1.aws.confluent.cloud:9092/42: Broker changed state INIT -> DOWN 1674849917.785|BRKTERM|rdkafka#consumer-4| [thrd:sasl_ssl://b42-kafka.eu-west-1.aws.confluent.cloud:9092/42]: sasl_ssl://b42-kafka.eu-west-1.aws.confluent.cloud:9092/42: terminating: broker still has 2 refcnt(s), 0 buffer(s), 0 partition(s) 1674849917.785|TERMINATE|rdkafka#consumer-4| [thrd:sasl_ssl://b42-kafka.eu-west-1.aws.confluent.cloud:9092/42]: sasl_ssl://b42-kafka.eu-west-1.aws.confluent.cloud:9092/42: Handle is terminating in state DOWN: 1 refcnts (0x7fd10004a638), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.785|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b42-kafka.eu-west-1.aws.confluent.cloud:9092/42]: sasl_ssl://b42-kafka.eu-west-1.aws.confluent.cloud:9092/42: Broker handle is terminating (after 0ms in state DOWN) (_DESTROY) 1674849917.785|DESTROY|rdkafka#consumer-4| [thrd:main]: Sending TERMINATE to sasl_ssl://b47-kafka.eu-west-1.aws.confluent.cloud:9092/47 1674849917.785|DESTROY|rdkafka#consumer-4| [thrd:main]: Sending TERMINATE to sasl_ssl://b4-kafka.eu-west-1.aws.confluent.cloud:9092/4 1674849917.785|TERM|rdkafka#consumer-4| [thrd:sasl_ssl://b4-kafka.eu-west-1.aws.confluent.cloud:9092/4]: sasl_ssl://b4-kafka.eu-west-1.aws.confluent.cloud:9092/4: Received TERMINATE op in state INIT: 3 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs 1674849917.785|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b4-kafka.eu-west-1.aws.confluent.cloud:9092/4]: sasl_ssl://b4-kafka.eu-west-1.aws.confluent.cloud:9092/4: Client is terminating (after 23397102ms in state INIT) (_DESTROY) 1674849917.785|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b4-kafka.eu-west-1.aws.confluent.cloud:9092/4]: sasl_ssl://b4-kafka.eu-west-1.aws.confluent.cloud:9092/4: Broker changed state INIT -> DOWN 1674849917.785|BRKTERM|rdkafka#consumer-4| [thrd:sasl_ssl://b4-kafka.eu-west-1.aws.confluent.cloud:9092/4]: sasl_ssl://b4-kafka.eu-west-1.aws.confluent.cloud:9092/4: terminating: broker still has 3 refcnt(s), 0 buffer(s), 0 partition(s) 1674849917.785|TERM|rdkafka#consumer-4| [thrd:sasl_ssl://b47-kafka.eu-west-1.aws.confluent.cloud:9092/47]: sasl_ssl://b47-kafka.eu-west-1.aws.confluent.cloud:9092/47: Received TERMINATE op in state INIT: 2 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs 1674849917.785|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b47-kafka.eu-west-1.aws.confluent.cloud:9092/47]: sasl_ssl://b47-kafka.eu-west-1.aws.confluent.cloud:9092/47: Client is terminating (after 23397102ms in state INIT) (_DESTROY) 1674849917.785|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b47-kafka.eu-west-1.aws.confluent.cloud:9092/47]: sasl_ssl://b47-kafka.eu-west-1.aws.confluent.cloud:9092/47: Broker changed state INIT -> DOWN 1674849917.785|BRKTERM|rdkafka#consumer-4| [thrd:sasl_ssl://b47-kafka.eu-west-1.aws.confluent.cloud:9092/47]: sasl_ssl://b47-kafka.eu-west-1.aws.confluent.cloud:9092/47: terminating: broker still has 2 refcnt(s), 0 buffer(s), 0 partition(s) 1674849917.785|TERMINATE|rdkafka#consumer-4| [thrd:sasl_ssl://b47-kafka.eu-west-1.aws.confluent.cloud:9092/47]: sasl_ssl://b47-kafka.eu-west-1.aws.confluent.cloud:9092/47: Handle is terminating in state DOWN: 1 refcnts (0x7fd100049768), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.785|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b47-kafka.eu-west-1.aws.confluent.cloud:9092/47]: sasl_ssl://b47-kafka.eu-west-1.aws.confluent.cloud:9092/47: Broker handle is terminating (after 0ms in state DOWN) (_DESTROY) 1674849917.785|TERMINATE|rdkafka#consumer-4| [thrd:sasl_ssl://b4-kafka.eu-west-1.aws.confluent.cloud:9092/4]: sasl_ssl://b4-kafka.eu-west-1.aws.confluent.cloud:9092/4: Handle is terminating in state DOWN: 2 refcnts (0x7fd100048898), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.785|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b4-kafka.eu-west-1.aws.confluent.cloud:9092/4]: sasl_ssl://b4-kafka.eu-west-1.aws.confluent.cloud:9092/4: Broker changed state DOWN -> INIT 1674849917.786|DESTROY|rdkafka#consumer-4| [thrd:main]: Sending TERMINATE to sasl_ssl://b14-kafka.eu-west-1.aws.confluent.cloud:9092/14 1674849917.786|TERM|rdkafka#consumer-4| [thrd:sasl_ssl://b14-kafka.eu-west-1.aws.confluent.cloud:9092/14]: sasl_ssl://b14-kafka.eu-west-1.aws.confluent.cloud:9092/14: Received TERMINATE op in state INIT: 3 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs 1674849917.786|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b14-kafka.eu-west-1.aws.confluent.cloud:9092/14]: sasl_ssl://b14-kafka.eu-west-1.aws.confluent.cloud:9092/14: Client is terminating (after 23397103ms in state INIT) (_DESTROY) 1674849917.786|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b14-kafka.eu-west-1.aws.confluent.cloud:9092/14]: sasl_ssl://b14-kafka.eu-west-1.aws.confluent.cloud:9092/14: Broker changed state INIT -> DOWN 1674849917.786|BRKTERM|rdkafka#consumer-4| [thrd:sasl_ssl://b14-kafka.eu-west-1.aws.confluent.cloud:9092/14]: sasl_ssl://b14-kafka.eu-west-1.aws.confluent.cloud:9092/14: terminating: broker still has 3 refcnt(s), 0 buffer(s), 0 partition(s) 1674849917.786|TERMINATE|rdkafka#consumer-4| [thrd:sasl_ssl://b14-kafka.eu-west-1.aws.confluent.cloud:9092/14]: sasl_ssl://b14-kafka.eu-west-1.aws.confluent.cloud:9092/14: Handle is terminating in state DOWN: 2 refcnts (0x7fd1000479c8), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.786|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b14-kafka.eu-west-1.aws.confluent.cloud:9092/14]: sasl_ssl://b14-kafka.eu-west-1.aws.confluent.cloud:9092/14: Broker changed state DOWN -> INIT 1674849917.786|DESTROY|rdkafka#consumer-4| [thrd:main]: Sending TERMINATE to sasl_ssl://b19-kafka.eu-west-1.aws.confluent.cloud:9092/19 1674849917.786|DESTROY|rdkafka#consumer-4| [thrd:main]: Sending TERMINATE to sasl_ssl://b12-kafka.eu-west-1.aws.confluent.cloud:9092/12 1674849917.786|DESTROY|rdkafka#consumer-4| [thrd:main]: Sending TERMINATE to sasl_ssl://b2-kafka.eu-west-1.aws.confluent.cloud:9092/2 1674849917.786|DESTROY|rdkafka#consumer-4| [thrd:main]: Sending TERMINATE to sasl_ssl://b28-kafka.eu-west-1.aws.confluent.cloud:9092/28 1674849917.786|TERM|rdkafka#consumer-4| [thrd:sasl_ssl://b12-kafka.eu-west-1.aws.confluent.cloud:9092/12]: sasl_ssl://b12-kafka.eu-west-1.aws.confluent.cloud:9092/12: Received TERMINATE op in state INIT: 2 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs 1674849917.786|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b12-kafka.eu-west-1.aws.confluent.cloud:9092/12]: sasl_ssl://b12-kafka.eu-west-1.aws.confluent.cloud:9092/12: Client is terminating (after 23397103ms in state INIT) (_DESTROY) 1674849917.786|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b12-kafka.eu-west-1.aws.confluent.cloud:9092/12]: sasl_ssl://b12-kafka.eu-west-1.aws.confluent.cloud:9092/12: Broker changed state INIT -> DOWN 1674849917.786|BRKTERM|rdkafka#consumer-4| [thrd:sasl_ssl://b12-kafka.eu-west-1.aws.confluent.cloud:9092/12]: sasl_ssl://b12-kafka.eu-west-1.aws.confluent.cloud:9092/12: terminating: broker still has 2 refcnt(s), 0 buffer(s), 0 partition(s) 1674849917.786|TERMINATE|rdkafka#consumer-4| [thrd:sasl_ssl://b12-kafka.eu-west-1.aws.confluent.cloud:9092/12]: sasl_ssl://b12-kafka.eu-west-1.aws.confluent.cloud:9092/12: Handle is terminating in state DOWN: 1 refcnts (0x7fd100045c28), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.786|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b12-kafka.eu-west-1.aws.confluent.cloud:9092/12]: sasl_ssl://b12-kafka.eu-west-1.aws.confluent.cloud:9092/12: Broker handle is terminating (after 0ms in state DOWN) (_DESTROY) 1674849917.786|TERMINATE|rdkafka#consumer-4| [thrd:sasl_ssl://b21-kafka.eu-west-1.aws.confluent.cloud:9092/21]: sasl_ssl://b21-kafka.eu-west-1.aws.confluent.cloud:9092/21: Handle is terminating in state INIT: 1 refcnts (0x7fd10004c3d8), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.786|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b21-kafka.eu-west-1.aws.confluent.cloud:9092/21]: sasl_ssl://b21-kafka.eu-west-1.aws.confluent.cloud:9092/21: Broker handle is terminating (after 1ms in state INIT) (_DESTROY) 1674849917.786|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b21-kafka.eu-west-1.aws.confluent.cloud:9092/21]: sasl_ssl://b21-kafka.eu-west-1.aws.confluent.cloud:9092/21: Broker changed state INIT -> DOWN 1674849917.786|TERM|rdkafka#consumer-4| [thrd:sasl_ssl://b2-kafka.eu-west-1.aws.confluent.cloud:9092/2]: sasl_ssl://b2-kafka.eu-west-1.aws.confluent.cloud:9092/2: Received TERMINATE op in state INIT: 2 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs 1674849917.786|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b2-kafka.eu-west-1.aws.confluent.cloud:9092/2]: sasl_ssl://b2-kafka.eu-west-1.aws.confluent.cloud:9092/2: Client is terminating (after 23397104ms in state INIT) (_DESTROY) 1674849917.786|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b2-kafka.eu-west-1.aws.confluent.cloud:9092/2]: sasl_ssl://b2-kafka.eu-west-1.aws.confluent.cloud:9092/2: Broker changed state INIT -> DOWN 1674849917.786|BRKTERM|rdkafka#consumer-4| [thrd:sasl_ssl://b2-kafka.eu-west-1.aws.confluent.cloud:9092/2]: sasl_ssl://b2-kafka.eu-west-1.aws.confluent.cloud:9092/2: terminating: broker still has 2 refcnt(s), 0 buffer(s), 0 partition(s) 1674849917.786|TERMINATE|rdkafka#consumer-4| [thrd:sasl_ssl://b2-kafka.eu-west-1.aws.confluent.cloud:9092/2]: sasl_ssl://b2-kafka.eu-west-1.aws.confluent.cloud:9092/2: Handle is terminating in state DOWN: 1 refcnts (0x7fd100044d58), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.786|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b2-kafka.eu-west-1.aws.confluent.cloud:9092/2]: sasl_ssl://b2-kafka.eu-west-1.aws.confluent.cloud:9092/2: Broker handle is terminating (after 0ms in state DOWN) (_DESTROY) 1674849917.786|TERMINATE|rdkafka#consumer-4| [thrd:sasl_ssl://b0-kafka.eu-west-1.aws.confluent.cloud:9092/0]: sasl_ssl://b0-kafka.eu-west-1.aws.confluent.cloud:9092/0: Handle is terminating in state UP: 5 refcnts (0x7fd100007cc8), 0 toppar(s), 0 active toppar(s), 0 outbufs, 1 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.786|TERM|rdkafka#consumer-4| [thrd:sasl_ssl://b19-kafka.eu-west-1.aws.confluent.cloud:9092/19]: sasl_ssl://b19-kafka.eu-west-1.aws.confluent.cloud:9092/19: Received TERMINATE op in state INIT: 2 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs 1674849917.786|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b19-kafka.eu-west-1.aws.confluent.cloud:9092/19]: sasl_ssl://b19-kafka.eu-west-1.aws.confluent.cloud:9092/19: Client is terminating (after 23397104ms in state INIT) (_DESTROY) 1674849917.786|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b19-kafka.eu-west-1.aws.confluent.cloud:9092/19]: sasl_ssl://b19-kafka.eu-west-1.aws.confluent.cloud:9092/19: Broker changed state INIT -> DOWN 1674849917.786|BRKTERM|rdkafka#consumer-4| [thrd:sasl_ssl://b19-kafka.eu-west-1.aws.confluent.cloud:9092/19]: sasl_ssl://b19-kafka.eu-west-1.aws.confluent.cloud:9092/19: terminating: broker still has 2 refcnt(s), 0 buffer(s), 0 partition(s) 1674849917.786|TERMINATE|rdkafka#consumer-4| [thrd:sasl_ssl://b19-kafka.eu-west-1.aws.confluent.cloud:9092/19]: sasl_ssl://b19-kafka.eu-west-1.aws.confluent.cloud:9092/19: Handle is terminating in state DOWN: 1 refcnts (0x7fd100046af8), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.786|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b19-kafka.eu-west-1.aws.confluent.cloud:9092/19]: sasl_ssl://b19-kafka.eu-west-1.aws.confluent.cloud:9092/19: Broker handle is terminating (after 0ms in state DOWN) (_DESTROY) 1674849917.786|TERMINATE|rdkafka#consumer-4| [thrd:GroupCoordinator]: GroupCoordinator: Handle is terminating in state INIT: 3 refcnts (0x7fd11017f0c8), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.787|DESTROY|rdkafka#consumer-4| [thrd:main]: Sending TERMINATE to sasl_ssl://b23-kafka.eu-west-1.aws.confluent.cloud:9092/23 1674849917.787|TERM|rdkafka#consumer-4| [thrd:sasl_ssl://b28-kafka.eu-west-1.aws.confluent.cloud:9092/28]: sasl_ssl://b28-kafka.eu-west-1.aws.confluent.cloud:9092/28: Received TERMINATE op in state INIT: 2 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs 1674849917.787|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b28-kafka.eu-west-1.aws.confluent.cloud:9092/28]: sasl_ssl://b28-kafka.eu-west-1.aws.confluent.cloud:9092/28: Client is terminating (after 23397104ms in state INIT) (_DESTROY) 1674849917.787|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b28-kafka.eu-west-1.aws.confluent.cloud:9092/28]: sasl_ssl://b28-kafka.eu-west-1.aws.confluent.cloud:9092/28: Broker changed state INIT -> DOWN 1674849917.787|BRKTERM|rdkafka#consumer-4| [thrd:sasl_ssl://b28-kafka.eu-west-1.aws.confluent.cloud:9092/28]: sasl_ssl://b28-kafka.eu-west-1.aws.confluent.cloud:9092/28: terminating: broker still has 2 refcnt(s), 0 buffer(s), 0 partition(s) 1674849917.787|TERMINATE|rdkafka#consumer-4| [thrd:sasl_ssl://b4-kafka.eu-west-1.aws.confluent.cloud:9092/4]: sasl_ssl://b4-kafka.eu-west-1.aws.confluent.cloud:9092/4: Handle is terminating in state INIT: 1 refcnts (0x7fd100048898), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.787|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b4-kafka.eu-west-1.aws.confluent.cloud:9092/4]: sasl_ssl://b4-kafka.eu-west-1.aws.confluent.cloud:9092/4: Broker handle is terminating (after 1ms in state INIT) (_DESTROY) 1674849917.787|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b4-kafka.eu-west-1.aws.confluent.cloud:9092/4]: sasl_ssl://b4-kafka.eu-west-1.aws.confluent.cloud:9092/4: Broker changed state INIT -> DOWN 1674849917.787|TERMINATE|rdkafka#consumer-4| [thrd:sasl_ssl://b28-kafka.eu-west-1.aws.confluent.cloud:9092/28]: sasl_ssl://b28-kafka.eu-west-1.aws.confluent.cloud:9092/28: Handle is terminating in state DOWN: 1 refcnts (0x7fd100043e88), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.787|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b28-kafka.eu-west-1.aws.confluent.cloud:9092/28]: sasl_ssl://b28-kafka.eu-west-1.aws.confluent.cloud:9092/28: Broker handle is terminating (after 0ms in state DOWN) (_DESTROY) 1674849917.787|TERMINATE|rdkafka#consumer-4| [thrd:sasl_ssl://b14-kafka.eu-west-1.aws.confluent.cloud:9092/14]: sasl_ssl://b14-kafka.eu-west-1.aws.confluent.cloud:9092/14: Handle is terminating in state INIT: 1 refcnts (0x7fd1000479c8), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.787|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b14-kafka.eu-west-1.aws.confluent.cloud:9092/14]: sasl_ssl://b14-kafka.eu-west-1.aws.confluent.cloud:9092/14: Broker handle is terminating (after 1ms in state INIT) (_DESTROY) 1674849917.787|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b14-kafka.eu-west-1.aws.confluent.cloud:9092/14]: sasl_ssl://b14-kafka.eu-west-1.aws.confluent.cloud:9092/14: Broker changed state INIT -> DOWN 1674849917.787|TERM|rdkafka#consumer-4| [thrd:sasl_ssl://b23-kafka.eu-west-1.aws.confluent.cloud:9092/23]: sasl_ssl://b23-kafka.eu-west-1.aws.confluent.cloud:9092/23: Received TERMINATE op in state INIT: 3 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs 1674849917.787|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b23-kafka.eu-west-1.aws.confluent.cloud:9092/23]: sasl_ssl://b23-kafka.eu-west-1.aws.confluent.cloud:9092/23: Client is terminating (after 23397105ms in state INIT) (_DESTROY) 1674849917.787|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b23-kafka.eu-west-1.aws.confluent.cloud:9092/23]: sasl_ssl://b23-kafka.eu-west-1.aws.confluent.cloud:9092/23: Broker changed state INIT -> DOWN 1674849917.787|BRKTERM|rdkafka#consumer-4| [thrd:sasl_ssl://b23-kafka.eu-west-1.aws.confluent.cloud:9092/23]: sasl_ssl://b23-kafka.eu-west-1.aws.confluent.cloud:9092/23: terminating: broker still has 3 refcnt(s), 0 buffer(s), 0 partition(s) 1674849917.787|TERMINATE|rdkafka#consumer-4| [thrd:sasl_ssl://b23-kafka.eu-west-1.aws.confluent.cloud:9092/23]: sasl_ssl://b23-kafka.eu-west-1.aws.confluent.cloud:9092/23: Handle is terminating in state DOWN: 2 refcnts (0x7fd100042fb8), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.787|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b23-kafka.eu-west-1.aws.confluent.cloud:9092/23]: sasl_ssl://b23-kafka.eu-west-1.aws.confluent.cloud:9092/23: Broker changed state DOWN -> INIT 1674849917.787|DESTROY|rdkafka#consumer-4| [thrd:main]: Sending TERMINATE to sasl_ssl://b33-kafka.eu-west-1.aws.confluent.cloud:9092/33 1674849917.787|DESTROY|rdkafka#consumer-4| [thrd:main]: Sending TERMINATE to sasl_ssl://b38-kafka.eu-west-1.aws.confluent.cloud:9092/38 1674849917.787|DESTROY|rdkafka#consumer-4| [thrd:main]: Sending TERMINATE to sasl_ssl://b24-kafka.eu-west-1.aws.confluent.cloud:9092/24 1674849917.787|TERM|rdkafka#consumer-4| [thrd:sasl_ssl://b38-kafka.eu-west-1.aws.confluent.cloud:9092/38]: sasl_ssl://b38-kafka.eu-west-1.aws.confluent.cloud:9092/38: Received TERMINATE op in state INIT: 2 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs 1674849917.787|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b38-kafka.eu-west-1.aws.confluent.cloud:9092/38]: sasl_ssl://b38-kafka.eu-west-1.aws.confluent.cloud:9092/38: Client is terminating (after 23397105ms in state INIT) (_DESTROY) 1674849917.787|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b38-kafka.eu-west-1.aws.confluent.cloud:9092/38]: sasl_ssl://b38-kafka.eu-west-1.aws.confluent.cloud:9092/38: Broker changed state INIT -> DOWN 1674849917.787|BRKTERM|rdkafka#consumer-4| [thrd:sasl_ssl://b38-kafka.eu-west-1.aws.confluent.cloud:9092/38]: sasl_ssl://b38-kafka.eu-west-1.aws.confluent.cloud:9092/38: terminating: broker still has 2 refcnt(s), 0 buffer(s), 0 partition(s) 1674849917.787|TERMINATE|rdkafka#consumer-4| [thrd:sasl_ssl://b38-kafka.eu-west-1.aws.confluent.cloud:9092/38]: sasl_ssl://b38-kafka.eu-west-1.aws.confluent.cloud:9092/38: Handle is terminating in state DOWN: 1 refcnts (0x7fd100041218), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.787|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b38-kafka.eu-west-1.aws.confluent.cloud:9092/38]: sasl_ssl://b38-kafka.eu-west-1.aws.confluent.cloud:9092/38: Broker handle is terminating (after 0ms in state DOWN) (_DESTROY) 1674849917.787|TERM|rdkafka#consumer-4| [thrd:sasl_ssl://b33-kafka.eu-west-1.aws.confluent.cloud:9092/33]: sasl_ssl://b33-kafka.eu-west-1.aws.confluent.cloud:9092/33: Received TERMINATE op in state INIT: 2 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs 1674849917.789|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b33-kafka.eu-west-1.aws.confluent.cloud:9092/33]: sasl_ssl://b33-kafka.eu-west-1.aws.confluent.cloud:9092/33: Client is terminating (after 23397106ms in state INIT) (_DESTROY) 1674849917.789|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b33-kafka.eu-west-1.aws.confluent.cloud:9092/33]: sasl_ssl://b33-kafka.eu-west-1.aws.confluent.cloud:9092/33: Broker changed state INIT -> DOWN 1674849917.789|BRKTERM|rdkafka#consumer-4| [thrd:sasl_ssl://b33-kafka.eu-west-1.aws.confluent.cloud:9092/33]: sasl_ssl://b33-kafka.eu-west-1.aws.confluent.cloud:9092/33: terminating: broker still has 2 refcnt(s), 0 buffer(s), 0 partition(s) 1674849917.789|TERMINATE|rdkafka#consumer-4| [thrd:sasl_ssl://b33-kafka.eu-west-1.aws.confluent.cloud:9092/33]: sasl_ssl://b33-kafka.eu-west-1.aws.confluent.cloud:9092/33: Handle is terminating in state DOWN: 1 refcnts (0x7fd1000420e8), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.789|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b33-kafka.eu-west-1.aws.confluent.cloud:9092/33]: sasl_ssl://b33-kafka.eu-west-1.aws.confluent.cloud:9092/33: Broker handle is terminating (after 0ms in state DOWN) (_DESTROY) 1674849917.789|TERMINATE|rdkafka#consumer-4| [thrd:sasl_ssl://b23-kafka.eu-west-1.aws.confluent.cloud:9092/23]: sasl_ssl://b23-kafka.eu-west-1.aws.confluent.cloud:9092/23: Handle is terminating in state INIT: 1 refcnts (0x7fd100042fb8), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.789|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b23-kafka.eu-west-1.aws.confluent.cloud:9092/23]: sasl_ssl://b23-kafka.eu-west-1.aws.confluent.cloud:9092/23: Broker handle is terminating (after 1ms in state INIT) (_DESTROY) 1674849917.789|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b23-kafka.eu-west-1.aws.confluent.cloud:9092/23]: sasl_ssl://b23-kafka.eu-west-1.aws.confluent.cloud:9092/23: Broker changed state INIT -> DOWN 1674849917.789|TERMINATE|rdkafka#consumer-4| [thrd:sasl_ssl://b0-kafka.eu-west-1.aws.confluent.cloud:9092/0]: sasl_ssl://b0-kafka.eu-west-1.aws.confluent.cloud:9092/0: Handle is terminating in state UP: 5 refcnts (0x7fd100007cc8), 0 toppar(s), 0 active toppar(s), 0 outbufs, 1 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.789|TERMINATE|rdkafka#consumer-4| [thrd:GroupCoordinator]: GroupCoordinator: Handle is terminating in state INIT: 3 refcnts (0x7fd11017f0c8), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.789|DESTROY|rdkafka#consumer-4| [thrd:main]: Sending TERMINATE to sasl_ssl://b45-kafka.eu-west-1.aws.confluent.cloud:9092/45 1674849917.789|TERM|rdkafka#consumer-4| [thrd:sasl_ssl://b24-kafka.eu-west-1.aws.confluent.cloud:9092/24]: sasl_ssl://b24-kafka.eu-west-1.aws.confluent.cloud:9092/24: Received TERMINATE op in state INIT: 2 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs 1674849917.789|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b24-kafka.eu-west-1.aws.confluent.cloud:9092/24]: sasl_ssl://b24-kafka.eu-west-1.aws.confluent.cloud:9092/24: Client is terminating (after 23397107ms in state INIT) (_DESTROY) 1674849917.789|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b24-kafka.eu-west-1.aws.confluent.cloud:9092/24]: sasl_ssl://b24-kafka.eu-west-1.aws.confluent.cloud:9092/24: Broker changed state INIT -> DOWN 1674849917.789|BRKTERM|rdkafka#consumer-4| [thrd:sasl_ssl://b24-kafka.eu-west-1.aws.confluent.cloud:9092/24]: sasl_ssl://b24-kafka.eu-west-1.aws.confluent.cloud:9092/24: terminating: broker still has 2 refcnt(s), 0 buffer(s), 0 partition(s) 1674849917.789|TERMINATE|rdkafka#consumer-4| [thrd:sasl_ssl://b24-kafka.eu-west-1.aws.confluent.cloud:9092/24]: sasl_ssl://b24-kafka.eu-west-1.aws.confluent.cloud:9092/24: Handle is terminating in state DOWN: 1 refcnts (0x7fd100040348), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.789|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b24-kafka.eu-west-1.aws.confluent.cloud:9092/24]: sasl_ssl://b24-kafka.eu-west-1.aws.confluent.cloud:9092/24: Broker handle is terminating (after 0ms in state DOWN) (_DESTROY) 1674849917.789|DESTROY|rdkafka#consumer-4| [thrd:main]: Sending TERMINATE to sasl_ssl://b3-kafka.eu-west-1.aws.confluent.cloud:9092/3 1674849917.789|TERM|rdkafka#consumer-4| [thrd:sasl_ssl://b45-kafka.eu-west-1.aws.confluent.cloud:9092/45]: sasl_ssl://b45-kafka.eu-west-1.aws.confluent.cloud:9092/45: Received TERMINATE op in state INIT: 2 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs 1674849917.789|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b45-kafka.eu-west-1.aws.confluent.cloud:9092/45]: sasl_ssl://b45-kafka.eu-west-1.aws.confluent.cloud:9092/45: Client is terminating (after 23397107ms in state INIT) (_DESTROY) 1674849917.789|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b45-kafka.eu-west-1.aws.confluent.cloud:9092/45]: sasl_ssl://b45-kafka.eu-west-1.aws.confluent.cloud:9092/45: Broker changed state INIT -> DOWN 1674849917.789|BRKTERM|rdkafka#consumer-4| [thrd:sasl_ssl://b45-kafka.eu-west-1.aws.confluent.cloud:9092/45]: sasl_ssl://b45-kafka.eu-west-1.aws.confluent.cloud:9092/45: terminating: broker still has 2 refcnt(s), 0 buffer(s), 0 partition(s) 1674849917.789|TERMINATE|rdkafka#consumer-4| [thrd:sasl_ssl://b45-kafka.eu-west-1.aws.confluent.cloud:9092/45]: sasl_ssl://b45-kafka.eu-west-1.aws.confluent.cloud:9092/45: Handle is terminating in state DOWN: 1 refcnts (0x7fd10003f478), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.789|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b45-kafka.eu-west-1.aws.confluent.cloud:9092/45]: sasl_ssl://b45-kafka.eu-west-1.aws.confluent.cloud:9092/45: Broker handle is terminating (after 0ms in state DOWN) (_DESTROY) 1674849917.789|DESTROY|rdkafka#consumer-4| [thrd:main]: Sending TERMINATE to sasl_ssl://b17-kafka.eu-west-1.aws.confluent.cloud:9092/17 1674849917.789|TERM|rdkafka#consumer-4| [thrd:sasl_ssl://b3-kafka.eu-west-1.aws.confluent.cloud:9092/3]: sasl_ssl://b3-kafka.eu-west-1.aws.confluent.cloud:9092/3: Received TERMINATE op in state INIT: 2 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs 1674849917.789|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b3-kafka.eu-west-1.aws.confluent.cloud:9092/3]: sasl_ssl://b3-kafka.eu-west-1.aws.confluent.cloud:9092/3: Client is terminating (after 23397107ms in state INIT) (_DESTROY) 1674849917.789|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b3-kafka.eu-west-1.aws.confluent.cloud:9092/3]: sasl_ssl://b3-kafka.eu-west-1.aws.confluent.cloud:9092/3: Broker changed state INIT -> DOWN 1674849917.789|BRKTERM|rdkafka#consumer-4| [thrd:sasl_ssl://b3-kafka.eu-west-1.aws.confluent.cloud:9092/3]: sasl_ssl://b3-kafka.eu-west-1.aws.confluent.cloud:9092/3: terminating: broker still has 2 refcnt(s), 0 buffer(s), 0 partition(s) 1674849917.789|TERMINATE|rdkafka#consumer-4| [thrd:sasl_ssl://b3-kafka.eu-west-1.aws.confluent.cloud:9092/3]: sasl_ssl://b3-kafka.eu-west-1.aws.confluent.cloud:9092/3: Handle is terminating in state DOWN: 1 refcnts (0x7fd10003e5a8), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.789|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b3-kafka.eu-west-1.aws.confluent.cloud:9092/3]: sasl_ssl://b3-kafka.eu-west-1.aws.confluent.cloud:9092/3: Broker handle is terminating (after 0ms in state DOWN) (_DESTROY) 1674849917.789|DESTROY|rdkafka#consumer-4| [thrd:main]: Sending TERMINATE to sasl_ssl://b16-kafka.eu-west-1.aws.confluent.cloud:9092/16 1674849917.789|TERM|rdkafka#consumer-4| [thrd:sasl_ssl://b17-kafka.eu-west-1.aws.confluent.cloud:9092/17]: sasl_ssl://b17-kafka.eu-west-1.aws.confluent.cloud:9092/17: Received TERMINATE op in state INIT: 2 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs 1674849917.789|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b17-kafka.eu-west-1.aws.confluent.cloud:9092/17]: sasl_ssl://b17-kafka.eu-west-1.aws.confluent.cloud:9092/17: Client is terminating (after 23397108ms in state INIT) (_DESTROY) 1674849917.789|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b17-kafka.eu-west-1.aws.confluent.cloud:9092/17]: sasl_ssl://b17-kafka.eu-west-1.aws.confluent.cloud:9092/17: Broker changed state INIT -> DOWN 1674849917.789|BRKTERM|rdkafka#consumer-4| [thrd:sasl_ssl://b17-kafka.eu-west-1.aws.confluent.cloud:9092/17]: sasl_ssl://b17-kafka.eu-west-1.aws.confluent.cloud:9092/17: terminating: broker still has 2 refcnt(s), 0 buffer(s), 0 partition(s) 1674849917.789|TERMINATE|rdkafka#consumer-4| [thrd:sasl_ssl://b17-kafka.eu-west-1.aws.confluent.cloud:9092/17]: sasl_ssl://b17-kafka.eu-west-1.aws.confluent.cloud:9092/17: Handle is terminating in state DOWN: 1 refcnts (0x7fd10003d6d8), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.789|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b17-kafka.eu-west-1.aws.confluent.cloud:9092/17]: sasl_ssl://b17-kafka.eu-west-1.aws.confluent.cloud:9092/17: Broker handle is terminating (after 0ms in state DOWN) (_DESTROY) 1674849917.789|DESTROY|rdkafka#consumer-4| [thrd:main]: Sending TERMINATE to sasl_ssl://b37-kafka.eu-west-1.aws.confluent.cloud:9092/37 1674849917.789|TERM|rdkafka#consumer-4| [thrd:sasl_ssl://b16-kafka.eu-west-1.aws.confluent.cloud:9092/16]: sasl_ssl://b16-kafka.eu-west-1.aws.confluent.cloud:9092/16: Received TERMINATE op in state INIT: 2 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs 1674849917.789|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b16-kafka.eu-west-1.aws.confluent.cloud:9092/16]: sasl_ssl://b16-kafka.eu-west-1.aws.confluent.cloud:9092/16: Client is terminating (after 23397108ms in state INIT) (_DESTROY) 1674849917.789|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b16-kafka.eu-west-1.aws.confluent.cloud:9092/16]: sasl_ssl://b16-kafka.eu-west-1.aws.confluent.cloud:9092/16: Broker changed state INIT -> DOWN 1674849917.790|BRKTERM|rdkafka#consumer-4| [thrd:sasl_ssl://b16-kafka.eu-west-1.aws.confluent.cloud:9092/16]: sasl_ssl://b16-kafka.eu-west-1.aws.confluent.cloud:9092/16: terminating: broker still has 2 refcnt(s), 0 buffer(s), 0 partition(s) 1674849917.790|TERMINATE|rdkafka#consumer-4| [thrd:sasl_ssl://b16-kafka.eu-west-1.aws.confluent.cloud:9092/16]: sasl_ssl://b16-kafka.eu-west-1.aws.confluent.cloud:9092/16: Handle is terminating in state DOWN: 1 refcnts (0x7fd10003c808), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.790|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b16-kafka.eu-west-1.aws.confluent.cloud:9092/16]: sasl_ssl://b16-kafka.eu-west-1.aws.confluent.cloud:9092/16: Broker handle is terminating (after 0ms in state DOWN) (_DESTROY) 1674849917.791|TERMINATE|rdkafka#consumer-4| [thrd:sasl_ssl://b0-kafka.eu-west-1.aws.confluent.cloud:9092/0]: sasl_ssl://b0-kafka.eu-west-1.aws.confluent.cloud:9092/0: Handle is terminating in state UP: 5 refcnts (0x7fd100007cc8), 0 toppar(s), 0 active toppar(s), 0 outbufs, 1 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.791|TERMINATE|rdkafka#consumer-4| [thrd:GroupCoordinator]: GroupCoordinator: Handle is terminating in state INIT: 3 refcnts (0x7fd11017f0c8), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.791|DESTROY|rdkafka#consumer-4| [thrd:main]: Sending TERMINATE to sasl_ssl://b44-kafka.eu-west-1.aws.confluent.cloud:9092/44 1674849917.791|TERM|rdkafka#consumer-4| [thrd:sasl_ssl://b44-kafka.eu-west-1.aws.confluent.cloud:9092/44]: sasl_ssl://b44-kafka.eu-west-1.aws.confluent.cloud:9092/44: Received TERMINATE op in state INIT: 3 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs 1674849917.791|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b44-kafka.eu-west-1.aws.confluent.cloud:9092/44]: sasl_ssl://b44-kafka.eu-west-1.aws.confluent.cloud:9092/44: Client is terminating (after 23397109ms in state INIT) (_DESTROY) 1674849917.791|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b44-kafka.eu-west-1.aws.confluent.cloud:9092/44]: sasl_ssl://b44-kafka.eu-west-1.aws.confluent.cloud:9092/44: Broker changed state INIT -> DOWN 1674849917.791|BRKTERM|rdkafka#consumer-4| [thrd:sasl_ssl://b44-kafka.eu-west-1.aws.confluent.cloud:9092/44]: sasl_ssl://b44-kafka.eu-west-1.aws.confluent.cloud:9092/44: terminating: broker still has 3 refcnt(s), 0 buffer(s), 0 partition(s) 1674849917.791|TERMINATE|rdkafka#consumer-4| [thrd:sasl_ssl://b44-kafka.eu-west-1.aws.confluent.cloud:9092/44]: sasl_ssl://b44-kafka.eu-west-1.aws.confluent.cloud:9092/44: Handle is terminating in state DOWN: 2 refcnts (0x7fd10003aa68), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.791|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b44-kafka.eu-west-1.aws.confluent.cloud:9092/44]: sasl_ssl://b44-kafka.eu-west-1.aws.confluent.cloud:9092/44: Broker changed state DOWN -> INIT 1674849917.791|DESTROY|rdkafka#consumer-4| [thrd:main]: Sending TERMINATE to sasl_ssl://b36-kafka.eu-west-1.aws.confluent.cloud:9092/36 1674849917.791|TERM|rdkafka#consumer-4| [thrd:sasl_ssl://b36-kafka.eu-west-1.aws.confluent.cloud:9092/36]: sasl_ssl://b36-kafka.eu-west-1.aws.confluent.cloud:9092/36: Received TERMINATE op in state INIT: 3 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs 1674849917.791|TERM|rdkafka#consumer-4| [thrd:sasl_ssl://b37-kafka.eu-west-1.aws.confluent.cloud:9092/37]: sasl_ssl://b37-kafka.eu-west-1.aws.confluent.cloud:9092/37: Received TERMINATE op in state INIT: 2 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs 1674849917.791|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b37-kafka.eu-west-1.aws.confluent.cloud:9092/37]: sasl_ssl://b37-kafka.eu-west-1.aws.confluent.cloud:9092/37: Client is terminating (after 23397109ms in state INIT) (_DESTROY) 1674849917.791|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b37-kafka.eu-west-1.aws.confluent.cloud:9092/37]: sasl_ssl://b37-kafka.eu-west-1.aws.confluent.cloud:9092/37: Broker changed state INIT -> DOWN 1674849917.791|BRKTERM|rdkafka#consumer-4| [thrd:sasl_ssl://b37-kafka.eu-west-1.aws.confluent.cloud:9092/37]: sasl_ssl://b37-kafka.eu-west-1.aws.confluent.cloud:9092/37: terminating: broker still has 2 refcnt(s), 0 buffer(s), 0 partition(s) 1674849917.791|TERMINATE|rdkafka#consumer-4| [thrd:sasl_ssl://b37-kafka.eu-west-1.aws.confluent.cloud:9092/37]: sasl_ssl://b37-kafka.eu-west-1.aws.confluent.cloud:9092/37: Handle is terminating in state DOWN: 1 refcnts (0x7fd10003b938), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.791|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b37-kafka.eu-west-1.aws.confluent.cloud:9092/37]: sasl_ssl://b37-kafka.eu-west-1.aws.confluent.cloud:9092/37: Broker handle is terminating (after 0ms in state DOWN) (_DESTROY) 1674849917.791|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b36-kafka.eu-west-1.aws.confluent.cloud:9092/36]: sasl_ssl://b36-kafka.eu-west-1.aws.confluent.cloud:9092/36: Client is terminating (after 23397109ms in state INIT) (_DESTROY) 1674849917.791|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b36-kafka.eu-west-1.aws.confluent.cloud:9092/36]: sasl_ssl://b36-kafka.eu-west-1.aws.confluent.cloud:9092/36: Broker changed state INIT -> DOWN 1674849917.791|BRKTERM|rdkafka#consumer-4| [thrd:sasl_ssl://b36-kafka.eu-west-1.aws.confluent.cloud:9092/36]: sasl_ssl://b36-kafka.eu-west-1.aws.confluent.cloud:9092/36: terminating: broker still has 3 refcnt(s), 0 buffer(s), 0 partition(s) 1674849917.791|TERMINATE|rdkafka#consumer-4| [thrd:sasl_ssl://b36-kafka.eu-west-1.aws.confluent.cloud:9092/36]: sasl_ssl://b36-kafka.eu-west-1.aws.confluent.cloud:9092/36: Handle is terminating in state DOWN: 2 refcnts (0x7fd100039b98), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.791|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b36-kafka.eu-west-1.aws.confluent.cloud:9092/36]: sasl_ssl://b36-kafka.eu-west-1.aws.confluent.cloud:9092/36: Broker changed state DOWN -> INIT 1674849917.791|DESTROY|rdkafka#consumer-4| [thrd:main]: Sending TERMINATE to sasl_ssl://b26-kafka.eu-west-1.aws.confluent.cloud:9092/26 1674849917.791|DESTROY|rdkafka#consumer-4| [thrd:main]: Sending TERMINATE to sasl_ssl://b46-kafka.eu-west-1.aws.confluent.cloud:9092/46 1674849917.791|TERM|rdkafka#consumer-4| [thrd:sasl_ssl://b26-kafka.eu-west-1.aws.confluent.cloud:9092/26]: sasl_ssl://b26-kafka.eu-west-1.aws.confluent.cloud:9092/26: Received TERMINATE op in state INIT: 2 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs 1674849917.791|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b26-kafka.eu-west-1.aws.confluent.cloud:9092/26]: sasl_ssl://b26-kafka.eu-west-1.aws.confluent.cloud:9092/26: Client is terminating (after 23397110ms in state INIT) (_DESTROY) 1674849917.791|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b26-kafka.eu-west-1.aws.confluent.cloud:9092/26]: sasl_ssl://b26-kafka.eu-west-1.aws.confluent.cloud:9092/26: Broker changed state INIT -> DOWN 1674849917.791|BRKTERM|rdkafka#consumer-4| [thrd:sasl_ssl://b26-kafka.eu-west-1.aws.confluent.cloud:9092/26]: sasl_ssl://b26-kafka.eu-west-1.aws.confluent.cloud:9092/26: terminating: broker still has 2 refcnt(s), 0 buffer(s), 0 partition(s) 1674849917.791|TERMINATE|rdkafka#consumer-4| [thrd:sasl_ssl://b26-kafka.eu-west-1.aws.confluent.cloud:9092/26]: sasl_ssl://b26-kafka.eu-west-1.aws.confluent.cloud:9092/26: Handle is terminating in state DOWN: 1 refcnts (0x7fd100038cc8), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.791|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b26-kafka.eu-west-1.aws.confluent.cloud:9092/26]: sasl_ssl://b26-kafka.eu-west-1.aws.confluent.cloud:9092/26: Broker handle is terminating (after 0ms in state DOWN) (_DESTROY) 1674849917.791|TERM|rdkafka#consumer-4| [thrd:sasl_ssl://b46-kafka.eu-west-1.aws.confluent.cloud:9092/46]: sasl_ssl://b46-kafka.eu-west-1.aws.confluent.cloud:9092/46: Received TERMINATE op in state INIT: 3 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs 1674849917.791|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b46-kafka.eu-west-1.aws.confluent.cloud:9092/46]: sasl_ssl://b46-kafka.eu-west-1.aws.confluent.cloud:9092/46: Client is terminating (after 23397110ms in state INIT) (_DESTROY) 1674849917.791|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b46-kafka.eu-west-1.aws.confluent.cloud:9092/46]: sasl_ssl://b46-kafka.eu-west-1.aws.confluent.cloud:9092/46: Broker changed state INIT -> DOWN 1674849917.791|BRKTERM|rdkafka#consumer-4| [thrd:sasl_ssl://b46-kafka.eu-west-1.aws.confluent.cloud:9092/46]: sasl_ssl://b46-kafka.eu-west-1.aws.confluent.cloud:9092/46: terminating: broker still has 3 refcnt(s), 0 buffer(s), 0 partition(s) 1674849917.791|TERMINATE|rdkafka#consumer-4| [thrd:sasl_ssl://b46-kafka.eu-west-1.aws.confluent.cloud:9092/46]: sasl_ssl://b46-kafka.eu-west-1.aws.confluent.cloud:9092/46: Handle is terminating in state DOWN: 2 refcnts (0x7fd100037df8), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.796|TERMINATE|rdkafka#consumer-4| [thrd:sasl_ssl://b0-kafka.eu-west-1.aws.confluent.cloud:9092/0]: sasl_ssl://b0-kafka.eu-west-1.aws.confluent.cloud:9092/0: Handle is terminating in state UP: 5 refcnts (0x7fd100007cc8), 0 toppar(s), 0 active toppar(s), 0 outbufs, 1 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.796|TERMINATE|rdkafka#consumer-4| [thrd:sasl_ssl://b44-kafka.eu-west-1.aws.confluent.cloud:9092/44]: sasl_ssl://b44-kafka.eu-west-1.aws.confluent.cloud:9092/44: Handle is terminating in state INIT: 1 refcnts (0x7fd10003aa68), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.796|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b44-kafka.eu-west-1.aws.confluent.cloud:9092/44]: sasl_ssl://b44-kafka.eu-west-1.aws.confluent.cloud:9092/44: Broker handle is terminating (after 5ms in state INIT) (_DESTROY) 1674849917.796|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b44-kafka.eu-west-1.aws.confluent.cloud:9092/44]: sasl_ssl://b44-kafka.eu-west-1.aws.confluent.cloud:9092/44: Broker changed state INIT -> DOWN 1674849917.796|TERMINATE|rdkafka#consumer-4| [thrd:sasl_ssl://b36-kafka.eu-west-1.aws.confluent.cloud:9092/36]: sasl_ssl://b36-kafka.eu-west-1.aws.confluent.cloud:9092/36: Handle is terminating in state INIT: 1 refcnts (0x7fd100039b98), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.796|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b36-kafka.eu-west-1.aws.confluent.cloud:9092/36]: sasl_ssl://b36-kafka.eu-west-1.aws.confluent.cloud:9092/36: Broker handle is terminating (after 5ms in state INIT) (_DESTROY) 1674849917.796|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b36-kafka.eu-west-1.aws.confluent.cloud:9092/36]: sasl_ssl://b36-kafka.eu-west-1.aws.confluent.cloud:9092/36: Broker changed state INIT -> DOWN 1674849917.796|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b46-kafka.eu-west-1.aws.confluent.cloud:9092/46]: sasl_ssl://b46-kafka.eu-west-1.aws.confluent.cloud:9092/46: Broker changed state DOWN -> INIT 1674849917.796|TERMINATE|rdkafka#consumer-4| [thrd:GroupCoordinator]: GroupCoordinator: Handle is terminating in state INIT: 3 refcnts (0x7fd11017f0c8), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.796|DESTROY|rdkafka#consumer-4| [thrd:main]: Sending TERMINATE to sasl_ssl://b25-kafka.eu-west-1.aws.confluent.cloud:9092/25 1674849917.797|DESTROY|rdkafka#consumer-4| [thrd:main]: Sending TERMINATE to sasl_ssl://b35-kafka.eu-west-1.aws.confluent.cloud:9092/35 1674849917.797|TERM|rdkafka#consumer-4| [thrd:sasl_ssl://b25-kafka.eu-west-1.aws.confluent.cloud:9092/25]: sasl_ssl://b25-kafka.eu-west-1.aws.confluent.cloud:9092/25: Received TERMINATE op in state INIT: 2 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs 1674849917.797|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b25-kafka.eu-west-1.aws.confluent.cloud:9092/25]: sasl_ssl://b25-kafka.eu-west-1.aws.confluent.cloud:9092/25: Client is terminating (after 23397116ms in state INIT) (_DESTROY) 1674849917.797|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b25-kafka.eu-west-1.aws.confluent.cloud:9092/25]: sasl_ssl://b25-kafka.eu-west-1.aws.confluent.cloud:9092/25: Broker changed state INIT -> DOWN 1674849917.797|BRKTERM|rdkafka#consumer-4| [thrd:sasl_ssl://b25-kafka.eu-west-1.aws.confluent.cloud:9092/25]: sasl_ssl://b25-kafka.eu-west-1.aws.confluent.cloud:9092/25: terminating: broker still has 2 refcnt(s), 0 buffer(s), 0 partition(s) 1674849917.797|TERMINATE|rdkafka#consumer-4| [thrd:sasl_ssl://b25-kafka.eu-west-1.aws.confluent.cloud:9092/25]: sasl_ssl://b25-kafka.eu-west-1.aws.confluent.cloud:9092/25: Handle is terminating in state DOWN: 1 refcnts (0x7fd100036f28), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.797|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b25-kafka.eu-west-1.aws.confluent.cloud:9092/25]: sasl_ssl://b25-kafka.eu-west-1.aws.confluent.cloud:9092/25: Broker handle is terminating (after 0ms in state DOWN) (_DESTROY) 1674849917.797|TERM|rdkafka#consumer-4| [thrd:sasl_ssl://b35-kafka.eu-west-1.aws.confluent.cloud:9092/35]: sasl_ssl://b35-kafka.eu-west-1.aws.confluent.cloud:9092/35: Received TERMINATE op in state INIT: 3 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs 1674849917.797|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b35-kafka.eu-west-1.aws.confluent.cloud:9092/35]: sasl_ssl://b35-kafka.eu-west-1.aws.confluent.cloud:9092/35: Client is terminating (after 23397116ms in state INIT) (_DESTROY) 1674849917.797|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b35-kafka.eu-west-1.aws.confluent.cloud:9092/35]: sasl_ssl://b35-kafka.eu-west-1.aws.confluent.cloud:9092/35: Broker changed state INIT -> DOWN 1674849917.797|BRKTERM|rdkafka#consumer-4| [thrd:sasl_ssl://b35-kafka.eu-west-1.aws.confluent.cloud:9092/35]: sasl_ssl://b35-kafka.eu-west-1.aws.confluent.cloud:9092/35: terminating: broker still has 3 refcnt(s), 0 buffer(s), 0 partition(s) 1674849917.797|TERMINATE|rdkafka#consumer-4| [thrd:sasl_ssl://b35-kafka.eu-west-1.aws.confluent.cloud:9092/35]: sasl_ssl://b35-kafka.eu-west-1.aws.confluent.cloud:9092/35: Handle is terminating in state DOWN: 2 refcnts (0x7fd100036058), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.797|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b35-kafka.eu-west-1.aws.confluent.cloud:9092/35]: sasl_ssl://b35-kafka.eu-west-1.aws.confluent.cloud:9092/35: Broker changed state DOWN -> INIT 1674849917.797|DESTROY|rdkafka#consumer-4| [thrd:main]: Sending TERMINATE to sasl_ssl://b15-kafka.eu-west-1.aws.confluent.cloud:9092/15 1674849917.797|DESTROY|rdkafka#consumer-4| [thrd:main]: Sending TERMINATE to sasl_ssl://b5-kafka.eu-west-1.aws.confluent.cloud:9092/5 1674849917.797|DESTROY|rdkafka#consumer-4| [thrd:main]: Sending TERMINATE to sasl_ssl://b27-kafka.eu-west-1.aws.confluent.cloud:9092/27 1674849917.797|TERM|rdkafka#consumer-4| [thrd:sasl_ssl://b15-kafka.eu-west-1.aws.confluent.cloud:9092/15]: sasl_ssl://b15-kafka.eu-west-1.aws.confluent.cloud:9092/15: Received TERMINATE op in state INIT: 2 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs 1674849917.797|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b15-kafka.eu-west-1.aws.confluent.cloud:9092/15]: sasl_ssl://b15-kafka.eu-west-1.aws.confluent.cloud:9092/15: Client is terminating (after 23397116ms in state INIT) (_DESTROY) 1674849917.797|DESTROY|rdkafka#consumer-4| [thrd:main]: Sending TERMINATE to sasl_ssl://b41-kafka.eu-west-1.aws.confluent.cloud:9092/41 1674849917.797|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b15-kafka.eu-west-1.aws.confluent.cloud:9092/15]: sasl_ssl://b15-kafka.eu-west-1.aws.confluent.cloud:9092/15: Broker changed state INIT -> DOWN 1674849917.797|BRKTERM|rdkafka#consumer-4| [thrd:sasl_ssl://b15-kafka.eu-west-1.aws.confluent.cloud:9092/15]: sasl_ssl://b15-kafka.eu-west-1.aws.confluent.cloud:9092/15: terminating: broker still has 2 refcnt(s), 0 buffer(s), 0 partition(s) 1674849917.797|TERMINATE|rdkafka#consumer-4| [thrd:sasl_ssl://b15-kafka.eu-west-1.aws.confluent.cloud:9092/15]: sasl_ssl://b15-kafka.eu-west-1.aws.confluent.cloud:9092/15: Handle is terminating in state DOWN: 1 refcnts (0x7fd100035188), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.797|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b15-kafka.eu-west-1.aws.confluent.cloud:9092/15]: sasl_ssl://b15-kafka.eu-west-1.aws.confluent.cloud:9092/15: Broker handle is terminating (after 0ms in state DOWN) (_DESTROY) 1674849917.797|TERM|rdkafka#consumer-4| [thrd:sasl_ssl://b41-kafka.eu-west-1.aws.confluent.cloud:9092/41]: sasl_ssl://b41-kafka.eu-west-1.aws.confluent.cloud:9092/41: Received TERMINATE op in state INIT: 3 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs 1674849917.797|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b41-kafka.eu-west-1.aws.confluent.cloud:9092/41]: sasl_ssl://b41-kafka.eu-west-1.aws.confluent.cloud:9092/41: Client is terminating (after 23397116ms in state INIT) (_DESTROY) 1674849917.797|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b41-kafka.eu-west-1.aws.confluent.cloud:9092/41]: sasl_ssl://b41-kafka.eu-west-1.aws.confluent.cloud:9092/41: Broker changed state INIT -> DOWN 1674849917.797|BRKTERM|rdkafka#consumer-4| [thrd:sasl_ssl://b41-kafka.eu-west-1.aws.confluent.cloud:9092/41]: sasl_ssl://b41-kafka.eu-west-1.aws.confluent.cloud:9092/41: terminating: broker still has 3 refcnt(s), 0 buffer(s), 0 partition(s) 1674849917.797|TERMINATE|rdkafka#consumer-4| [thrd:sasl_ssl://b41-kafka.eu-west-1.aws.confluent.cloud:9092/41]: sasl_ssl://b41-kafka.eu-west-1.aws.confluent.cloud:9092/41: Handle is terminating in state DOWN: 2 refcnts (0x7fd100032518), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.797|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b41-kafka.eu-west-1.aws.confluent.cloud:9092/41]: sasl_ssl://b41-kafka.eu-west-1.aws.confluent.cloud:9092/41: Broker changed state DOWN -> INIT 1674849917.797|DESTROY|rdkafka#consumer-4| [thrd:main]: Sending TERMINATE to sasl_ssl://b6-kafka.eu-west-1.aws.confluent.cloud:9092/6 1674849917.797|DESTROY|rdkafka#consumer-4| [thrd:main]: Sending TERMINATE to sasl_ssl://b1-kafka.eu-west-1.aws.confluent.cloud:9092/1 1674849917.797|TERM|rdkafka#consumer-4| [thrd:sasl_ssl://b27-kafka.eu-west-1.aws.confluent.cloud:9092/27]: sasl_ssl://b27-kafka.eu-west-1.aws.confluent.cloud:9092/27: Received TERMINATE op in state INIT: 2 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs 1674849917.797|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b27-kafka.eu-west-1.aws.confluent.cloud:9092/27]: sasl_ssl://b27-kafka.eu-west-1.aws.confluent.cloud:9092/27: Client is terminating (after 23397116ms in state INIT) (_DESTROY) 1674849917.797|TERM|rdkafka#consumer-4| [thrd:sasl_ssl://b1-kafka.eu-west-1.aws.confluent.cloud:9092/1]: sasl_ssl://b1-kafka.eu-west-1.aws.confluent.cloud:9092/1: Received TERMINATE op in state INIT: 3 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs 1674849917.797|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b1-kafka.eu-west-1.aws.confluent.cloud:9092/1]: sasl_ssl://b1-kafka.eu-west-1.aws.confluent.cloud:9092/1: Client is terminating (after 23397117ms in state INIT) (_DESTROY) 1674849917.797|TERM|rdkafka#consumer-4| [thrd:sasl_ssl://b6-kafka.eu-west-1.aws.confluent.cloud:9092/6]: sasl_ssl://b6-kafka.eu-west-1.aws.confluent.cloud:9092/6: Received TERMINATE op in state INIT: 2 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs 1674849917.797|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b1-kafka.eu-west-1.aws.confluent.cloud:9092/1]: sasl_ssl://b1-kafka.eu-west-1.aws.confluent.cloud:9092/1: Broker changed state INIT -> DOWN 1674849917.797|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b6-kafka.eu-west-1.aws.confluent.cloud:9092/6]: sasl_ssl://b6-kafka.eu-west-1.aws.confluent.cloud:9092/6: Client is terminating (after 23397117ms in state INIT) (_DESTROY) 1674849917.797|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b27-kafka.eu-west-1.aws.confluent.cloud:9092/27]: sasl_ssl://b27-kafka.eu-west-1.aws.confluent.cloud:9092/27: Broker changed state INIT -> DOWN 1674849917.797|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b6-kafka.eu-west-1.aws.confluent.cloud:9092/6]: sasl_ssl://b6-kafka.eu-west-1.aws.confluent.cloud:9092/6: Broker changed state INIT -> DOWN 1674849917.797|BRKTERM|rdkafka#consumer-4| [thrd:sasl_ssl://b27-kafka.eu-west-1.aws.confluent.cloud:9092/27]: sasl_ssl://b27-kafka.eu-west-1.aws.confluent.cloud:9092/27: terminating: broker still has 2 refcnt(s), 0 buffer(s), 0 partition(s) 1674849917.797|BRKTERM|rdkafka#consumer-4| [thrd:sasl_ssl://b6-kafka.eu-west-1.aws.confluent.cloud:9092/6]: sasl_ssl://b6-kafka.eu-west-1.aws.confluent.cloud:9092/6: terminating: broker still has 2 refcnt(s), 0 buffer(s), 0 partition(s) 1674849917.797|TERMINATE|rdkafka#consumer-4| [thrd:sasl_ssl://b27-kafka.eu-west-1.aws.confluent.cloud:9092/27]: sasl_ssl://b27-kafka.eu-west-1.aws.confluent.cloud:9092/27: Handle is terminating in state DOWN: 1 refcnts (0x7fd1000333e8), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.797|TERMINATE|rdkafka#consumer-4| [thrd:sasl_ssl://b6-kafka.eu-west-1.aws.confluent.cloud:9092/6]: sasl_ssl://b6-kafka.eu-west-1.aws.confluent.cloud:9092/6: Handle is terminating in state DOWN: 1 refcnts (0x7fd100031648), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.797|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b27-kafka.eu-west-1.aws.confluent.cloud:9092/27]: sasl_ssl://b27-kafka.eu-west-1.aws.confluent.cloud:9092/27: Broker handle is terminating (after 0ms in state DOWN) (_DESTROY) 1674849917.797|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b6-kafka.eu-west-1.aws.confluent.cloud:9092/6]: sasl_ssl://b6-kafka.eu-west-1.aws.confluent.cloud:9092/6: Broker handle is terminating (after 0ms in state DOWN) (_DESTROY) 1674849917.797|BRKTERM|rdkafka#consumer-4| [thrd:sasl_ssl://b1-kafka.eu-west-1.aws.confluent.cloud:9092/1]: sasl_ssl://b1-kafka.eu-west-1.aws.confluent.cloud:9092/1: terminating: broker still has 3 refcnt(s), 0 buffer(s), 0 partition(s) 1674849917.797|TERM|rdkafka#consumer-4| [thrd:sasl_ssl://b5-kafka.eu-west-1.aws.confluent.cloud:9092/5]: sasl_ssl://b5-kafka.eu-west-1.aws.confluent.cloud:9092/5: Received TERMINATE op in state INIT: 2 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs 1674849917.797|TERMINATE|rdkafka#consumer-4| [thrd:sasl_ssl://b1-kafka.eu-west-1.aws.confluent.cloud:9092/1]: sasl_ssl://b1-kafka.eu-west-1.aws.confluent.cloud:9092/1: Handle is terminating in state DOWN: 2 refcnts (0x7fd100030778), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.797|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b1-kafka.eu-west-1.aws.confluent.cloud:9092/1]: sasl_ssl://b1-kafka.eu-west-1.aws.confluent.cloud:9092/1: Broker changed state DOWN -> INIT 1674849917.797|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b5-kafka.eu-west-1.aws.confluent.cloud:9092/5]: sasl_ssl://b5-kafka.eu-west-1.aws.confluent.cloud:9092/5: Client is terminating (after 23397116ms in state INIT) (_DESTROY) 1674849917.797|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b5-kafka.eu-west-1.aws.confluent.cloud:9092/5]: sasl_ssl://b5-kafka.eu-west-1.aws.confluent.cloud:9092/5: Broker changed state INIT -> DOWN 1674849917.797|BRKTERM|rdkafka#consumer-4| [thrd:sasl_ssl://b5-kafka.eu-west-1.aws.confluent.cloud:9092/5]: sasl_ssl://b5-kafka.eu-west-1.aws.confluent.cloud:9092/5: terminating: broker still has 2 refcnt(s), 0 buffer(s), 0 partition(s) 1674849917.797|TERMINATE|rdkafka#consumer-4| [thrd:sasl_ssl://b5-kafka.eu-west-1.aws.confluent.cloud:9092/5]: sasl_ssl://b5-kafka.eu-west-1.aws.confluent.cloud:9092/5: Handle is terminating in state DOWN: 1 refcnts (0x7fd1000342b8), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.797|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b5-kafka.eu-west-1.aws.confluent.cloud:9092/5]: sasl_ssl://b5-kafka.eu-west-1.aws.confluent.cloud:9092/5: Broker handle is terminating (after 0ms in state DOWN) (_DESTROY) 1674849917.797|DESTROY|rdkafka#consumer-4| [thrd:main]: Sending TERMINATE to sasl_ssl://b34-kafka.eu-west-1.aws.confluent.cloud:9092/34 1674849917.797|DESTROY|rdkafka#consumer-4| [thrd:main]: Sending TERMINATE to sasl_ssl://b29-kafka.eu-west-1.aws.confluent.cloud:9092/29 1674849917.797|TERM|rdkafka#consumer-4| [thrd:sasl_ssl://b34-kafka.eu-west-1.aws.confluent.cloud:9092/34]: sasl_ssl://b34-kafka.eu-west-1.aws.confluent.cloud:9092/34: Received TERMINATE op in state INIT: 2 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs 1674849917.797|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b34-kafka.eu-west-1.aws.confluent.cloud:9092/34]: sasl_ssl://b34-kafka.eu-west-1.aws.confluent.cloud:9092/34: Client is terminating (after 23397117ms in state INIT) (_DESTROY) 1674849917.797|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b34-kafka.eu-west-1.aws.confluent.cloud:9092/34]: sasl_ssl://b34-kafka.eu-west-1.aws.confluent.cloud:9092/34: Broker changed state INIT -> DOWN 1674849917.797|BRKTERM|rdkafka#consumer-4| [thrd:sasl_ssl://b34-kafka.eu-west-1.aws.confluent.cloud:9092/34]: sasl_ssl://b34-kafka.eu-west-1.aws.confluent.cloud:9092/34: terminating: broker still has 2 refcnt(s), 0 buffer(s), 0 partition(s) 1674849917.797|TERMINATE|rdkafka#consumer-4| [thrd:sasl_ssl://b34-kafka.eu-west-1.aws.confluent.cloud:9092/34]: sasl_ssl://b34-kafka.eu-west-1.aws.confluent.cloud:9092/34: Handle is terminating in state DOWN: 1 refcnts (0x7fd10002f718), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.797|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b34-kafka.eu-west-1.aws.confluent.cloud:9092/34]: sasl_ssl://b34-kafka.eu-west-1.aws.confluent.cloud:9092/34: Broker handle is terminating (after 0ms in state DOWN) (_DESTROY) 1674849917.797|TERM|rdkafka#consumer-4| [thrd:sasl_ssl://b29-kafka.eu-west-1.aws.confluent.cloud:9092/29]: sasl_ssl://b29-kafka.eu-west-1.aws.confluent.cloud:9092/29: Received TERMINATE op in state INIT: 3 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs 1674849917.797|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b29-kafka.eu-west-1.aws.confluent.cloud:9092/29]: sasl_ssl://b29-kafka.eu-west-1.aws.confluent.cloud:9092/29: Client is terminating (after 347ms in state INIT) (_DESTROY) 1674849917.797|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b29-kafka.eu-west-1.aws.confluent.cloud:9092/29]: sasl_ssl://b29-kafka.eu-west-1.aws.confluent.cloud:9092/29: Broker changed state INIT -> DOWN 1674849917.797|BRKTERM|rdkafka#consumer-4| [thrd:sasl_ssl://b29-kafka.eu-west-1.aws.confluent.cloud:9092/29]: sasl_ssl://b29-kafka.eu-west-1.aws.confluent.cloud:9092/29: terminating: broker still has 3 refcnt(s), 0 buffer(s), 0 partition(s) 1674849917.797|TERMINATE|rdkafka#consumer-4| [thrd:sasl_ssl://b29-kafka.eu-west-1.aws.confluent.cloud:9092/29]: sasl_ssl://b29-kafka.eu-west-1.aws.confluent.cloud:9092/29: Handle is terminating in state DOWN: 2 refcnts (0x7fd10002e848), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.797|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b29-kafka.eu-west-1.aws.confluent.cloud:9092/29]: sasl_ssl://b29-kafka.eu-west-1.aws.confluent.cloud:9092/29: Broker changed state DOWN -> INIT 1674849917.797|TERMINATE|rdkafka#consumer-4| [thrd:sasl_ssl://b0-kafka.eu-west-1.aws.confluent.cloud:9092/0]: sasl_ssl://b0-kafka.eu-west-1.aws.confluent.cloud:9092/0: Handle is terminating in state UP: 5 refcnts (0x7fd100007cc8), 0 toppar(s), 0 active toppar(s), 0 outbufs, 1 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.797|DESTROY|rdkafka#consumer-4| [thrd:main]: Sending TERMINATE to sasl_ssl://b43-kafka.eu-west-1.aws.confluent.cloud:9092/43 1674849917.797|TERMINATE|rdkafka#consumer-4| [thrd:sasl_ssl://b46-kafka.eu-west-1.aws.confluent.cloud:9092/46]: sasl_ssl://b46-kafka.eu-west-1.aws.confluent.cloud:9092/46: Handle is terminating in state INIT: 1 refcnts (0x7fd100037df8), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.798|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b46-kafka.eu-west-1.aws.confluent.cloud:9092/46]: sasl_ssl://b46-kafka.eu-west-1.aws.confluent.cloud:9092/46: Broker handle is terminating (after 1ms in state INIT) (_DESTROY) 1674849917.798|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b46-kafka.eu-west-1.aws.confluent.cloud:9092/46]: sasl_ssl://b46-kafka.eu-west-1.aws.confluent.cloud:9092/46: Broker changed state INIT -> DOWN 1674849917.797|TERMINATE|rdkafka#consumer-4| [thrd:GroupCoordinator]: GroupCoordinator: Handle is terminating in state INIT: 3 refcnts (0x7fd11017f0c8), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.798|DESTROY|rdkafka#consumer-4| [thrd:main]: Sending TERMINATE to sasl_ssl://b32-kafka.eu-west-1.aws.confluent.cloud:9092/32 1674849917.798|TERM|rdkafka#consumer-4| [thrd:sasl_ssl://b43-kafka.eu-west-1.aws.confluent.cloud:9092/43]: sasl_ssl://b43-kafka.eu-west-1.aws.confluent.cloud:9092/43: Received TERMINATE op in state INIT: 2 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs 1674849917.798|DESTROY|rdkafka#consumer-4| [thrd:main]: Sending TERMINATE to sasl_ssl://b8-kafka.eu-west-1.aws.confluent.cloud:9092/8 1674849917.798|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b43-kafka.eu-west-1.aws.confluent.cloud:9092/43]: sasl_ssl://b43-kafka.eu-west-1.aws.confluent.cloud:9092/43: Client is terminating (after 23397118ms in state INIT) (_DESTROY) 1674849917.798|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b43-kafka.eu-west-1.aws.confluent.cloud:9092/43]: sasl_ssl://b43-kafka.eu-west-1.aws.confluent.cloud:9092/43: Broker changed state INIT -> DOWN 1674849917.798|BRKTERM|rdkafka#consumer-4| [thrd:sasl_ssl://b43-kafka.eu-west-1.aws.confluent.cloud:9092/43]: sasl_ssl://b43-kafka.eu-west-1.aws.confluent.cloud:9092/43: terminating: broker still has 2 refcnt(s), 0 buffer(s), 0 partition(s) 1674849917.798|TERMINATE|rdkafka#consumer-4| [thrd:sasl_ssl://b43-kafka.eu-west-1.aws.confluent.cloud:9092/43]: sasl_ssl://b43-kafka.eu-west-1.aws.confluent.cloud:9092/43: Handle is terminating in state DOWN: 1 refcnts (0x7fd10002d978), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.798|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b43-kafka.eu-west-1.aws.confluent.cloud:9092/43]: sasl_ssl://b43-kafka.eu-west-1.aws.confluent.cloud:9092/43: Broker handle is terminating (after 0ms in state DOWN) (_DESTROY) 1674849917.798|TERMINATE|rdkafka#consumer-4| [thrd:sasl_ssl://b35-kafka.eu-west-1.aws.confluent.cloud:9092/35]: sasl_ssl://b35-kafka.eu-west-1.aws.confluent.cloud:9092/35: Handle is terminating in state INIT: 1 refcnts (0x7fd100036058), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.798|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b35-kafka.eu-west-1.aws.confluent.cloud:9092/35]: sasl_ssl://b35-kafka.eu-west-1.aws.confluent.cloud:9092/35: Broker handle is terminating (after 1ms in state INIT) (_DESTROY) 1674849917.798|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b35-kafka.eu-west-1.aws.confluent.cloud:9092/35]: sasl_ssl://b35-kafka.eu-west-1.aws.confluent.cloud:9092/35: Broker changed state INIT -> DOWN 1674849917.798|TERM|rdkafka#consumer-4| [thrd:sasl_ssl://b32-kafka.eu-west-1.aws.confluent.cloud:9092/32]: sasl_ssl://b32-kafka.eu-west-1.aws.confluent.cloud:9092/32: Received TERMINATE op in state INIT: 2 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs 1674849917.798|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b32-kafka.eu-west-1.aws.confluent.cloud:9092/32]: sasl_ssl://b32-kafka.eu-west-1.aws.confluent.cloud:9092/32: Client is terminating (after 23397118ms in state INIT) (_DESTROY) 1674849917.798|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b32-kafka.eu-west-1.aws.confluent.cloud:9092/32]: sasl_ssl://b32-kafka.eu-west-1.aws.confluent.cloud:9092/32: Broker changed state INIT -> DOWN 1674849917.798|BRKTERM|rdkafka#consumer-4| [thrd:sasl_ssl://b32-kafka.eu-west-1.aws.confluent.cloud:9092/32]: sasl_ssl://b32-kafka.eu-west-1.aws.confluent.cloud:9092/32: terminating: broker still has 2 refcnt(s), 0 buffer(s), 0 partition(s) 1674849917.798|TERMINATE|rdkafka#consumer-4| [thrd:sasl_ssl://b32-kafka.eu-west-1.aws.confluent.cloud:9092/32]: sasl_ssl://b32-kafka.eu-west-1.aws.confluent.cloud:9092/32: Handle is terminating in state DOWN: 1 refcnts (0x7fd10002caa8), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.798|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b32-kafka.eu-west-1.aws.confluent.cloud:9092/32]: sasl_ssl://b32-kafka.eu-west-1.aws.confluent.cloud:9092/32: Broker handle is terminating (after 0ms in state DOWN) (_DESTROY) 1674849917.798|TERMINATE|rdkafka#consumer-4| [thrd:sasl_ssl://b41-kafka.eu-west-1.aws.confluent.cloud:9092/41]: sasl_ssl://b41-kafka.eu-west-1.aws.confluent.cloud:9092/41: Handle is terminating in state INIT: 1 refcnts (0x7fd100032518), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.798|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b41-kafka.eu-west-1.aws.confluent.cloud:9092/41]: sasl_ssl://b41-kafka.eu-west-1.aws.confluent.cloud:9092/41: Broker handle is terminating (after 1ms in state INIT) (_DESTROY) 1674849917.798|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b41-kafka.eu-west-1.aws.confluent.cloud:9092/41]: sasl_ssl://b41-kafka.eu-west-1.aws.confluent.cloud:9092/41: Broker changed state INIT -> DOWN 1674849917.798|TERMINATE|rdkafka#consumer-4| [thrd:sasl_ssl://b1-kafka.eu-west-1.aws.confluent.cloud:9092/1]: sasl_ssl://b1-kafka.eu-west-1.aws.confluent.cloud:9092/1: Handle is terminating in state INIT: 1 refcnts (0x7fd100030778), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.798|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b1-kafka.eu-west-1.aws.confluent.cloud:9092/1]: sasl_ssl://b1-kafka.eu-west-1.aws.confluent.cloud:9092/1: Broker handle is terminating (after 1ms in state INIT) (_DESTROY) 1674849917.798|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b1-kafka.eu-west-1.aws.confluent.cloud:9092/1]: sasl_ssl://b1-kafka.eu-west-1.aws.confluent.cloud:9092/1: Broker changed state INIT -> DOWN 1674849917.798|TERM|rdkafka#consumer-4| [thrd:sasl_ssl://b8-kafka.eu-west-1.aws.confluent.cloud:9092/8]: sasl_ssl://b8-kafka.eu-west-1.aws.confluent.cloud:9092/8: Received TERMINATE op in state INIT: 3 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs 1674849917.798|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b8-kafka.eu-west-1.aws.confluent.cloud:9092/8]: sasl_ssl://b8-kafka.eu-west-1.aws.confluent.cloud:9092/8: Client is terminating (after 23397119ms in state INIT) (_DESTROY) 1674849917.798|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b8-kafka.eu-west-1.aws.confluent.cloud:9092/8]: sasl_ssl://b8-kafka.eu-west-1.aws.confluent.cloud:9092/8: Broker changed state INIT -> DOWN 1674849917.798|BRKTERM|rdkafka#consumer-4| [thrd:sasl_ssl://b8-kafka.eu-west-1.aws.confluent.cloud:9092/8]: sasl_ssl://b8-kafka.eu-west-1.aws.confluent.cloud:9092/8: terminating: broker still has 3 refcnt(s), 0 buffer(s), 0 partition(s) 1674849917.798|TERMINATE|rdkafka#consumer-4| [thrd:sasl_ssl://b8-kafka.eu-west-1.aws.confluent.cloud:9092/8]: sasl_ssl://b8-kafka.eu-west-1.aws.confluent.cloud:9092/8: Handle is terminating in state DOWN: 2 refcnts (0x7fd10002bbd8), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.798|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b8-kafka.eu-west-1.aws.confluent.cloud:9092/8]: sasl_ssl://b8-kafka.eu-west-1.aws.confluent.cloud:9092/8: Broker changed state DOWN -> INIT 1674849917.798|DESTROY|rdkafka#consumer-4| [thrd:main]: Sending TERMINATE to sasl_ssl://b22-kafka.eu-west-1.aws.confluent.cloud:9092/22 1674849917.798|TERM|rdkafka#consumer-4| [thrd:sasl_ssl://b22-kafka.eu-west-1.aws.confluent.cloud:9092/22]: sasl_ssl://b22-kafka.eu-west-1.aws.confluent.cloud:9092/22: Received TERMINATE op in state INIT: 3 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs 1674849917.798|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b22-kafka.eu-west-1.aws.confluent.cloud:9092/22]: sasl_ssl://b22-kafka.eu-west-1.aws.confluent.cloud:9092/22: Client is terminating (after 23397119ms in state INIT) (_DESTROY) 1674849917.798|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b22-kafka.eu-west-1.aws.confluent.cloud:9092/22]: sasl_ssl://b22-kafka.eu-west-1.aws.confluent.cloud:9092/22: Broker changed state INIT -> DOWN 1674849917.798|BRKTERM|rdkafka#consumer-4| [thrd:sasl_ssl://b22-kafka.eu-west-1.aws.confluent.cloud:9092/22]: sasl_ssl://b22-kafka.eu-west-1.aws.confluent.cloud:9092/22: terminating: broker still has 3 refcnt(s), 0 buffer(s), 0 partition(s) 1674849917.798|TERMINATE|rdkafka#consumer-4| [thrd:sasl_ssl://b22-kafka.eu-west-1.aws.confluent.cloud:9092/22]: sasl_ssl://b22-kafka.eu-west-1.aws.confluent.cloud:9092/22: Handle is terminating in state DOWN: 2 refcnts (0x7fd10002ad08), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.798|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b22-kafka.eu-west-1.aws.confluent.cloud:9092/22]: sasl_ssl://b22-kafka.eu-west-1.aws.confluent.cloud:9092/22: Broker changed state DOWN -> INIT 1674849917.798|TERMINATE|rdkafka#consumer-4| [thrd:sasl_ssl://b0-kafka.eu-west-1.aws.confluent.cloud:9092/0]: sasl_ssl://b0-kafka.eu-west-1.aws.confluent.cloud:9092/0: Handle is terminating in state UP: 5 refcnts (0x7fd100007cc8), 0 toppar(s), 0 active toppar(s), 0 outbufs, 1 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.798|TERMINATE|rdkafka#consumer-4| [thrd:sasl_ssl://b29-kafka.eu-west-1.aws.confluent.cloud:9092/29]: sasl_ssl://b29-kafka.eu-west-1.aws.confluent.cloud:9092/29: Handle is terminating in state INIT: 1 refcnts (0x7fd10002e848), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.799|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b29-kafka.eu-west-1.aws.confluent.cloud:9092/29]: sasl_ssl://b29-kafka.eu-west-1.aws.confluent.cloud:9092/29: Broker handle is terminating (after 1ms in state INIT) (_DESTROY) 1674849917.799|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b29-kafka.eu-west-1.aws.confluent.cloud:9092/29]: sasl_ssl://b29-kafka.eu-west-1.aws.confluent.cloud:9092/29: Broker changed state INIT -> DOWN 1674849917.799|DESTROY|rdkafka#consumer-4| [thrd:main]: Sending TERMINATE to sasl_ssl://b18-kafka.eu-west-1.aws.confluent.cloud:9092/18 1674849917.799|TERM|rdkafka#consumer-4| [thrd:sasl_ssl://b18-kafka.eu-west-1.aws.confluent.cloud:9092/18]: sasl_ssl://b18-kafka.eu-west-1.aws.confluent.cloud:9092/18: Received TERMINATE op in state INIT: 3 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs 1674849917.799|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b18-kafka.eu-west-1.aws.confluent.cloud:9092/18]: sasl_ssl://b18-kafka.eu-west-1.aws.confluent.cloud:9092/18: Client is terminating (after 23397119ms in state INIT) (_DESTROY) 1674849917.799|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b18-kafka.eu-west-1.aws.confluent.cloud:9092/18]: sasl_ssl://b18-kafka.eu-west-1.aws.confluent.cloud:9092/18: Broker changed state INIT -> DOWN 1674849917.799|BRKTERM|rdkafka#consumer-4| [thrd:sasl_ssl://b18-kafka.eu-west-1.aws.confluent.cloud:9092/18]: sasl_ssl://b18-kafka.eu-west-1.aws.confluent.cloud:9092/18: terminating: broker still has 3 refcnt(s), 0 buffer(s), 0 partition(s) 1674849917.799|TERMINATE|rdkafka#consumer-4| [thrd:sasl_ssl://b18-kafka.eu-west-1.aws.confluent.cloud:9092/18]: sasl_ssl://b18-kafka.eu-west-1.aws.confluent.cloud:9092/18: Handle is terminating in state DOWN: 2 refcnts (0x7fd100029e38), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.799|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b18-kafka.eu-west-1.aws.confluent.cloud:9092/18]: sasl_ssl://b18-kafka.eu-west-1.aws.confluent.cloud:9092/18: Broker changed state DOWN -> INIT 1674849917.799|TERMINATE|rdkafka#consumer-4| [thrd:GroupCoordinator]: GroupCoordinator: Handle is terminating in state INIT: 3 refcnts (0x7fd11017f0c8), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.799|DESTROY|rdkafka#consumer-4| [thrd:main]: Sending TERMINATE to sasl_ssl://b13-kafka.eu-west-1.aws.confluent.cloud:9092/13 1674849917.799|DESTROY|rdkafka#consumer-4| [thrd:main]: Sending TERMINATE to sasl_ssl://b31-kafka.eu-west-1.aws.confluent.cloud:9092/31 1674849917.799|TERM|rdkafka#consumer-4| [thrd:sasl_ssl://b13-kafka.eu-west-1.aws.confluent.cloud:9092/13]: sasl_ssl://b13-kafka.eu-west-1.aws.confluent.cloud:9092/13: Received TERMINATE op in state INIT: 2 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs 1674849917.799|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b13-kafka.eu-west-1.aws.confluent.cloud:9092/13]: sasl_ssl://b13-kafka.eu-west-1.aws.confluent.cloud:9092/13: Client is terminating (after 23397119ms in state INIT) (_DESTROY) 1674849917.799|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b13-kafka.eu-west-1.aws.confluent.cloud:9092/13]: sasl_ssl://b13-kafka.eu-west-1.aws.confluent.cloud:9092/13: Broker changed state INIT -> DOWN 1674849917.799|BRKTERM|rdkafka#consumer-4| [thrd:sasl_ssl://b13-kafka.eu-west-1.aws.confluent.cloud:9092/13]: sasl_ssl://b13-kafka.eu-west-1.aws.confluent.cloud:9092/13: terminating: broker still has 2 refcnt(s), 0 buffer(s), 0 partition(s) 1674849917.799|TERMINATE|rdkafka#consumer-4| [thrd:sasl_ssl://b13-kafka.eu-west-1.aws.confluent.cloud:9092/13]: sasl_ssl://b13-kafka.eu-west-1.aws.confluent.cloud:9092/13: Handle is terminating in state DOWN: 1 refcnts (0x7fd100028f88), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.799|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b13-kafka.eu-west-1.aws.confluent.cloud:9092/13]: sasl_ssl://b13-kafka.eu-west-1.aws.confluent.cloud:9092/13: Broker handle is terminating (after 0ms in state DOWN) (_DESTROY) 1674849917.799|DESTROY|rdkafka#consumer-4| [thrd:main]: Sending TERMINATE to sasl_ssl://b11-kafka.eu-west-1.aws.confluent.cloud:9092/11 1674849917.799|DESTROY|rdkafka#consumer-4| [thrd:main]: Sending TERMINATE to sasl_ssl://b9-kafka.eu-west-1.aws.confluent.cloud:9092/9 1674849917.799|TERM|rdkafka#consumer-4| [thrd:sasl_ssl://b11-kafka.eu-west-1.aws.confluent.cloud:9092/11]: sasl_ssl://b11-kafka.eu-west-1.aws.confluent.cloud:9092/11: Received TERMINATE op in state INIT: 2 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs 1674849917.799|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b11-kafka.eu-west-1.aws.confluent.cloud:9092/11]: sasl_ssl://b11-kafka.eu-west-1.aws.confluent.cloud:9092/11: Client is terminating (after 23397120ms in state INIT) (_DESTROY) 1674849917.799|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b11-kafka.eu-west-1.aws.confluent.cloud:9092/11]: sasl_ssl://b11-kafka.eu-west-1.aws.confluent.cloud:9092/11: Broker changed state INIT -> DOWN 1674849917.799|BRKTERM|rdkafka#consumer-4| [thrd:sasl_ssl://b11-kafka.eu-west-1.aws.confluent.cloud:9092/11]: sasl_ssl://b11-kafka.eu-west-1.aws.confluent.cloud:9092/11: terminating: broker still has 2 refcnt(s), 0 buffer(s), 0 partition(s) 1674849917.799|TERMINATE|rdkafka#consumer-4| [thrd:sasl_ssl://b11-kafka.eu-west-1.aws.confluent.cloud:9092/11]: sasl_ssl://b11-kafka.eu-west-1.aws.confluent.cloud:9092/11: Handle is terminating in state DOWN: 1 refcnts (0x7fd100027228), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.799|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b11-kafka.eu-west-1.aws.confluent.cloud:9092/11]: sasl_ssl://b11-kafka.eu-west-1.aws.confluent.cloud:9092/11: Broker handle is terminating (after 0ms in state DOWN) (_DESTROY) 1674849917.799|TERM|rdkafka#consumer-4| [thrd:sasl_ssl://b9-kafka.eu-west-1.aws.confluent.cloud:9092/9]: sasl_ssl://b9-kafka.eu-west-1.aws.confluent.cloud:9092/9: Received TERMINATE op in state INIT: 3 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs 1674849917.799|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b9-kafka.eu-west-1.aws.confluent.cloud:9092/9]: sasl_ssl://b9-kafka.eu-west-1.aws.confluent.cloud:9092/9: Client is terminating (after 23397120ms in state INIT) (_DESTROY) 1674849917.799|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b9-kafka.eu-west-1.aws.confluent.cloud:9092/9]: sasl_ssl://b9-kafka.eu-west-1.aws.confluent.cloud:9092/9: Broker changed state INIT -> DOWN 1674849917.799|BRKTERM|rdkafka#consumer-4| [thrd:sasl_ssl://b9-kafka.eu-west-1.aws.confluent.cloud:9092/9]: sasl_ssl://b9-kafka.eu-west-1.aws.confluent.cloud:9092/9: terminating: broker still has 3 refcnt(s), 0 buffer(s), 0 partition(s) 1674849917.799|TERMINATE|rdkafka#consumer-4| [thrd:sasl_ssl://b9-kafka.eu-west-1.aws.confluent.cloud:9092/9]: sasl_ssl://b9-kafka.eu-west-1.aws.confluent.cloud:9092/9: Handle is terminating in state DOWN: 2 refcnts (0x7fd100026378), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.799|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b9-kafka.eu-west-1.aws.confluent.cloud:9092/9]: sasl_ssl://b9-kafka.eu-west-1.aws.confluent.cloud:9092/9: Broker changed state DOWN -> INIT 1674849917.799|TERM|rdkafka#consumer-4| [thrd:sasl_ssl://b31-kafka.eu-west-1.aws.confluent.cloud:9092/31]: sasl_ssl://b31-kafka.eu-west-1.aws.confluent.cloud:9092/31: Received TERMINATE op in state INIT: 2 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs 1674849917.799|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b31-kafka.eu-west-1.aws.confluent.cloud:9092/31]: sasl_ssl://b31-kafka.eu-west-1.aws.confluent.cloud:9092/31: Client is terminating (after 23397120ms in state INIT) (_DESTROY) 1674849917.799|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b31-kafka.eu-west-1.aws.confluent.cloud:9092/31]: sasl_ssl://b31-kafka.eu-west-1.aws.confluent.cloud:9092/31: Broker changed state INIT -> DOWN 1674849917.799|BRKTERM|rdkafka#consumer-4| [thrd:sasl_ssl://b31-kafka.eu-west-1.aws.confluent.cloud:9092/31]: sasl_ssl://b31-kafka.eu-west-1.aws.confluent.cloud:9092/31: terminating: broker still has 2 refcnt(s), 0 buffer(s), 0 partition(s) 1674849917.799|TERMINATE|rdkafka#consumer-4| [thrd:sasl_ssl://b31-kafka.eu-west-1.aws.confluent.cloud:9092/31]: sasl_ssl://b31-kafka.eu-west-1.aws.confluent.cloud:9092/31: Handle is terminating in state DOWN: 1 refcnts (0x7fd1000280d8), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.799|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b31-kafka.eu-west-1.aws.confluent.cloud:9092/31]: sasl_ssl://b31-kafka.eu-west-1.aws.confluent.cloud:9092/31: Broker handle is terminating (after 0ms in state DOWN) (_DESTROY) 1674849917.799|DESTROY|rdkafka#consumer-4| [thrd:main]: Sending TERMINATE to sasl_ssl://b39-kafka.eu-west-1.aws.confluent.cloud:9092/39 1674849917.799|TERM|rdkafka#consumer-4| [thrd:sasl_ssl://b39-kafka.eu-west-1.aws.confluent.cloud:9092/39]: sasl_ssl://b39-kafka.eu-west-1.aws.confluent.cloud:9092/39: Received TERMINATE op in state INIT: 3 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs 1674849917.799|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b39-kafka.eu-west-1.aws.confluent.cloud:9092/39]: sasl_ssl://b39-kafka.eu-west-1.aws.confluent.cloud:9092/39: Client is terminating (after 23397120ms in state INIT) (_DESTROY) 1674849917.799|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b39-kafka.eu-west-1.aws.confluent.cloud:9092/39]: sasl_ssl://b39-kafka.eu-west-1.aws.confluent.cloud:9092/39: Broker changed state INIT -> DOWN 1674849917.799|BRKTERM|rdkafka#consumer-4| [thrd:sasl_ssl://b39-kafka.eu-west-1.aws.confluent.cloud:9092/39]: sasl_ssl://b39-kafka.eu-west-1.aws.confluent.cloud:9092/39: terminating: broker still has 3 refcnt(s), 0 buffer(s), 0 partition(s) 1674849917.799|TERMINATE|rdkafka#consumer-4| [thrd:sasl_ssl://b39-kafka.eu-west-1.aws.confluent.cloud:9092/39]: sasl_ssl://b39-kafka.eu-west-1.aws.confluent.cloud:9092/39: Handle is terminating in state DOWN: 2 refcnts (0x7fd1000254c8), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.799|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b39-kafka.eu-west-1.aws.confluent.cloud:9092/39]: sasl_ssl://b39-kafka.eu-west-1.aws.confluent.cloud:9092/39: Broker changed state DOWN -> INIT 1674849917.799|DESTROY|rdkafka#consumer-4| [thrd:main]: Sending TERMINATE to sasl_ssl://b30-kafka.eu-west-1.aws.confluent.cloud:9092/30 1674849917.799|DESTROY|rdkafka#consumer-4| [thrd:main]: Sending TERMINATE to sasl_ssl://b40-kafka.eu-west-1.aws.confluent.cloud:9092/40 1674849917.799|TERM|rdkafka#consumer-4| [thrd:sasl_ssl://b30-kafka.eu-west-1.aws.confluent.cloud:9092/30]: sasl_ssl://b30-kafka.eu-west-1.aws.confluent.cloud:9092/30: Received TERMINATE op in state INIT: 2 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs 1674849917.799|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b30-kafka.eu-west-1.aws.confluent.cloud:9092/30]: sasl_ssl://b30-kafka.eu-west-1.aws.confluent.cloud:9092/30: Client is terminating (after 23397121ms in state INIT) (_DESTROY) 1674849917.799|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b30-kafka.eu-west-1.aws.confluent.cloud:9092/30]: sasl_ssl://b30-kafka.eu-west-1.aws.confluent.cloud:9092/30: Broker changed state INIT -> DOWN 1674849917.799|BRKTERM|rdkafka#consumer-4| [thrd:sasl_ssl://b30-kafka.eu-west-1.aws.confluent.cloud:9092/30]: sasl_ssl://b30-kafka.eu-west-1.aws.confluent.cloud:9092/30: terminating: broker still has 2 refcnt(s), 0 buffer(s), 0 partition(s) 1674849917.799|TERMINATE|rdkafka#consumer-4| [thrd:sasl_ssl://b30-kafka.eu-west-1.aws.confluent.cloud:9092/30]: sasl_ssl://b30-kafka.eu-west-1.aws.confluent.cloud:9092/30: Handle is terminating in state DOWN: 1 refcnts (0x7fd1000246e8), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.799|TERMINATE|rdkafka#consumer-4| [thrd:sasl_ssl://b8-kafka.eu-west-1.aws.confluent.cloud:9092/8]: sasl_ssl://b8-kafka.eu-west-1.aws.confluent.cloud:9092/8: Handle is terminating in state INIT: 1 refcnts (0x7fd10002bbd8), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.799|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b30-kafka.eu-west-1.aws.confluent.cloud:9092/30]: sasl_ssl://b30-kafka.eu-west-1.aws.confluent.cloud:9092/30: Broker handle is terminating (after 0ms in state DOWN) (_DESTROY) 1674849917.799|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b8-kafka.eu-west-1.aws.confluent.cloud:9092/8]: sasl_ssl://b8-kafka.eu-west-1.aws.confluent.cloud:9092/8: Broker handle is terminating (after 1ms in state INIT) (_DESTROY) 1674849917.799|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b8-kafka.eu-west-1.aws.confluent.cloud:9092/8]: sasl_ssl://b8-kafka.eu-west-1.aws.confluent.cloud:9092/8: Broker changed state INIT -> DOWN 1674849917.799|TERM|rdkafka#consumer-4| [thrd:sasl_ssl://b40-kafka.eu-west-1.aws.confluent.cloud:9092/40]: sasl_ssl://b40-kafka.eu-west-1.aws.confluent.cloud:9092/40: Received TERMINATE op in state INIT: 3 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs 1674849917.799|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b40-kafka.eu-west-1.aws.confluent.cloud:9092/40]: sasl_ssl://b40-kafka.eu-west-1.aws.confluent.cloud:9092/40: Client is terminating (after 23397121ms in state INIT) (_DESTROY) 1674849917.799|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b40-kafka.eu-west-1.aws.confluent.cloud:9092/40]: sasl_ssl://b40-kafka.eu-west-1.aws.confluent.cloud:9092/40: Broker changed state INIT -> DOWN 1674849917.799|BRKTERM|rdkafka#consumer-4| [thrd:sasl_ssl://b40-kafka.eu-west-1.aws.confluent.cloud:9092/40]: sasl_ssl://b40-kafka.eu-west-1.aws.confluent.cloud:9092/40: terminating: broker still has 3 refcnt(s), 0 buffer(s), 0 partition(s) 1674849917.799|TERMINATE|rdkafka#consumer-4| [thrd:sasl_ssl://b40-kafka.eu-west-1.aws.confluent.cloud:9092/40]: sasl_ssl://b40-kafka.eu-west-1.aws.confluent.cloud:9092/40: Handle is terminating in state DOWN: 2 refcnts (0x7fd1000239c8), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.799|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b40-kafka.eu-west-1.aws.confluent.cloud:9092/40]: sasl_ssl://b40-kafka.eu-west-1.aws.confluent.cloud:9092/40: Broker changed state DOWN -> INIT 1674849917.799|DESTROY|rdkafka#consumer-4| [thrd:main]: Sending TERMINATE to sasl_ssl://b20-kafka.eu-west-1.aws.confluent.cloud:9092/20 1674849917.800|TERM|rdkafka#consumer-4| [thrd:sasl_ssl://b20-kafka.eu-west-1.aws.confluent.cloud:9092/20]: sasl_ssl://b20-kafka.eu-west-1.aws.confluent.cloud:9092/20: Received TERMINATE op in state INIT: 3 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs 1674849917.800|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b20-kafka.eu-west-1.aws.confluent.cloud:9092/20]: sasl_ssl://b20-kafka.eu-west-1.aws.confluent.cloud:9092/20: Client is terminating (after 23397121ms in state INIT) (_DESTROY) 1674849917.800|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b20-kafka.eu-west-1.aws.confluent.cloud:9092/20]: sasl_ssl://b20-kafka.eu-west-1.aws.confluent.cloud:9092/20: Broker changed state INIT -> DOWN 1674849917.800|BRKTERM|rdkafka#consumer-4| [thrd:sasl_ssl://b20-kafka.eu-west-1.aws.confluent.cloud:9092/20]: sasl_ssl://b20-kafka.eu-west-1.aws.confluent.cloud:9092/20: terminating: broker still has 3 refcnt(s), 0 buffer(s), 0 partition(s) 1674849917.800|TERMINATE|rdkafka#consumer-4| [thrd:sasl_ssl://b20-kafka.eu-west-1.aws.confluent.cloud:9092/20]: sasl_ssl://b20-kafka.eu-west-1.aws.confluent.cloud:9092/20: Handle is terminating in state DOWN: 2 refcnts (0x7fd100009698), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.800|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b20-kafka.eu-west-1.aws.confluent.cloud:9092/20]: sasl_ssl://b20-kafka.eu-west-1.aws.confluent.cloud:9092/20: Broker changed state DOWN -> INIT 1674849917.800|TERMINATE|rdkafka#consumer-4| [thrd:sasl_ssl://b0-kafka.eu-west-1.aws.confluent.cloud:9092/0]: sasl_ssl://b0-kafka.eu-west-1.aws.confluent.cloud:9092/0: Handle is terminating in state UP: 5 refcnts (0x7fd100007cc8), 0 toppar(s), 0 active toppar(s), 0 outbufs, 1 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.800|TERMINATE|rdkafka#consumer-4| [thrd:sasl_ssl://b22-kafka.eu-west-1.aws.confluent.cloud:9092/22]: sasl_ssl://b22-kafka.eu-west-1.aws.confluent.cloud:9092/22: Handle is terminating in state INIT: 1 refcnts (0x7fd10002ad08), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.800|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b22-kafka.eu-west-1.aws.confluent.cloud:9092/22]: sasl_ssl://b22-kafka.eu-west-1.aws.confluent.cloud:9092/22: Broker handle is terminating (after 1ms in state INIT) (_DESTROY) 1674849917.800|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b22-kafka.eu-west-1.aws.confluent.cloud:9092/22]: sasl_ssl://b22-kafka.eu-west-1.aws.confluent.cloud:9092/22: Broker changed state INIT -> DOWN 1674849917.800|DESTROY|rdkafka#consumer-4| [thrd:main]: Sending TERMINATE to sasl_ssl://b10-kafka.eu-west-1.aws.confluent.cloud:9092/10 1674849917.800|TERM|rdkafka#consumer-4| [thrd:sasl_ssl://b10-kafka.eu-west-1.aws.confluent.cloud:9092/10]: sasl_ssl://b10-kafka.eu-west-1.aws.confluent.cloud:9092/10: Received TERMINATE op in state INIT: 3 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs 1674849917.800|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b10-kafka.eu-west-1.aws.confluent.cloud:9092/10]: sasl_ssl://b10-kafka.eu-west-1.aws.confluent.cloud:9092/10: Client is terminating (after 23397121ms in state INIT) (_DESTROY) 1674849917.800|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b10-kafka.eu-west-1.aws.confluent.cloud:9092/10]: sasl_ssl://b10-kafka.eu-west-1.aws.confluent.cloud:9092/10: Broker changed state INIT -> DOWN 1674849917.800|BRKTERM|rdkafka#consumer-4| [thrd:sasl_ssl://b10-kafka.eu-west-1.aws.confluent.cloud:9092/10]: sasl_ssl://b10-kafka.eu-west-1.aws.confluent.cloud:9092/10: terminating: broker still has 3 refcnt(s), 0 buffer(s), 0 partition(s) 1674849917.800|TERMINATE|rdkafka#consumer-4| [thrd:sasl_ssl://b10-kafka.eu-west-1.aws.confluent.cloud:9092/10]: sasl_ssl://b10-kafka.eu-west-1.aws.confluent.cloud:9092/10: Handle is terminating in state DOWN: 2 refcnts (0x7fd1000088b8), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.800|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b10-kafka.eu-west-1.aws.confluent.cloud:9092/10]: sasl_ssl://b10-kafka.eu-west-1.aws.confluent.cloud:9092/10: Broker changed state DOWN -> INIT 1674849917.800|DESTROY|rdkafka#consumer-4| [thrd:main]: Sending TERMINATE to sasl_ssl://b0-kafka.eu-west-1.aws.confluent.cloud:9092/0 1674849917.800|TERM|rdkafka#consumer-4| [thrd:sasl_ssl://b0-kafka.eu-west-1.aws.confluent.cloud:9092/0]: sasl_ssl://b0-kafka.eu-west-1.aws.confluent.cloud:9092/0: Received TERMINATE op in state UP: 5 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 1 waitresps, 0 retrybufs 1674849917.800|TERMINATE|rdkafka#consumer-4| [thrd:sasl_ssl://b18-kafka.eu-west-1.aws.confluent.cloud:9092/18]: sasl_ssl://b18-kafka.eu-west-1.aws.confluent.cloud:9092/18: Handle is terminating in state INIT: 1 refcnts (0x7fd100029e38), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.800|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b18-kafka.eu-west-1.aws.confluent.cloud:9092/18]: sasl_ssl://b18-kafka.eu-west-1.aws.confluent.cloud:9092/18: Broker handle is terminating (after 1ms in state INIT) (_DESTROY) 1674849917.800|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b18-kafka.eu-west-1.aws.confluent.cloud:9092/18]: sasl_ssl://b18-kafka.eu-west-1.aws.confluent.cloud:9092/18: Broker changed state INIT -> DOWN 1674849917.800|TERMINATE|rdkafka#consumer-4| [thrd:GroupCoordinator]: GroupCoordinator: Handle is terminating in state INIT: 3 refcnts (0x7fd11017f0c8), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.800|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b0-kafka.eu-west-1.aws.confluent.cloud:9092/0]: sasl_ssl://b0-kafka.eu-west-1.aws.confluent.cloud:9092/0: Client is terminating (after 3607ms in state UP) (_DESTROY) 1674849917.800|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b0-kafka.eu-west-1.aws.confluent.cloud:9092/0]: sasl_ssl://b0-kafka.eu-west-1.aws.confluent.cloud:9092/0: Broker changed state UP -> DOWN 1674849917.800|BRKTERM|rdkafka#consumer-4| [thrd:sasl_ssl://b0-kafka.eu-west-1.aws.confluent.cloud:9092/0]: sasl_ssl://b0-kafka.eu-west-1.aws.confluent.cloud:9092/0: terminating: broker still has 3 refcnt(s), 0 buffer(s), 0 partition(s) 1674849917.800|TERMINATE|rdkafka#consumer-4| [thrd:sasl_ssl://b0-kafka.eu-west-1.aws.confluent.cloud:9092/0]: sasl_ssl://b0-kafka.eu-west-1.aws.confluent.cloud:9092/0: Handle is terminating in state DOWN: 2 refcnts (0x7fd100007cc8), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.800|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b0-kafka.eu-west-1.aws.confluent.cloud:9092/0]: sasl_ssl://b0-kafka.eu-west-1.aws.confluent.cloud:9092/0: Broker changed state DOWN -> INIT 1674849917.800|DESTROY|rdkafka#consumer-4| [thrd:main]: Sending TERMINATE to sasl_ssl://kafka.eu-west-1.aws.confluent.cloud:9092/bootstrap 1674849917.800|DESTROY|rdkafka#consumer-4| [thrd:main]: Sending TERMINATE to GroupCoordinator 1674849917.800|TERM|rdkafka#consumer-4| [thrd:sasl_ssl://kafka.eu-west-1.aws.confluent.cloud:9092/bootstr]: sasl_ssl://kafka.eu-west-1.aws.confluent.cloud:9092/bootstrap: Received TERMINATE op in state UP: 2 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs 1674849917.800|TERM|rdkafka#consumer-4| [thrd:GroupCoordinator]: GroupCoordinator: Received TERMINATE op in state INIT: 3 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs 1674849917.800|FAIL|rdkafka#consumer-4| [thrd:GroupCoordinator]: GroupCoordinator: Client is terminating (after 15ms in state INIT) (_DESTROY) 1674849917.800|STATE|rdkafka#consumer-4| [thrd:GroupCoordinator]: GroupCoordinator: Broker changed state INIT -> DOWN 1674849917.800|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://kafka.eu-west-1.aws.confluent.cloud:9092/bootstr]: sasl_ssl://kafka.eu-west-1.aws.confluent.cloud:9092/bootstrap: Client is terminating (after 23397130ms in state UP) (_DESTROY) 1674849917.800|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://kafka.eu-west-1.aws.confluent.cloud:9092/bootstr]: sasl_ssl://kafka.eu-west-1.aws.confluent.cloud:9092/bootstrap: Broker changed state UP -> DOWN 1674849917.800|BRKTERM|rdkafka#consumer-4| [thrd:sasl_ssl://kafka.eu-west-1.aws.confluent.cloud:9092/bootstr]: sasl_ssl://kafka.eu-west-1.aws.confluent.cloud:9092/bootstrap: terminating: broker still has 2 refcnt(s), 0 buffer(s), 0 partition(s) 1674849917.800|TERMINATE|rdkafka#consumer-4| [thrd:sasl_ssl://kafka.eu-west-1.aws.confluent.cloud:9092/bootstr]: sasl_ssl://kafka.eu-west-1.aws.confluent.cloud:9092/bootstrap: Handle is terminating in state DOWN: 1 refcnts (0x7fd110180db8), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.800|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://kafka.eu-west-1.aws.confluent.cloud:9092/bootstr]: sasl_ssl://kafka.eu-west-1.aws.confluent.cloud:9092/bootstrap: Broker handle is terminating (after 0ms in state DOWN) (_DESTROY) 1674849917.800|TERMINATE|rdkafka#consumer-4| [thrd:sasl_ssl://b9-kafka.eu-west-1.aws.confluent.cloud:9092/9]: sasl_ssl://b9-kafka.eu-west-1.aws.confluent.cloud:9092/9: Handle is terminating in state INIT: 1 refcnts (0x7fd100026378), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.800|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b9-kafka.eu-west-1.aws.confluent.cloud:9092/9]: sasl_ssl://b9-kafka.eu-west-1.aws.confluent.cloud:9092/9: Broker handle is terminating (after 1ms in state INIT) (_DESTROY) 1674849917.800|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b9-kafka.eu-west-1.aws.confluent.cloud:9092/9]: sasl_ssl://b9-kafka.eu-west-1.aws.confluent.cloud:9092/9: Broker changed state INIT -> DOWN 1674849917.800|BRKTERM|rdkafka#consumer-4| [thrd:GroupCoordinator]: GroupCoordinator: terminating: broker still has 3 refcnt(s), 0 buffer(s), 0 partition(s) 1674849917.800|TERMINATE|rdkafka#consumer-4| [thrd:GroupCoordinator]: GroupCoordinator: Handle is terminating in state DOWN: 2 refcnts (0x7fd11017f0c8), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.800|STATE|rdkafka#consumer-4| [thrd:GroupCoordinator]: GroupCoordinator: Broker changed state DOWN -> INIT 1674849917.800|TERMINATE|rdkafka#consumer-4| [thrd:sasl_ssl://b39-kafka.eu-west-1.aws.confluent.cloud:9092/39]: sasl_ssl://b39-kafka.eu-west-1.aws.confluent.cloud:9092/39: Handle is terminating in state INIT: 1 refcnts (0x7fd1000254c8), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.800|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b39-kafka.eu-west-1.aws.confluent.cloud:9092/39]: sasl_ssl://b39-kafka.eu-west-1.aws.confluent.cloud:9092/39: Broker handle is terminating (after 1ms in state INIT) (_DESTROY) 1674849917.800|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b39-kafka.eu-west-1.aws.confluent.cloud:9092/39]: sasl_ssl://b39-kafka.eu-west-1.aws.confluent.cloud:9092/39: Broker changed state INIT -> DOWN 1674849917.801|TERM|rdkafka#consumer-4| [thrd::0/internal]: :0/internal: Received TERMINATE op in state INIT: 3 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs 1674849917.801|FAIL|rdkafka#consumer-4| [thrd::0/internal]: :0/internal: Client is terminating (after 23397263ms in state INIT) (_DESTROY) 1674849917.801|STATE|rdkafka#consumer-4| [thrd::0/internal]: :0/internal: Broker changed state INIT -> DOWN 1674849917.801|BRKTERM|rdkafka#consumer-4| [thrd::0/internal]: :0/internal: terminating: broker still has 3 refcnt(s), 0 buffer(s), 0 partition(s) 1674849917.801|TERMINATE|rdkafka#consumer-4| [thrd::0/internal]: :0/internal: Handle is terminating in state DOWN: 2 refcnts (0x7fd11017ffd8), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.801|STATE|rdkafka#consumer-4| [thrd::0/internal]: :0/internal: Broker changed state DOWN -> INIT 1674849917.801|TERMINATE|rdkafka#consumer-4| [thrd:sasl_ssl://b40-kafka.eu-west-1.aws.confluent.cloud:9092/40]: sasl_ssl://b40-kafka.eu-west-1.aws.confluent.cloud:9092/40: Handle is terminating in state INIT: 1 refcnts (0x7fd1000239c8), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.801|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b40-kafka.eu-west-1.aws.confluent.cloud:9092/40]: sasl_ssl://b40-kafka.eu-west-1.aws.confluent.cloud:9092/40: Broker handle is terminating (after 1ms in state INIT) (_DESTROY) 1674849917.801|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b40-kafka.eu-west-1.aws.confluent.cloud:9092/40]: sasl_ssl://b40-kafka.eu-west-1.aws.confluent.cloud:9092/40: Broker changed state INIT -> DOWN 1674849917.801|TERMINATE|rdkafka#consumer-4| [thrd:sasl_ssl://b20-kafka.eu-west-1.aws.confluent.cloud:9092/20]: sasl_ssl://b20-kafka.eu-west-1.aws.confluent.cloud:9092/20: Handle is terminating in state INIT: 1 refcnts (0x7fd100009698), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.801|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b20-kafka.eu-west-1.aws.confluent.cloud:9092/20]: sasl_ssl://b20-kafka.eu-west-1.aws.confluent.cloud:9092/20: Broker handle is terminating (after 1ms in state INIT) (_DESTROY) 1674849917.801|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b20-kafka.eu-west-1.aws.confluent.cloud:9092/20]: sasl_ssl://b20-kafka.eu-west-1.aws.confluent.cloud:9092/20: Broker changed state INIT -> DOWN 1674849917.801|TERMINATE|rdkafka#consumer-4| [thrd:sasl_ssl://b10-kafka.eu-west-1.aws.confluent.cloud:9092/10]: sasl_ssl://b10-kafka.eu-west-1.aws.confluent.cloud:9092/10: Handle is terminating in state INIT: 1 refcnts (0x7fd1000088b8), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.803|TERMINATE|rdkafka#consumer-4| [thrd:sasl_ssl://b0-kafka.eu-west-1.aws.confluent.cloud:9092/0]: sasl_ssl://b0-kafka.eu-west-1.aws.confluent.cloud:9092/0: Handle is terminating in state INIT: 1 refcnts (0x7fd100007cc8), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.803|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b0-kafka.eu-west-1.aws.confluent.cloud:9092/0]: sasl_ssl://b0-kafka.eu-west-1.aws.confluent.cloud:9092/0: Broker handle is terminating (after 2ms in state INIT) (_DESTROY) 1674849917.803|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b0-kafka.eu-west-1.aws.confluent.cloud:9092/0]: sasl_ssl://b0-kafka.eu-west-1.aws.confluent.cloud:9092/0: Broker changed state INIT -> DOWN 1674849917.803|FAIL|rdkafka#consumer-4| [thrd:sasl_ssl://b10-kafka.eu-west-1.aws.confluent.cloud:9092/10]: sasl_ssl://b10-kafka.eu-west-1.aws.confluent.cloud:9092/10: Broker handle is terminating (after 2ms in state INIT) (_DESTROY) 1674849917.803|STATE|rdkafka#consumer-4| [thrd:sasl_ssl://b10-kafka.eu-west-1.aws.confluent.cloud:9092/10]: sasl_ssl://b10-kafka.eu-west-1.aws.confluent.cloud:9092/10: Broker changed state INIT -> DOWN 1674849917.803|TERMINATE|rdkafka#consumer-4| [thrd:GroupCoordinator]: GroupCoordinator: Handle is terminating in state INIT: 1 refcnts (0x7fd11017f0c8), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.803|FAIL|rdkafka#consumer-4| [thrd:GroupCoordinator]: GroupCoordinator: Broker handle is terminating (after 2ms in state INIT) (_DESTROY) 1674849917.803|STATE|rdkafka#consumer-4| [thrd:GroupCoordinator]: GroupCoordinator: Broker changed state INIT -> DOWN 1674849917.803|TERMINATE|rdkafka#consumer-4| [thrd::0/internal]: :0/internal: Handle is terminating in state INIT: 2 refcnts (0x7fd11017ffd8), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.804|TERMINATE|rdkafka#consumer-4| [thrd::0/internal]: :0/internal: Handle is terminating in state INIT: 1 refcnts (0x7fd11017ffd8), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf 1674849917.804|FAIL|rdkafka#consumer-4| [thrd::0/internal]: :0/internal: Broker handle is terminating (after 3ms in state INIT) (_DESTROY) 1674849917.804|STATE|rdkafka#consumer-4| [thrd::0/internal]: :0/internal: Broker changed state INIT -> DOWN 1674849917.804|MEMBERID|rdkafka#consumer-4| [thrd:app]: Group "cgroup.ravendb.loads": updating member id "" -> "(not-set)" 1674850881.040|FAIL|rdkafka#producer-2| [thrd:sasl_ssl://b38-kafka.eu-west-1.aws.confluent.cloud:9092/38]: sasl_ssl://b38-kafka.eu-west-1.aws.confluent.cloud:9092/38: Disconnected (after 6063777ms in state UP) (_TRANSPORT) 1674850881.040|STATE|rdkafka#producer-2| [thrd:sasl_ssl://b38-kafka.eu-west-1.aws.confluent.cloud:9092/38]: sasl_ssl://b38-kafka.eu-west-1.aws.confluent.cloud:9092/38: Broker changed state UP -> DOWN 1674850881.040|STATE|rdkafka#producer-2| [thrd:sasl_ssl://b38-kafka.eu-west-1.aws.confluent.cloud:9092/38]: sasl_ssl://b38-kafka.eu-west-1.aws.confluent.cloud:9092/38: Broker changed state DOWN -> INIT 1674850881.041|FAIL|rdkafka#producer-2| [thrd:sasl_ssl://b1-kafka.eu-west-1.aws.confluent.cloud:9092/1]: sasl_ssl://b1-kafka.eu-west-1.aws.confluent.cloud:9092/1: Disconnected (after 6063865ms in state UP, 1 identical error(s) suppressed) (_TRANSPORT): identical to last error %6|1674850881.041|FAIL|rdkafka#producer-2| [thrd:sasl_ssl://b1-kafka.eu-west-1.aws.confluent.cloud:9092/1]: sasl_ssl://b1-kafka.eu-west-1.aws.confluent.cloud:9092/1: Disconnected (after 6063865ms in state UP, 1 identical error(s) suppressed) 1674850881.041|STATE|rdkafka#producer-2| [thrd:sasl_ssl://b1-kafka.eu-west-1.aws.confluent.cloud:9092/1]: sasl_ssl://b1-kafka.eu-west-1.aws.confluent.cloud:9092/1: Broker changed state UP -> DOWN 1674850881.041|REQERR|rdkafka#producer-2| [thrd:main]: sasl_ssl://b1-kafka.eu-west-1.aws.confluent.cloud:9092/1: MetadataRequest failed: Local: Broker transport failure: actions Retry 1674850881.041|STATE|rdkafka#producer-2| [thrd:sasl_ssl://b1-kafka.eu-west-1.aws.confluent.cloud:9092/1]: sasl_ssl://b1-kafka.eu-west-1.aws.confluent.cloud:9092/1: Broker changed state DOWN -> INIT 1674850881.042|STATE|rdkafka#producer-2| [thrd:sasl_ssl://b1-kafka.eu-west-1.aws.confluent.cloud:9092/1]: sasl_ssl://b1-kafka.eu-west-1.aws.confluent.cloud:9092/1: Broker changed state INIT -> TRY_CONNECT 1674850881.042|CONNECT|rdkafka#producer-2| [thrd:sasl_ssl://b1-kafka.eu-west-1.aws.confluent.cloud:9092/1]: sasl_ssl://b1-kafka.eu-west-1.aws.confluent.cloud:9092/1: broker in state TRY_CONNECT connecting 1674850881.042|STATE|rdkafka#producer-2| [thrd:sasl_ssl://b1-kafka.eu-west-1.aws.confluent.cloud:9092/1]: sasl_ssl://b1-kafka.eu-west-1.aws.confluent.cloud:9092/1: Broker changed state TRY_CONNECT -> CONNECT 1674850881.043|FAIL|rdkafka#producer-2| [thrd:sasl_ssl://kafka.eu-west-1.aws.confluent.cloud:9092/bootstr]: sasl_ssl://kafka.eu-west-1.aws.confluent.cloud:9092/bootstrap: Disconnected (after 6063805ms in state UP, 1 identical error(s) suppressed) (_TRANSPORT): identical to last error %6|1674850881.043|FAIL|rdkafka#producer-2| [thrd:sasl_ssl://kafka.eu-west-1.aws.confluent.cloud:9092/bootstr]: sasl_ssl://kafka.eu-west-1.aws.confluent.cloud:9092/bootstrap: Disconnected (after 6063805ms in state UP, 1 identical error(s) suppressed) 1674850881.043|STATE|rdkafka#producer-2| [thrd:sasl_ssl://kafka.eu-west-1.aws.confluent.cloud:9092/bootstr]: sasl_ssl://kafka.eu-west-1.aws.confluent.cloud:9092/bootstrap: Broker changed state UP -> DOWN 1674850881.043|CONNECT|rdkafka#producer-2| [thrd:sasl_ssl://kafka.eu-west-1.aws.confluent.cloud:9092/bootstr]: sasl_ssl://b20-kafka.eu-west-1.aws.confluent.cloud:9092/20: Selected for cluster connection: broker down (broker has 0 connection attempt(s)) 1674850881.043|STATE|rdkafka#producer-2| [thrd:sasl_ssl://kafka.eu-west-1.aws.confluent.cloud:9092/bootstr]: sasl_ssl://kafka.eu-west-1.aws.confluent.cloud:9092/bootstrap: Broker changed state DOWN -> INIT 1674850881.043|CONNECT|rdkafka#producer-2| [thrd:sasl_ssl://b20-kafka.eu-west-1.aws.confluent.cloud:9092/20]: sasl_ssl://b20-kafka.eu-west-1.aws.confluent.cloud:9092/20: Received CONNECT op 1674850881.043|STATE|rdkafka#producer-2| [thrd:sasl_ssl://b20-kafka.eu-west-1.aws.confluent.cloud:9092/20]: sasl_ssl://b20-kafka.eu-west-1.aws.confluent.cloud:9092/20: Broker changed state INIT -> TRY_CONNECT 1674850881.043|STATE|rdkafka#producer-2| [thrd:sasl_ssl://kafka.eu-west-1.aws.confluent.cloud:9092/bootstr]: sasl_ssl://kafka.eu-west-1.aws.confluent.cloud:9092/bootstrap: Broker changed state INIT -> TRY_CONNECT 1674850881.043|CONNECT|rdkafka#producer-2| [thrd:sasl_ssl://b20-kafka.eu-west-1.aws.confluent.cloud:9092/20]: sasl_ssl://b20-kafka.eu-west-1.aws.confluent.cloud:9092/20: broker in state TRY_CONNECT connecting 1674850881.043|STATE|rdkafka#producer-2| [thrd:sasl_ssl://b20-kafka.eu-west-1.aws.confluent.cloud:9092/20]: sasl_ssl://b20-kafka.eu-west-1.aws.confluent.cloud:9092/20: Broker changed state TRY_CONNECT -> CONNECT 1674850881.043|CONNECT|rdkafka#producer-2| [thrd:sasl_ssl://kafka.eu-west-1.aws.confluent.cloud:9092/bootstr]: sasl_ssl://kafka.eu-west-1.aws.confluent.cloud:9092/bootstrap: broker in state TRY_CONNECT connecting 1674850881.043|STATE|rdkafka#producer-2| [thrd:sasl_ssl://kafka.eu-west-1.aws.confluent.cloud:9092/bootstr]: sasl_ssl://kafka.eu-west-1.aws.confluent.cloud:9092/bootstrap: Broker changed state TRY_CONNECT -> CONNECT 1674850881.043|REQERR|rdkafka#producer-2| [thrd:main]: sasl_ssl://kafka.eu-west-1.aws.confluent.cloud:9092/bootstrap: MetadataRequest failed: Local: Broker transport failure: actions Retry 1674850881.044|CONNECT|rdkafka#producer-2| [thrd:sasl_ssl://b1-kafka.eu-west-1.aws.confluent.cloud:9092/1]: sasl_ssl://b1-kafka.eu-west-1.aws.confluent.cloud:9092/1: Connecting to ipv4#52.215.108.126:9092 (sasl_ssl) with socket 210 1674850881.045|CONNECT|rdkafka#producer-2| [thrd:sasl_ssl://b20-kafka.eu-west-1.aws.confluent.cloud:9092/20]: sasl_ssl://b20-kafka.eu-west-1.aws.confluent.cloud:9092/20: Connecting to ipv4#52.48.136.231:9092 (sasl_ssl) with socket 216 1674850881.045|CONNECT|rdkafka#producer-2| [thrd:sasl_ssl://kafka.eu-west-1.aws.confluent.cloud:9092/bootstr]: sasl_ssl://kafka.eu-west-1.aws.confluent.cloud:9092/bootstrap: Connecting to ipv4#52.214.229.117:9092 (sasl_ssl) with socket 111 1674850881.046|CONNECT|rdkafka#producer-2| [thrd:sasl_ssl://b1-kafka.eu-west-1.aws.confluent.cloud:9092/1]: sasl_ssl://b1-kafka.eu-west-1.aws.confluent.cloud:9092/1: Connected to ipv4#52.215.108.126:9092 1674850881.046|STATE|rdkafka#producer-2| [thrd:sasl_ssl://b1-kafka.eu-west-1.aws.confluent.cloud:9092/1]: sasl_ssl://b1-kafka.eu-west-1.aws.confluent.cloud:9092/1: Broker changed state CONNECT -> SSL_HANDSHAKE 1674850881.047|CONNECT|rdkafka#producer-2| [thrd:sasl_ssl://b20-kafka.eu-west-1.aws.confluent.cloud:9092/20]: sasl_ssl://b20-kafka.eu-west-1.aws.confluent.cloud:9092/20: Connected to ipv4#52.48.136.231:9092 1674850881.047|STATE|rdkafka#producer-2| [thrd:sasl_ssl://b20-kafka.eu-west-1.aws.confluent.cloud:9092/20]: sasl_ssl://b20-kafka.eu-west-1.aws.confluent.cloud:9092/20: Broker changed state CONNECT -> SSL_HANDSHAKE 1674850881.047|CONNECT|rdkafka#producer-2| [thrd:sasl_ssl://kafka.eu-west-1.aws.confluent.cloud:9092/bootstr]: sasl_ssl://kafka.eu-west-1.aws.confluent.cloud:9092/bootstrap: Connected to ipv4#52.214.229.117:9092 1674850881.047|STATE|rdkafka#producer-2| [thrd:sasl_ssl://kafka.eu-west-1.aws.confluent.cloud:9092/bootstr]: sasl_ssl://kafka.eu-west-1.aws.confluent.cloud:9092/bootstrap: Broker changed state CONNECT -> SSL_HANDSHAKE 1674850881.141|CONNECT|rdkafka#producer-2| [thrd:main]: sasl_ssl://b23-kafka.eu-west-1.aws.confluent.cloud:9092/23: Selected for cluster connection: refresh unavailable topics (broker has 0 connection attempt(s)) 1674850881.141|CONNECT|rdkafka#producer-2| [thrd:sasl_ssl://b23-kafka.eu-west-1.aws.confluent.cloud:9092/23]: sasl_ssl://b23-kafka.eu-west-1.aws.confluent.cloud:9092/23: Received CONNECT op 1674850881.141|STATE|rdkafka#producer-2| [thrd:sasl_ssl://b23-kafka.eu-west-1.aws.confluent.cloud:9092/23]: sasl_ssl://b23-kafka.eu-west-1.aws.confluent.cloud:9092/23: Broker changed state INIT -> TRY_CONNECT 1674850881.141|CONNECT|rdkafka#producer-2| [thrd:sasl_ssl://b23-kafka.eu-west-1.aws.confluent.cloud:9092/23]: sasl_ssl://b23-kafka.eu-west-1.aws.confluent.cloud:9092/23: broker in state TRY_CONNECT connecting 1674850881.141|STATE|rdkafka#producer-2| [thrd:sasl_ssl://b23-kafka.eu-west-1.aws.confluent.cloud:9092/23]: sasl_ssl://b23-kafka.eu-west-1.aws.confluent.cloud:9092/23: Broker changed state TRY_CONNECT -> CONNECT 1674850881.141|CONNECT|rdkafka#producer-2| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection 1674850881.144|CONNECT|rdkafka#producer-2| [thrd:sasl_ssl://b23-kafka.eu-west-1.aws.confluent.cloud:9092/23]: sasl_ssl://b23-kafka.eu-west-1.aws.confluent.cloud:9092/23: Connecting to ipv4#52.213.166.219:9092 (sasl_ssl) with socket 313 1674850881.145|CONNECT|rdkafka#producer-2| [thrd:sasl_ssl://b23-kafka.eu-west-1.aws.confluent.cloud:9092/23]: sasl_ssl://b23-kafka.eu-west-1.aws.confluent.cloud:9092/23: Connected to ipv4#52.213.166.219:9092 1674850881.145|STATE|rdkafka#producer-2| [thrd:sasl_ssl://b23-kafka.eu-west-1.aws.confluent.cloud:9092/23]: sasl_ssl://b23-kafka.eu-west-1.aws.confluent.cloud:9092/23: Broker changed state CONNECT -> SSL_HANDSHAKE 1674850881.145|RETRY|rdkafka#producer-2| [thrd:sasl_ssl://kafka.eu-west-1.aws.confluent.cloud:9092/bootstr]: sasl_ssl://kafka.eu-west-1.aws.confluent.cloud:9092/bootstrap: Moved 1 retry buffer(s) to output queue 1674850881.145|RETRY|rdkafka#producer-2| [thrd:sasl_ssl://b1-kafka.eu-west-1.aws.confluent.cloud:9092/1]: sasl_ssl://b1-kafka.eu-west-1.aws.confluent.cloud:9092/1: Moved 1 retry buffer(s) to output queue 1674850881.167|CONNECTED|rdkafka#producer-2| [thrd:sasl_ssl://b23-kafka.eu-west-1.aws.confluent.cloud:9092/23]: sasl_ssl://b23-kafka.eu-west-1.aws.confluent.cloud:9092/23: Connected (#1) 1674850881.167|FEATURE|rdkafka#producer-2| [thrd:sasl_ssl://b23-kafka.eu-west-1.aws.confluent.cloud:9092/23]: sasl_ssl://b23-kafka.eu-west-1.aws.confluent.cloud:9092/23: Updated enabled protocol features +ApiVersion to ApiVersion 1674850881.167|STATE|rdkafka#producer-2| [thrd:sasl_ssl://b23-kafka.eu-west-1.aws.confluent.cloud:9092/23]: sasl_ssl://b23-kafka.eu-west-1.aws.confluent.cloud:9092/23: Broker changed state SSL_HANDSHAKE -> APIVERSION_QUERY 1674850881.226|CONNECTED|rdkafka#producer-2| [thrd:sasl_ssl://b20-kafka.eu-west-1.aws.confluent.cloud:9092/20]: sasl_ssl://b20-kafka.eu-west-1.aws.confluent.cloud:9092/20: Connected (#1) 1674850881.226|FEATURE|rdkafka#producer-2| [thrd:sasl_ssl://b20-kafka.eu-west-1.aws.confluent.cloud:9092/20]: sasl_ssl://b20-kafka.eu-west-1.aws.confluent.cloud:9092/20: Updated enabled protocol features +ApiVersion to ApiVersion 1674850881.226|STATE|rdkafka#producer-2| [thrd:sasl_ssl://b20-kafka.eu-west-1.aws.confluent.cloud:9092/20]: sasl_ssl://b20-kafka.eu-west-1.aws.confluent.cloud:9092/20: Broker changed state SSL_HANDSHAKE -> APIVERSION_QUERY 1674850881.228|CONNECTED|rdkafka#producer-2| [thrd:sasl_ssl://kafka.eu-west-1.aws.confluent.cloud:9092/bootstr]: sasl_ssl://kafka.eu-west-1.aws.confluent.cloud:9092/bootstrap: Connected (#3) 1674850881.228|STATE|rdkafka#producer-2| [thrd:sasl_ssl://kafka.eu-west-1.aws.confluent.cloud:9092/bootstr]: sasl_ssl://kafka.eu-west-1.aws.confluent.cloud:9092/bootstrap: Broker changed state SSL_HANDSHAKE -> APIVERSION_QUERY 1674850881.229|FEATURE|rdkafka#producer-2| [thrd:sasl_ssl://b20-kafka.eu-west-1.aws.confluent.cloud:9092/20]: sasl_ssl://b20-kafka.eu-west-1.aws.confluent.cloud:9092/20: Updated enabled protocol features to MsgVer1,ApiVersion,BrokerBalancedConsumer,ThrottleTime,Sasl,SaslHandshake,BrokerGroupCoordinator,LZ4,OffsetTime,MsgVer2,IdempotentProducer,ZSTD,SaslAuthReq 1674850881.229|AUTH|rdkafka#producer-2| [thrd:sasl_ssl://b20-kafka.eu-west-1.aws.confluent.cloud:9092/20]: sasl_ssl://b20-kafka.eu-west-1.aws.confluent.cloud:9092/20: Auth in state APIVERSION_QUERY (handshake supported) 1674850881.230|STATE|rdkafka#producer-2| [thrd:sasl_ssl://b20-kafka.eu-west-1.aws.confluent.cloud:9092/20]: sasl_ssl://b20-kafka.eu-west-1.aws.confluent.cloud:9092/20: Broker changed state APIVERSION_QUERY -> AUTH_HANDSHAKE 1674850881.230|AUTH|rdkafka#producer-2| [thrd:sasl_ssl://kafka.eu-west-1.aws.confluent.cloud:9092/bootstr]: sasl_ssl://kafka.eu-west-1.aws.confluent.cloud:9092/bootstrap: Auth in state APIVERSION_QUERY (handshake supported) 1674850881.230|STATE|rdkafka#producer-2| [thrd:sasl_ssl://kafka.eu-west-1.aws.confluent.cloud:9092/bootstr]: sasl_ssl://kafka.eu-west-1.aws.confluent.cloud:9092/bootstrap: Broker changed state APIVERSION_QUERY -> AUTH_HANDSHAKE 1674850881.232|SASLMECHS|rdkafka#producer-2| [thrd:sasl_ssl://b20-kafka.eu-west-1.aws.confluent.cloud:9092/20]: sasl_ssl://b20-kafka.eu-west-1.aws.confluent.cloud:9092/20: Broker supported SASL mechanisms: PLAIN,OAUTHBEARER 1674850881.232|AUTH|rdkafka#producer-2| [thrd:sasl_ssl://b20-kafka.eu-west-1.aws.confluent.cloud:9092/20]: sasl_ssl://b20-kafka.eu-west-1.aws.confluent.cloud:9092/20: Auth in state AUTH_HANDSHAKE (handshake supported) 1674850881.232|STATE|rdkafka#producer-2| [thrd:sasl_ssl://b20-kafka.eu-west-1.aws.confluent.cloud:9092/20]: sasl_ssl://b20-kafka.eu-west-1.aws.confluent.cloud:9092/20: Broker changed state AUTH_HANDSHAKE -> AUTH_REQ 1674850881.246|CONNECTED|rdkafka#producer-2| [thrd:sasl_ssl://b1-kafka.eu-west-1.aws.confluent.cloud:9092/1]: sasl_ssl://b1-kafka.eu-west-1.aws.confluent.cloud:9092/1: Connected (#4) 1674850881.247|STATE|rdkafka#producer-2| [thrd:sasl_ssl://b1-kafka.eu-west-1.aws.confluent.cloud:9092/1]: sasl_ssl://b1-kafka.eu-west-1.aws.confluent.cloud:9092/1: Broker changed state SSL_HANDSHAKE -> APIVERSION_QUERY 1674850881.249|AUTH|rdkafka#producer-2| [thrd:sasl_ssl://b1-kafka.eu-west-1.aws.confluent.cloud:9092/1]: sasl_ssl://b1-kafka.eu-west-1.aws.confluent.cloud:9092/1: Auth in state APIVERSION_QUERY (handshake supported) 1674850881.249|STATE|rdkafka#producer-2| [thrd:sasl_ssl://b1-kafka.eu-west-1.aws.confluent.cloud:9092/1]: sasl_ssl://b1-kafka.eu-west-1.aws.confluent.cloud:9092/1: Broker changed state APIVERSION_QUERY -> AUTH_HANDSHAKE 1674850881.257|SASLMECHS|rdkafka#producer-2| [thrd:sasl_ssl://b1-kafka.eu-west-1.aws.confluent.cloud:9092/1]: sasl_ssl://b1-kafka.eu-west-1.aws.confluent.cloud:9092/1: Broker supported SASL mechanisms: PLAIN,OAUTHBEARER 1674850881.257|AUTH|rdkafka#producer-2| [thrd:sasl_ssl://b1-kafka.eu-west-1.aws.confluent.cloud:9092/1]: sasl_ssl://b1-kafka.eu-west-1.aws.confluent.cloud:9092/1: Auth in state AUTH_HANDSHAKE (handshake supported) 1674850881.257|STATE|rdkafka#producer-2| [thrd:sasl_ssl://b1-kafka.eu-west-1.aws.confluent.cloud:9092/1]: sasl_ssl://b1-kafka.eu-west-1.aws.confluent.cloud:9092/1: Broker changed state AUTH_HANDSHAKE -> AUTH_REQ 1674850881.418|STATE|rdkafka#producer-2| [thrd:sasl_ssl://b20-kafka.eu-west-1.aws.confluent.cloud:9092/20]: sasl_ssl://b20-kafka.eu-west-1.aws.confluent.cloud:9092/20: Broker changed state AUTH_REQ -> UP 1674850881.552|SASLMECHS|rdkafka#producer-2| [thrd:sasl_ssl://kafka.eu-west-1.aws.confluent.cloud:9092/bootstr]: sasl_ssl://kafka.eu-west-1.aws.confluent.cloud:9092/bootstrap: Broker supported SASL mechanisms: PLAIN,OAUTHBEARER 1674850881.552|AUTH|rdkafka#producer-2| [thrd:sasl_ssl://kafka.eu-west-1.aws.confluent.cloud:9092/bootstr]: sasl_ssl://kafka.eu-west-1.aws.confluent.cloud:9092/bootstrap: Auth in state AUTH_HANDSHAKE (handshake supported) 1674850881.552|STATE|rdkafka#producer-2| [thrd:sasl_ssl://kafka.eu-west-1.aws.confluent.cloud:9092/bootstr]: sasl_ssl://kafka.eu-west-1.aws.confluent.cloud:9092/bootstrap: Broker changed state AUTH_HANDSHAKE -> AUTH_REQ 1674850881.553|STATE|rdkafka#producer-2| [thrd:sasl_ssl://b1-kafka.eu-west-1.aws.confluent.cloud:9092/1]: sasl_ssl://b1-kafka.eu-west-1.aws.confluent.cloud:9092/1: Broker changed state AUTH_REQ -> UP 1674850881.559|STATE|rdkafka#producer-2| [thrd:sasl_ssl://kafka.eu-west-1.aws.confluent.cloud:9092/bootstr]: sasl_ssl://kafka.eu-west-1.aws.confluent.cloud:9092/bootstrap: Broker changed state AUTH_REQ -> UP 1674850881.690|FEATURE|rdkafka#producer-2| [thrd:sasl_ssl://b23-kafka.eu-west-1.aws.confluent.cloud:9092/23]: sasl_ssl://b23-kafka.eu-west-1.aws.confluent.cloud:9092/23: Updated enabled protocol features to MsgVer1,ApiVersion,BrokerBalancedConsumer,ThrottleTime,Sasl,SaslHandshake,BrokerGroupCoordinator,LZ4,OffsetTime,MsgVer2,IdempotentProducer,ZSTD,SaslAuthReq 1674850881.690|AUTH|rdkafka#producer-2| [thrd:sasl_ssl://b23-kafka.eu-west-1.aws.confluent.cloud:9092/23]: sasl_ssl://b23-kafka.eu-west-1.aws.confluent.cloud:9092/23: Auth in state APIVERSION_QUERY (handshake supported) 1674850881.690|STATE|rdkafka#producer-2| [thrd:sasl_ssl://b23-kafka.eu-west-1.aws.confluent.cloud:9092/23]: sasl_ssl://b23-kafka.eu-west-1.aws.confluent.cloud:9092/23: Broker changed state APIVERSION_QUERY -> AUTH_HANDSHAKE 1674850881.724|SASLMECHS|rdkafka#producer-2| [thrd:sasl_ssl://b23-kafka.eu-west-1.aws.confluent.cloud:9092/23]: sasl_ssl://b23-kafka.eu-west-1.aws.confluent.cloud:9092/23: Broker supported SASL mechanisms: PLAIN,OAUTHBEARER 1674850881.725|AUTH|rdkafka#producer-2| [thrd:sasl_ssl://b23-kafka.eu-west-1.aws.confluent.cloud:9092/23]: sasl_ssl://b23-kafka.eu-west-1.aws.confluent.cloud:9092/23: Auth in state AUTH_HANDSHAKE (handshake supported) 1674850881.725|STATE|rdkafka#producer-2| [thrd:sasl_ssl://b23-kafka.eu-west-1.aws.confluent.cloud:9092/23]: sasl_ssl://b23-kafka.eu-west-1.aws.confluent.cloud:9092/23: Broker changed state AUTH_HANDSHAKE -> AUTH_REQ 1674850881.905|STATE|rdkafka#producer-2| [thrd:sasl_ssl://b23-kafka.eu-west-1.aws.confluent.cloud:9092/23]: sasl_ssl://b23-kafka.eu-west-1.aws.confluent.cloud:9092/23: Broker changed state AUTH_REQ -> UP 1674851416.343|CONTROLLERID|rdkafka#producer-1| [thrd:main]: sasl_ssl://b12-kafka.eu-west-1.aws.confluent.cloud:9092/12: ControllerId update 41 -> 40 1674851416.749|CONTROLLERID|rdkafka#producer-2| [thrd:main]: sasl_ssl://b23-kafka.eu-west-1.aws.confluent.cloud:9092/23: ControllerId update 41 -> 40 1674851420.355|CONTROLLERID|rdkafka#producer-3| [thrd:main]: sasl_ssl://kafka.eu-west-1.aws.confluent.cloud:9092/bootstrap: ControllerId update 41 -> 40