Skip to content
New issue

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

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

Already on GitHub? Sign in to your account

Disconnecting a consumer before .run resolves causes a crash event and sometimes it keeps consuming #1639

Open
everhardt opened this issue Nov 22, 2023 · 1 comment

Comments

@everhardt
Copy link

Describe the bug
When a consumer disconnects before .run has resolved, I get the following log entries (loglevel .DEBUG):

{"namespace":"Connection","level":5,"label":"DEBUG","log":{"timestamp":"2023-11-22T13:21:07.279Z","logger":"kafkajs","message":"Connecting","broker":"127.0.0.1:9093","clientId":"xxx","ssl":false,"sasl":false}}
{"namespace":"Connection","level":5,"label":"DEBUG","log":{"timestamp":"2023-11-22T13:21:07.279Z","logger":"kafkajs","message":"Request ApiVersions(key: 18, version: 2)","broker":"127.0.0.1:9093","clientId":"xxx","correlationId":0,"expectResponse":true,"size":34}}
{"namespace":"Connection","level":5,"label":"DEBUG","log":{"timestamp":"2023-11-22T13:21:07.288Z","logger":"kafkajs","message":"Response ApiVersions(key: 18, version: 2)","broker":"127.0.0.1:9093","clientId":"xxx","correlationId":0,"size":320,"data":{"errorCode":0,"apiVersions":[{"apiKey":0,"minVersion":0,"maxVersion":9},{"apiKey":1,"minVersion":0,"maxVersion":15},{"apiKey":2,"minVersion":0,"maxVersion":8},{"apiKey":3,"minVersion":0,"maxVersion":12},{"apiKey":8,"minVersion":0,"maxVersion":8},{"apiKey":9,"minVersion":0,"maxVersion":8},{"apiKey":10,"minVersion":0,"maxVersion":4},{"apiKey":11,"minVersion":0,"maxVersion":9},{"apiKey":12,"minVersion":0,"maxVersion":4},{"apiKey":13,"minVersion":0,"maxVersion":5},{"apiKey":14,"minVersion":0,"maxVersion":5},{"apiKey":15,"minVersion":0,"maxVersion":5},{"apiKey":16,"minVersion":0,"maxVersion":4},{"apiKey":17,"minVersion":0,"maxVersion":1},{"apiKey":18,"minVersion":0,"maxVersion":3},{"apiKey":19,"minVersion":0,"maxVersion":7},{"apiKey":20,"minVersion":0,"maxVersion":6},{"apiKey":21,"minVersion":0,"maxVersion":2},{"apiKey":22,"minVersion":0,"maxVersion":4},{"apiKey":23,"minVersion":0,"maxVersion":4},{"apiKey":24,"minVersion":0,"maxVersion":3},{"apiKey":25,"minVersion":0,"maxVersion":3},{"apiKey":26,"minVersion":0,"maxVersion":3},{"apiKey":27,"minVersion":0,"maxVersion":1},{"apiKey":28,"minVersion":0,"maxVersion":3},{"apiKey":29,"minVersion":0,"maxVersion":3},{"apiKey":30,"minVersion":0,"maxVersion":3},{"apiKey":31,"minVersion":0,"maxVersion":3},{"apiKey":32,"minVersion":0,"maxVersion":4},{"apiKey":33,"minVersion":0,"maxVersion":2},{"apiKey":34,"minVersion":0,"maxVersion":2},{"apiKey":35,"minVersion":0,"maxVersion":4},{"apiKey":36,"minVersion":0,"maxVersion":2},{"apiKey":37,"minVersion":0,"maxVersion":3},{"apiKey":42,"minVersion":0,"maxVersion":2},{"apiKey":43,"minVersion":0,"maxVersion":2},{"apiKey":44,"minVersion":0,"maxVersion":1},{"apiKey":45,"minVersion":0,"maxVersion":0},{"apiKey":46,"minVersion":0,"maxVersion":0},{"apiKey":47,"minVersion":0,"maxVersion":0},{"apiKey":48,"minVersion":0,"maxVersion":1},{"apiKey":49,"minVersion":0,"maxVersion":1},{"apiKey":50,"minVersion":0,"maxVersion":0},{"apiKey":51,"minVersion":0,"maxVersion":0},{"apiKey":55,"minVersion":0,"maxVersion":1},{"apiKey":57,"minVersion":0,"maxVersion":1},{"apiKey":60,"minVersion":0,"maxVersion":0},{"apiKey":61,"minVersion":0,"maxVersion":0},{"apiKey":64,"minVersion":0,"maxVersion":0},{"apiKey":65,"minVersion":0,"maxVersion":0},{"apiKey":66,"minVersion":0,"maxVersion":0}],"throttleTime":0,"clientSideThrottleTime":0}}}
{"namespace":"Broker","level":5,"label":"DEBUG","log":{"timestamp":"2023-11-22T13:21:07.289Z","logger":"kafkajs","message":"Verified support for SaslAuthenticate","broker":"127.0.0.1:9093","supportAuthenticationProtocol":true}}
{"namespace":"Connection","level":5,"label":"DEBUG","log":{"timestamp":"2023-11-22T13:21:07.289Z","logger":"kafkajs","message":"Request Metadata(key: 3, version: 6)","broker":"127.0.0.1:9093","clientId":"xxx","correlationId":1,"expectResponse":true,"size":39}}
{"namespace":"Connection","level":5,"label":"DEBUG","log":{"timestamp":"2023-11-22T13:21:07.294Z","logger":"kafkajs","message":"Response Metadata(key: 3, version: 6)","broker":"127.0.0.1:9093","clientId":"xxx","correlationId":1,"size":1909,"data":{"throttleTime":0,"brokers":[{"nodeId":1,"host":"127.0.0.1","port":9093,"rack":null}],"clusterId":"ciWo7IWazngRchmPES6q5A","controllerId":1,"topicMetadata":[{"topicErrorCode":0,"topic":"yyy","isInternal":false,"partitionMetadata":[{"partitionErrorCode":0,"partitionId":0,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]}]},{"topicErrorCode":0,"topic":"aaa","isInternal":false,"partitionMetadata":[{"partitionErrorCode":0,"partitionId":1,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":3,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":2,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":0,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":4,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]}]},{"topicErrorCode":0,"topic":"workers","isInternal":false,"partitionMetadata":[{"partitionErrorCode":0,"partitionId":0,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]}]},{"topicErrorCode":0,"topic":"__consumer_offsets","isInternal":true,"partitionMetadata":[{"partitionErrorCode":0,"partitionId":17,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":11,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":23,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":40,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":5,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":0,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":29,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":46,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":30,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":4,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":39,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":42,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":36,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":48,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":10,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":13,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":45,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":16,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":28,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":34,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":19,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":22,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":31,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":2,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":25,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":20,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":26,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":14,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":32,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":37,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":8,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":43,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":7,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":49,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":33,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":1,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":27,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":24,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":21,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":47,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":3,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":9,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":15,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":18,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":44,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":6,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":35,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":38,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":41,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":12,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]}]},{"topicErrorCode":0,"topic":"bbb","isInternal":false,"partitionMetadata":[{"partitionErrorCode":0,"partitionId":0,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]}]}],"clientSideThrottleTime":0}}}
{"namespace":"Connection","level":5,"label":"DEBUG","log":{"timestamp":"2023-11-22T13:21:07.294Z","logger":"kafkajs","message":"Request CreateTopics(key: 19, version: 3)","broker":"127.0.0.1:9093","clientId":"xxx","correlationId":2,"expectResponse":true,"size":145}}
{"namespace":"Connection","level":5,"label":"DEBUG","log":{"timestamp":"2023-11-22T13:21:07.305Z","logger":"kafkajs","message":"Request Metadata(key: 3, version: 6)","broker":"127.0.0.1:9093","clientId":"xxx","correlationId":3,"expectResponse":true,"size":39}}
{"namespace":"Connection","level":5,"label":"DEBUG","log":{"timestamp":"2023-11-22T13:21:07.307Z","logger":"kafkajs","message":"Response Metadata(key: 3, version: 6)","broker":"127.0.0.1:9093","clientId":"xxx","correlationId":3,"size":1909,"data":{"throttleTime":0,"brokers":[{"nodeId":1,"host":"127.0.0.1","port":9093,"rack":null}],"clusterId":"ciWo7IWazngRchmPES6q5A","controllerId":1,"topicMetadata":[{"topicErrorCode":0,"topic":"yyy","isInternal":false,"partitionMetadata":[{"partitionErrorCode":0,"partitionId":0,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]}]},{"topicErrorCode":0,"topic":"aaa","isInternal":false,"partitionMetadata":[{"partitionErrorCode":0,"partitionId":1,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":3,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":2,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":0,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":4,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]}]},{"topicErrorCode":0,"topic":"workers","isInternal":false,"partitionMetadata":[{"partitionErrorCode":0,"partitionId":0,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]}]},{"topicErrorCode":0,"topic":"__consumer_offsets","isInternal":true,"partitionMetadata":[{"partitionErrorCode":0,"partitionId":17,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":11,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":23,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":40,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":5,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":0,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":29,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":46,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":30,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":4,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":39,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":42,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":36,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":48,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":10,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":13,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":45,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":16,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":28,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":34,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":19,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":22,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":31,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":2,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":25,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":20,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":26,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":14,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":32,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":37,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":8,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":43,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":7,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":49,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":33,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":1,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":27,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":24,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":21,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":47,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":3,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":9,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":15,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":18,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":44,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":6,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":35,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":38,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":41,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":12,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]}]},{"topicErrorCode":0,"topic":"bbb","isInternal":false,"partitionMetadata":[{"partitionErrorCode":0,"partitionId":0,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]}]}],"clientSideThrottleTime":0}}}
{"namespace":"Connection","level":5,"label":"DEBUG","log":{"timestamp":"2023-11-22T13:21:07.307Z","logger":"kafkajs","message":"Request DescribeConfigs(key: 32, version: 2)","broker":"127.0.0.1:9093","clientId":"xxx","correlationId":4,"expectResponse":true,"size":77}}
{"namespace":"Connection","level":5,"label":"DEBUG","log":{"timestamp":"2023-11-22T13:21:07.315Z","logger":"kafkajs","message":"Response DescribeConfigs(key: 32, version: 2)","broker":"127.0.0.1:9093","clientId":"xxx","correlationId":4,"size":2054,"data":{"throttleTime":0,"resources":[{"errorCode":0,"errorMessage":"","resourceType":2,"resourceName":"yyy","configEntries":[{"configName":"compression.type","configValue":"producer","readOnly":false,"isDefault":true,"configSource":5,"isSensitive":false,"configSynonyms":[]},{"configName":"leader.replication.throttled.replicas","configValue":"","readOnly":false,"isDefault":true,"configSource":5,"isSensitive":false,"configSynonyms":[]},{"configName":"message.downconversion.enable","configValue":"true","readOnly":false,"isDefault":true,"configSource":5,"isSensitive":false,"configSynonyms":[]},{"configName":"min.insync.replicas","configValue":"1","readOnly":false,"isDefault":true,"configSource":5,"isSensitive":false,"configSynonyms":[]},{"configName":"segment.jitter.ms","configValue":"0","readOnly":false,"isDefault":true,"configSource":5,"isSensitive":false,"configSynonyms":[]},{"configName":"cleanup.policy","configValue":"delete","readOnly":false,"isDefault":true,"configSource":5,"isSensitive":false,"configSynonyms":[]},{"configName":"flush.ms","configValue":"9223372036854775807","readOnly":false,"isDefault":true,"configSource":5,"isSensitive":false,"configSynonyms":[]},{"configName":"follower.replication.throttled.replicas","configValue":"","readOnly":false,"isDefault":true,"configSource":5,"isSensitive":false,"configSynonyms":[]},{"configName":"segment.bytes","configValue":"1073741824","readOnly":false,"isDefault":true,"configSource":5,"isSensitive":false,"configSynonyms":[]},{"configName":"retention.ms","configValue":"1209600000","readOnly":false,"isDefault":false,"configSource":1,"isSensitive":false,"configSynonyms":[]},{"configName":"flush.messages","configValue":"9223372036854775807","readOnly":false,"isDefault":true,"configSource":5,"isSensitive":false,"configSynonyms":[]},{"configName":"message.format.version","configValue":"3.0-IV1","readOnly":false,"isDefault":true,"configSource":5,"isSensitive":false,"configSynonyms":[]},{"configName":"max.compaction.lag.ms","configValue":"9223372036854775807","readOnly":false,"isDefault":true,"configSource":5,"isSensitive":false,"configSynonyms":[]},{"configName":"file.delete.delay.ms","configValue":"60000","readOnly":false,"isDefault":true,"configSource":5,"isSensitive":false,"configSynonyms":[]},{"configName":"max.message.bytes","configValue":"1048588","readOnly":false,"isDefault":true,"configSource":5,"isSensitive":false,"configSynonyms":[]},{"configName":"min.compaction.lag.ms","configValue":"0","readOnly":false,"isDefault":true,"configSource":5,"isSensitive":false,"configSynonyms":[]},{"configName":"message.timestamp.type","configValue":"CreateTime","readOnly":false,"isDefault":true,"configSource":5,"isSensitive":false,"configSynonyms":[]},{"configName":"preallocate","configValue":"false","readOnly":false,"isDefault":true,"configSource":5,"isSensitive":false,"configSynonyms":[]},{"configName":"min.cleanable.dirty.ratio","configValue":"0.5","readOnly":false,"isDefault":true,"configSource":5,"isSensitive":false,"configSynonyms":[]},{"configName":"index.interval.bytes","configValue":"4096","readOnly":false,"isDefault":true,"configSource":5,"isSensitive":false,"configSynonyms":[]},{"configName":"unclean.leader.election.enable","configValue":"false","readOnly":false,"isDefault":true,"configSource":5,"isSensitive":false,"configSynonyms":[]},{"configName":"retention.bytes","configValue":"-1","readOnly":false,"isDefault":true,"configSource":5,"isSensitive":false,"configSynonyms":[]},{"configName":"delete.retention.ms","configValue":"86400000","readOnly":false,"isDefault":true,"configSource":5,"isSensitive":false,"configSynonyms":[]},{"configName":"segment.ms","configValue":"604800000","readOnly":false,"isDefault":true,"configSource":5,"isSensitive":false,"configSynonyms":[]},{"configName":"message.timestamp.difference.max.ms","configValue":"9223372036854775807","readOnly":false,"isDefault":true,"configSource":5,"isSensitive":false,"configSynonyms":[]},{"configName":"segment.index.bytes","configValue":"10485760","readOnly":false,"isDefault":true,"configSource":5,"isSensitive":false,"configSynonyms":[]}]},{"errorCode":0,"errorMessage":"","resourceType":2,"resourceName":"bbb","configEntries":[{"configName":"compression.type","configValue":"producer","readOnly":false,"isDefault":true,"configSource":5,"isSensitive":false,"configSynonyms":[]},{"configName":"leader.replication.throttled.replicas","configValue":"","readOnly":false,"isDefault":true,"configSource":5,"isSensitive":false,"configSynonyms":[]},{"configName":"message.downconversion.enable","configValue":"true","readOnly":false,"isDefault":true,"configSource":5,"isSensitive":false,"configSynonyms":[]},{"configName":"min.insync.replicas","configValue":"1","readOnly":false,"isDefault":true,"configSource":5,"isSensitive":false,"configSynonyms":[]},{"configName":"segment.jitter.ms","configValue":"0","readOnly":false,"isDefault":true,"configSource":5,"isSensitive":false,"configSynonyms":[]},{"configName":"cleanup.policy","configValue":"delete","readOnly":false,"isDefault":true,"configSource":5,"isSensitive":false,"configSynonyms":[]},{"configName":"flush.ms","configValue":"9223372036854775807","readOnly":false,"isDefault":true,"configSource":5,"isSensitive":false,"configSynonyms":[]},{"configName":"follower.replication.throttled.replicas","configValue":"","readOnly":false,"isDefault":true,"configSource":5,"isSensitive":false,"configSynonyms":[]},{"configName":"segment.bytes","configValue":"1073741824","readOnly":false,"isDefault":true,"configSource":5,"isSensitive":false,"configSynonyms":[]},{"configName":"retention.ms","configValue":"5000","readOnly":false,"isDefault":false,"configSource":1,"isSensitive":false,"configSynonyms":[]},{"configName":"flush.messages","configValue":"9223372036854775807","readOnly":false,"isDefault":true,"configSource":5,"isSensitive":false,"configSynonyms":[]},{"configName":"message.format.version","configValue":"3.0-IV1","readOnly":false,"isDefault":true,"configSource":5,"isSensitive":false,"configSynonyms":[]},{"configName":"max.compaction.lag.ms","configValue":"9223372036854775807","readOnly":false,"isDefault":true,"configSource":5,"isSensitive":false,"configSynonyms":[]},{"configName":"file.delete.delay.ms","configValue":"60000","readOnly":false,"isDefault":true,"configSource":5,"isSensitive":false,"configSynonyms":[]},{"configName":"max.message.bytes","configValue":"1048588","readOnly":false,"isDefault":true,"configSource":5,"isSensitive":false,"configSynonyms":[]},{"configName":"min.compaction.lag.ms","configValue":"0","readOnly":false,"isDefault":true,"configSource":5,"isSensitive":false,"configSynonyms":[]},{"configName":"message.timestamp.type","configValue":"CreateTime","readOnly":false,"isDefault":true,"configSource":5,"isSensitive":false,"configSynonyms":[]},{"configName":"preallocate","configValue":"false","readOnly":false,"isDefault":true,"configSource":5,"isSensitive":false,"configSynonyms":[]},{"configName":"min.cleanable.dirty.ratio","configValue":"0.5","readOnly":false,"isDefault":true,"configSource":5,"isSensitive":false,"configSynonyms":[]},{"configName":"index.interval.bytes","configValue":"4096","readOnly":false,"isDefault":true,"configSource":5,"isSensitive":false,"configSynonyms":[]},{"configName":"unclean.leader.election.enable","configValue":"false","readOnly":false,"isDefault":true,"configSource":5,"isSensitive":false,"configSynonyms":[]},{"configName":"retention.bytes","configValue":"-1","readOnly":false,"isDefault":true,"configSource":5,"isSensitive":false,"configSynonyms":[]},{"configName":"delete.retention.ms","configValue":"86400000","readOnly":false,"isDefault":true,"configSource":5,"isSensitive":false,"configSynonyms":[]},{"configName":"segment.ms","configValue":"604800000","readOnly":false,"isDefault":true,"configSource":5,"isSensitive":false,"configSynonyms":[]},{"configName":"message.timestamp.difference.max.ms","configValue":"9223372036854775807","readOnly":false,"isDefault":true,"configSource":5,"isSensitive":false,"configSynonyms":[]},{"configName":"segment.index.bytes","configValue":"10485760","readOnly":false,"isDefault":true,"configSource":5,"isSensitive":false,"configSynonyms":[]}]}],"clientSideThrottleTime":0}}}
{"namespace":"Connection","level":5,"label":"DEBUG","log":{"timestamp":"2023-11-22T13:21:07.316Z","logger":"kafkajs","message":"disconnecting...","broker":"127.0.0.1:9093","clientId":"xxx"}}
{"namespace":"Connection","level":5,"label":"DEBUG","log":{"timestamp":"2023-11-22T13:21:07.316Z","logger":"kafkajs","message":"disconnecting...","broker":"127.0.0.1:9093","clientId":"xxx"}}
{"namespace":"Connection","level":5,"label":"DEBUG","log":{"timestamp":"2023-11-22T13:21:07.316Z","logger":"kafkajs","message":"disconnected","broker":"127.0.0.1:9093","clientId":"xxx"}}
{"namespace":"Connection","level":5,"label":"DEBUG","log":{"timestamp":"2023-11-22T13:21:07.317Z","logger":"kafkajs","message":"disconnected","broker":"127.0.0.1:9093","clientId":"xxx"}}
{"namespace":"Connection","level":5,"label":"DEBUG","log":{"timestamp":"2023-11-22T13:21:07.317Z","logger":"kafkajs","message":"disconnecting...","broker":"127.0.0.1:9093","clientId":"xxx"}}
{"namespace":"Connection","level":5,"label":"DEBUG","log":{"timestamp":"2023-11-22T13:21:07.317Z","logger":"kafkajs","message":"disconnecting...","broker":"127.0.0.1:9093","clientId":"xxx"}}
{"namespace":"Connection","level":5,"label":"DEBUG","log":{"timestamp":"2023-11-22T13:21:07.317Z","logger":"kafkajs","message":"disconnected","broker":"127.0.0.1:9093","clientId":"xxx"}}
{"namespace":"Connection","level":5,"label":"DEBUG","log":{"timestamp":"2023-11-22T13:21:07.317Z","logger":"kafkajs","message":"disconnected","broker":"127.0.0.1:9093","clientId":"xxx"}}
{"namespace":"Connection","level":5,"label":"DEBUG","log":{"timestamp":"2023-11-22T13:21:07.318Z","logger":"kafkajs","message":"Connecting","broker":"127.0.0.1:9093","clientId":"xxx","ssl":false,"sasl":false}}
{"namespace":"Connection","level":5,"label":"DEBUG","log":{"timestamp":"2023-11-22T13:21:07.321Z","logger":"kafkajs","message":"Request ApiVersions(key: 18, version: 2)","broker":"127.0.0.1:9093","clientId":"xxx","correlationId":0,"expectResponse":true,"size":34}}
{"namespace":"Connection","level":5,"label":"DEBUG","log":{"timestamp":"2023-11-22T13:21:07.321Z","logger":"kafkajs","message":"disconnecting...","broker":"127.0.0.1:9093","clientId":"xxx"}}
{"namespace":"Connection","level":5,"label":"DEBUG","log":{"timestamp":"2023-11-22T13:21:07.322Z","logger":"kafkajs","message":"disconnected","broker":"127.0.0.1:9093","clientId":"xxx"}}
{"namespace":"Connection","level":5,"label":"DEBUG","log":{"timestamp":"2023-11-22T13:21:07.322Z","logger":"kafkajs","message":"Response ApiVersions(key: 18, version: 2)","broker":"127.0.0.1:9093","clientId":"xxx","correlationId":0,"size":320,"data":{"errorCode":0,"apiVersions":[{"apiKey":0,"minVersion":0,"maxVersion":9},{"apiKey":1,"minVersion":0,"maxVersion":15},{"apiKey":2,"minVersion":0,"maxVersion":8},{"apiKey":3,"minVersion":0,"maxVersion":12},{"apiKey":8,"minVersion":0,"maxVersion":8},{"apiKey":9,"minVersion":0,"maxVersion":8},{"apiKey":10,"minVersion":0,"maxVersion":4},{"apiKey":11,"minVersion":0,"maxVersion":9},{"apiKey":12,"minVersion":0,"maxVersion":4},{"apiKey":13,"minVersion":0,"maxVersion":5},{"apiKey":14,"minVersion":0,"maxVersion":5},{"apiKey":15,"minVersion":0,"maxVersion":5},{"apiKey":16,"minVersion":0,"maxVersion":4},{"apiKey":17,"minVersion":0,"maxVersion":1},{"apiKey":18,"minVersion":0,"maxVersion":3},{"apiKey":19,"minVersion":0,"maxVersion":7},{"apiKey":20,"minVersion":0,"maxVersion":6},{"apiKey":21,"minVersion":0,"maxVersion":2},{"apiKey":22,"minVersion":0,"maxVersion":4},{"apiKey":23,"minVersion":0,"maxVersion":4},{"apiKey":24,"minVersion":0,"maxVersion":3},{"apiKey":25,"minVersion":0,"maxVersion":3},{"apiKey":26,"minVersion":0,"maxVersion":3},{"apiKey":27,"minVersion":0,"maxVersion":1},{"apiKey":28,"minVersion":0,"maxVersion":3},{"apiKey":29,"minVersion":0,"maxVersion":3},{"apiKey":30,"minVersion":0,"maxVersion":3},{"apiKey":31,"minVersion":0,"maxVersion":3},{"apiKey":32,"minVersion":0,"maxVersion":4},{"apiKey":33,"minVersion":0,"maxVersion":2},{"apiKey":34,"minVersion":0,"maxVersion":2},{"apiKey":35,"minVersion":0,"maxVersion":4},{"apiKey":36,"minVersion":0,"maxVersion":2},{"apiKey":37,"minVersion":0,"maxVersion":3},{"apiKey":42,"minVersion":0,"maxVersion":2},{"apiKey":43,"minVersion":0,"maxVersion":2},{"apiKey":44,"minVersion":0,"maxVersion":1},{"apiKey":45,"minVersion":0,"maxVersion":0},{"apiKey":46,"minVersion":0,"maxVersion":0},{"apiKey":47,"minVersion":0,"maxVersion":0},{"apiKey":48,"minVersion":0,"maxVersion":1},{"apiKey":49,"minVersion":0,"maxVersion":1},{"apiKey":50,"minVersion":0,"maxVersion":0},{"apiKey":51,"minVersion":0,"maxVersion":0},{"apiKey":55,"minVersion":0,"maxVersion":1},{"apiKey":57,"minVersion":0,"maxVersion":1},{"apiKey":60,"minVersion":0,"maxVersion":0},{"apiKey":61,"minVersion":0,"maxVersion":0},{"apiKey":64,"minVersion":0,"maxVersion":0},{"apiKey":65,"minVersion":0,"maxVersion":0},{"apiKey":66,"minVersion":0,"maxVersion":0}],"throttleTime":0,"clientSideThrottleTime":0}}}
{"namespace":"Broker","level":5,"label":"DEBUG","log":{"timestamp":"2023-11-22T13:21:07.323Z","logger":"kafkajs","message":"Verified support for SaslAuthenticate","broker":"127.0.0.1:9093","supportAuthenticationProtocol":true}}
{"namespace":"Connection","level":5,"label":"DEBUG","log":{"timestamp":"2023-11-22T13:21:07.323Z","logger":"kafkajs","message":"Request Metadata(key: 3, version: 6)","broker":"127.0.0.1:9093","clientId":"xxx","correlationId":1,"expectResponse":true,"size":52}}
{"namespace":"Connection","level":5,"label":"DEBUG","log":{"timestamp":"2023-11-22T13:21:07.324Z","logger":"kafkajs","message":"Response Metadata(key: 3, version: 6)","broker":"127.0.0.1:9093","clientId":"xxx","correlationId":1,"size":115,"data":{"throttleTime":0,"brokers":[{"nodeId":1,"host":"127.0.0.1","port":9093,"rack":null}],"clusterId":"ciWo7IWazngRchmPES6q5A","controllerId":1,"topicMetadata":[{"topicErrorCode":0,"topic":"yyy","isInternal":false,"partitionMetadata":[{"partitionErrorCode":0,"partitionId":0,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]}]}],"clientSideThrottleTime":0}}}
{"namespace":"Consumer","level":4,"label":"INFO","log":{"timestamp":"2023-11-22T13:21:07.326Z","logger":"kafkajs","message":"Starting","groupId":"zzz"}}
{"namespace":"Connection","level":5,"label":"DEBUG","log":{"timestamp":"2023-11-22T13:21:07.328Z","logger":"kafkajs","message":"Request GroupCoordinator(key: 10, version: 2)","broker":"127.0.0.1:9093","clientId":"xxx","correlationId":2,"expectResponse":true,"size":53}}
{"namespace":"Connection","level":5,"label":"DEBUG","log":{"timestamp":"2023-11-22T13:21:07.331Z","logger":"kafkajs","message":"Response GroupCoordinator(key: 10, version: 2)","broker":"127.0.0.1:9093","clientId":"xxx","correlationId":2,"size":35,"data":{"throttleTime":0,"errorCode":0,"errorMessage":"NONE","coordinator":{"nodeId":1,"host":"127.0.0.1","port":9093},"clientSideThrottleTime":0}}}
{"namespace":"Cluster","level":5,"label":"DEBUG","log":{"timestamp":"2023-11-22T13:21:07.331Z","logger":"kafkajs","message":"Found group coordinator","nodeId":1}}
{"namespace":"Connection","level":5,"label":"DEBUG","log":{"timestamp":"2023-11-22T13:21:07.332Z","logger":"kafkajs","message":"Request JoinGroup(key: 11, version: 5)","broker":"127.0.0.1:9093","clientId":"xxx","correlationId":3,"expectResponse":true,"size":125}}
{"namespace":"Connection","level":5,"label":"DEBUG","log":{"timestamp":"2023-11-22T13:21:07.335Z","logger":"kafkajs","message":"Request Metadata(key: 3, version: 6)","broker":"127.0.0.1:9093","clientId":"xxx","correlationId":1,"expectResponse":true,"size":54}}
{"namespace":"Connection","level":5,"label":"DEBUG","log":{"timestamp":"2023-11-22T13:21:07.335Z","logger":"kafkajs","message":"Response JoinGroup(key: 11, version: 5)","broker":"127.0.0.1:9093","clientId":"xxx","error":"The group member needs to have a valid member id before actually entering a consumer group","correlationId":3,"payload":{"type":"Buffer","data":"[filtered]"}}}
{"namespace":"Connection","level":5,"label":"DEBUG","log":{"timestamp":"2023-11-22T13:21:07.335Z","logger":"kafkajs","message":"Request JoinGroup(key: 11, version: 5)","broker":"127.0.0.1:9093","clientId":"xxx","correlationId":4,"expectResponse":true,"size":182}}
{"namespace":"Connection","level":5,"label":"DEBUG","log":{"timestamp":"2023-11-22T13:21:07.336Z","logger":"kafkajs","message":"Response Metadata(key: 3, version: 6)","broker":"127.0.0.1:9093","clientId":"xxx","correlationId":1,"size":117,"data":{"throttleTime":0,"brokers":[{"nodeId":1,"host":"127.0.0.1","port":9093,"rack":null}],"clusterId":"ciWo7IWazngRchmPES6q5A","controllerId":1,"topicMetadata":[{"topicErrorCode":0,"topic":"bbb","isInternal":false,"partitionMetadata":[{"partitionErrorCode":0,"partitionId":0,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]}]}],"clientSideThrottleTime":0}}}
{"namespace":"Connection","level":5,"label":"DEBUG","log":{"timestamp":"2023-11-22T13:21:07.340Z","logger":"kafkajs","message":"Request Produce(key: 0, version: 7)","broker":"127.0.0.1:9093","clientId":"xxx","correlationId":2,"expectResponse":true,"size":331}}
{"namespace":"Connection","level":5,"label":"DEBUG","log":{"timestamp":"2023-11-22T13:21:07.342Z","logger":"kafkajs","message":"Response Produce(key: 0, version: 7)","broker":"127.0.0.1:9093","clientId":"xxx","correlationId":2,"size":61,"data":{"topics":[{"topicName":"bbb","partitions":[{"partition":0,"errorCode":0,"baseOffset":"4561","logAppendTime":"-1","logStartOffset":"4559"}]}],"throttleTime":0,"clientSideThrottleTime":0}}}
{"namespace":"Connection","level":5,"label":"DEBUG","log":{"timestamp":"2023-11-22T13:21:07.344Z","logger":"kafkajs","message":"Request Produce(key: 0, version: 7)","broker":"127.0.0.1:9093","clientId":"xxx","correlationId":3,"expectResponse":true,"size":617}}
{"namespace":"Connection","level":5,"label":"DEBUG","log":{"timestamp":"2023-11-22T13:21:07.345Z","logger":"kafkajs","message":"Response Produce(key: 0, version: 7)","broker":"127.0.0.1:9093","clientId":"xxx","correlationId":3,"size":61,"data":{"topics":[{"topicName":"bbb","partitions":[{"partition":0,"errorCode":0,"baseOffset":"4562","logAppendTime":"-1","logStartOffset":"4559"}]}],"throttleTime":0,"clientSideThrottleTime":0}}}
{"namespace":"Consumer","level":4,"label":"INFO","log":{"timestamp":"2023-11-22T13:21:07.949Z","logger":"kafkajs","message":"Stopped","groupId":"zzz"}}
{"namespace":"Consumer","level":5,"label":"DEBUG","log":{"timestamp":"2023-11-22T13:21:07.949Z","logger":"kafkajs","message":"consumer has stopped, disconnecting","groupId":"zzz"}}
{"namespace":"Connection","level":5,"label":"DEBUG","log":{"timestamp":"2023-11-22T13:21:07.950Z","logger":"kafkajs","message":"disconnecting...","broker":"127.0.0.1:9093","clientId":"xxx"}}
{"namespace":"RequestQueue","level":5,"label":"DEBUG","log":{"timestamp":"2023-11-22T13:21:07.950Z","logger":"kafkajs","message":"Waiting for pending requests","clientId":"xxx","broker":"127.0.0.1:9093","currentInflightRequests":1,"currentPendingQueueSize":0}}
{"namespace":"Connection","level":5,"label":"DEBUG","log":{"timestamp":"2023-11-22T13:21:07.950Z","logger":"kafkajs","message":"disconnecting...","broker":"127.0.0.1:9093","clientId":"xxx"}}
{"namespace":"Connection","level":5,"label":"DEBUG","log":{"timestamp":"2023-11-22T13:21:07.950Z","logger":"kafkajs","message":"disconnected","broker":"127.0.0.1:9093","clientId":"xxx"}}
{"namespace":"Connection","level":5,"label":"DEBUG","log":{"timestamp":"2023-11-22T13:21:10.342Z","logger":"kafkajs","message":"disconnected","broker":"127.0.0.1:9093","clientId":"xxx"}}
{"namespace":"Connection","level":5,"label":"DEBUG","log":{"timestamp":"2023-11-22T13:21:10.343Z","logger":"kafkajs","message":"Response JoinGroup(key: 11, version: 5)","broker":"127.0.0.1:9093","clientId":"xxx","correlationId":4,"size":244,"data":{"throttleTime":0,"clientSideThrottleTime":0,"errorCode":0,"generationId":177,"groupProtocol":"RoundRobinAssigner","leaderId":"xxx-de5e2cee-6783-433a-b632-530fc8cf8651","memberId":"xxx-de5e2cee-6783-433a-b632-530fc8cf8651","members":[{"memberId":"xxx-de5e2cee-6783-433a-b632-530fc8cf8651","groupInstanceId":null,"memberMetadata":{"type":"Buffer","data":[0,0,0,0,0,1,0,11,116,111,45,100,101,118,105,99,101,45,49,0,0,0,0]}}]}}}
{"namespace":"Connection","level":5,"label":"DEBUG","log":{"timestamp":"2023-11-22T13:21:10.344Z","logger":"kafkajs","message":"disconnecting...","broker":"127.0.0.1:9093","clientId":"xxx"}}
{"namespace":"Connection","level":5,"label":"DEBUG","log":{"timestamp":"2023-11-22T13:21:10.344Z","logger":"kafkajs","message":"disconnecting...","broker":"127.0.0.1:9093","clientId":"xxx"}}
{"namespace":"Connection","level":5,"label":"DEBUG","log":{"timestamp":"2023-11-22T13:21:10.345Z","logger":"kafkajs","message":"disconnected","broker":"127.0.0.1:9093","clientId":"xxx"}}
{"namespace":"Connection","level":5,"label":"DEBUG","log":{"timestamp":"2023-11-22T13:21:10.345Z","logger":"kafkajs","message":"disconnected","broker":"127.0.0.1:9093","clientId":"xxx"}}
{"namespace":"ConsumerGroup","level":5,"label":"DEBUG","log":{"timestamp":"2023-11-22T13:21:10.346Z","logger":"kafkajs","message":"Chosen as group leader","groupId":"zzz","generationId":177,"memberId":"xxx-de5e2cee-6783-433a-b632-530fc8cf8651","topics":["yyy"]}}
{"namespace":"Connection","level":5,"label":"DEBUG","log":{"timestamp":"2023-11-22T13:21:10.347Z","logger":"kafkajs","message":"Connecting","broker":"127.0.0.1:9093","clientId":"xxx","ssl":false,"sasl":false}}
{"namespace":"Connection","level":5,"label":"DEBUG","log":{"timestamp":"2023-11-22T13:21:10.352Z","logger":"kafkajs","message":"Request Metadata(key: 3, version: 6)","broker":"127.0.0.1:9093","clientId":"xxx","correlationId":5,"expectResponse":true,"size":52}}
{"namespace":"Connection","level":5,"label":"DEBUG","log":{"timestamp":"2023-11-22T13:21:10.353Z","logger":"kafkajs","message":"Kafka server has closed connection","broker":"127.0.0.1:9093","clientId":"xxx"}}
{"namespace":"Connection","level":5,"label":"DEBUG","log":{"timestamp":"2023-11-22T13:21:10.354Z","logger":"kafkajs","message":"disconnecting...","broker":"127.0.0.1:9093","clientId":"xxx"}}
{"namespace":"Connection","level":5,"label":"DEBUG","log":{"timestamp":"2023-11-22T13:21:10.356Z","logger":"kafkajs","message":"disconnected","broker":"127.0.0.1:9093","clientId":"xxx"}}
{"namespace":"Connection","level":5,"label":"DEBUG","log":{"timestamp":"2023-11-22T13:21:10.356Z","logger":"kafkajs","message":"disconnecting...","broker":"127.0.0.1:9093","clientId":"xxx"}}
{"namespace":"Connection","level":5,"label":"DEBUG","log":{"timestamp":"2023-11-22T13:21:10.357Z","logger":"kafkajs","message":"disconnecting...","broker":"127.0.0.1:9093","clientId":"xxx"}}
{"namespace":"Connection","level":5,"label":"DEBUG","log":{"timestamp":"2023-11-22T13:21:10.357Z","logger":"kafkajs","message":"disconnected","broker":"127.0.0.1:9093","clientId":"xxx"}}
{"namespace":"Connection","level":5,"label":"DEBUG","log":{"timestamp":"2023-11-22T13:21:10.357Z","logger":"kafkajs","message":"disconnected","broker":"127.0.0.1:9093","clientId":"xxx"}}
{"namespace":"Consumer","level":1,"label":"ERROR","log":{"timestamp":"2023-11-22T13:21:10.359Z","logger":"kafkajs","message":"Crash: KafkaJSConnectionClosedError: Closed connection","groupId":"zzz","stack":"KafkaJSConnectionClosedError: Closed connection\n    at Socket.onEnd ([...]/node_modules/kafkajs/src/network/connection.js:197:13)\n    at Socket.emit (node:events:529:35)\n    at endReadableNT (node:internal/streams/readable:1368:12)\n    at processTicksAndRejections (node:internal/process/task_queues:82:21)"}}
{"namespace":"Consumer","level":4,"label":"INFO","log":{"timestamp":"2023-11-22T13:21:10.360Z","logger":"kafkajs","message":"Stopped","groupId":"zzz"}}
{"namespace":"Consumer","level":5,"label":"DEBUG","log":{"timestamp":"2023-11-22T13:21:10.360Z","logger":"kafkajs","message":"consumer has stopped, disconnecting","groupId":"zzz"}}
{"namespace":"Connection","level":5,"label":"DEBUG","log":{"timestamp":"2023-11-22T13:21:10.360Z","logger":"kafkajs","message":"disconnecting...","broker":"127.0.0.1:9093","clientId":"xxx"}}
{"namespace":"Connection","level":5,"label":"DEBUG","log":{"timestamp":"2023-11-22T13:21:10.361Z","logger":"kafkajs","message":"disconnecting...","broker":"127.0.0.1:9093","clientId":"xxx"}}
{"namespace":"Connection","level":5,"label":"DEBUG","log":{"timestamp":"2023-11-22T13:21:10.362Z","logger":"kafkajs","message":"disconnected","broker":"127.0.0.1:9093","clientId":"xxx"}}
{"namespace":"Connection","level":5,"label":"DEBUG","log":{"timestamp":"2023-11-22T13:21:10.362Z","logger":"kafkajs","message":"disconnected","broker":"127.0.0.1:9093","clientId":"xxx"}}
{"namespace":"RequestQueue","level":2,"label":"WARN","log":{"timestamp":"2023-11-22T13:21:10.363Z","logger":"kafkajs","message":"Response without match","clientId":"xxx","broker":"127.0.0.1:9093","correlationId":5}}
{"namespace":"Connection","level":5,"label":"DEBUG","log":{"timestamp":"2023-11-22T13:21:10.364Z","logger":"kafkajs","message":"disconnecting...","broker":"127.0.0.1:9093","clientId":"xxx"}}
{"namespace":"Connection","level":5,"label":"DEBUG","log":{"timestamp":"2023-11-22T13:21:10.365Z","logger":"kafkajs","message":"disconnected","broker":"127.0.0.1:9093","clientId":"xxx"}}

To Reproduce

  1. Run a consumer that subscribes to a topic
  2. Disconnect the consumer before the run promise resolves

Expected behavior
A clean disconnect

Observed behavior
A crash event, a Response without match event and not always, but pretty bad: not being disconnected at all, ie. the consumer just keeps consuming messages.

@everhardt
Copy link
Author

By the way, I tried with a patched version that includes #1148 and #1462, but that did not help.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

1 participant