Failed to create topic error code val=-197

[cjfarnold]

Description

Hi I am not able to create a topic using the confluent python API using the CLI provided by Kafka I am able to create the topics.

How to reproduce

Install Kafka version 2.12-2.8.1 on Windows
local requirements.txt for kafla client in python has the following
confluent-kafka[avro, json, protobuf]>=1.4.2

clientlogs

Checklist

Please provide the following information:

• confluent-kafka-python and librdkafka version (confluent_kafka.version() and confluent_kafka.libversion()):
• Apache Kafka broker version:
• Client configuration: {...}
• Operating system:
• Provide client logs (with 'debug': '..' as necessary)
• Provide broker log excerpts
• Critical issue

[edenhill]

Please try to reproduce on the latest version (1.7.0).

If still an issue, provide logs when configured with 'debug': 'broker,admin,protocol' and also provide the code for your CreateTopics call.

[cjfarnold]

Hi Magnus, This is the copy of the code: from confluent_kafka.admin import AdminClient, NewTopic import configparser config = configparser.ConfigParser() config.read("../config.conf") """ Kafka Configuration """ Topics = ["InitiateMatch","CompleteMatch"] class setupTopics(): # ,'debug':'broker,admin' def __init__(self): admin = AdminClient({'bootstrap.servers': '127.0.0.1:9092 ','debug':'broker,admin,protocol','compression.type':'none','group.id ':'mygroup'}) newtopics = [NewTopic(topic, num_partitions=1, replication_factor=1) for topic in Topics] self.schema = admin.create_topics(newtopics) def getTopics(self): for topic, t in self.schema.items(): try: t.result() return topic except Exception as e: print("Failed to create topic {}: {}".format(topic, e)) This is the copy of the log with version 1.7.0 runfile('D:/context/pubsub/admin.py', wdir='D:/context/pubsub') Failed to create topic InitiateMatch: KafkaError{code=_DESTROY,val=-197,str="Handle is terminating: Success"} Failed to create topic CompleteMatch: KafkaError{code=_DESTROY,val=-197,str="Handle is terminating: Success"} runfile('D:/context/pubsub/admin.py', wdir='D:/context/pubsub') Failed to create topic InitiateMatch: KafkaError{code=_DESTROY,val=-197,str="Handle is terminating: Success"} Failed to create topic CompleteMatch: KafkaError{code=_DESTROY,val=-197,str="Handle is terminating: Success"} runfile('D:/context/pubsub/admin.py', wdir='D:/context/pubsub') Failed to create topic InitiateMatch: KafkaError{code=_DESTROY,val=-197,str="Handle is terminating: Success"} Failed to create topic CompleteMatch: KafkaError{code=_DESTROY,val=-197,str="Handle is terminating: Success"} runfile('D:/context/pubsub/admin.py', wdir='D:/context/pubsub') Failed to create topic InitiateMatch: KafkaError{code=_DESTROY,val=-197,str="Handle is terminating: Local: Broker handle destroyed"} Failed to create topic CompleteMatch: KafkaError{code=_DESTROY,val=-197,str="Handle is terminating: Local: Broker handle destroyed"} %3|1641388116.211|FAIL|rdkafka#producer-1| [thrd:localhost9092:9092/bootstrap]: localhost9092:9092/bootstrap: Failed to resolve 'localhost9092:9092': No such host is known. (after 2317ms in state CONNECT) %3|1641388120.120|FAIL|rdkafka#producer-1| [thrd:localhost9092:9092/bootstrap]: localhost9092:9092/bootstrap: Failed to resolve 'localhost9092:9092': No such host is known. (after 2275ms in state CONNECT, 1 identical error(s) suppressed) %3|1641388152.314|FAIL|rdkafka#producer-1| [thrd:localhost9092:9092/bootstrap]: localhost9092:9092/bootstrap: Failed to resolve 'localhost9092:9092': No such host is known. (after 2271ms in state CONNECT, 8 identical error(s) suppressed) %3|1641388184.519|FAIL|rdkafka#producer-1| [thrd:localhost9092:9092/bootstrap]: localhost9092:9092/bootstrap: Failed to resolve 'localhost9092:9092': No such host is known. (after 2275ms in state CONNECT, 8 identical error(s) suppressed) %3|1641388216.750|FAIL|rdkafka#producer-1| [thrd:localhost9092:9092/bootstrap]: localhost9092:9092/bootstrap: Failed to resolve 'localhost9092:9092': No such host is known. (after 2281ms in state CONNECT, 8 identical error(s) suppressed) %3|1641388248.949|FAIL|rdkafka#producer-1| [thrd:localhost9092:9092/bootstrap]: localhost9092:9092/bootstrap: Failed to resolve 'localhost9092:9092': No such host is known. (after 2260ms in state CONNECT, 8 identical error(s) suppressed) %3|1641388277.743|FAIL|rdkafka#producer-2| [thrd:localhost9092:9092/bootstrap]: localhost9092:9092/bootstrap: Failed to resolve 'localhost9092:9092': No such host is known. (after 2286ms in state CONNECT) %3|1641388707.553|FAIL|rdkafka#producer-3| [thrd:localhost9092:9092/bootstrap]: localhost9092:9092/bootstrap: Failed to resolve 'localhost9092:9092': No such host is known. (after 2281ms in state CONNECT) %3|1641388784.186|FAIL|rdkafka#producer-4| [thrd:localhost9092:9092/bootstrap]: localhost9092:9092/bootstrap: Failed to resolve 'localhost9092:9092': No such host is known. (after 2265ms in state CONNECT) %7|1641457180.501|BROKER|rdkafka#producer-5| [thrd:app]: localhost9092:9092/bootstrap: Added new broker with NodeId -1 %7|1641457180.501|CONNECT|rdkafka#producer-5| [thrd:app]: localhost9092:9092/bootstrap: Selected for cluster connection: bootstrap servers added (broker has 0 connection attempt(s)) %7|1641457180.644|INIT|rdkafka#producer-5| [thrd:app]: librdkafka v1.7.0 (0x10700ff) rdkafka#producer-5 initialized (builtin.features gzip,snappy,ssl,sasl,regex,lz4,sasl_gssapi,sasl_plain,sasl_scram,plugins,zstd,sasl_oauthbearer, SSL ZLIB SNAPPY SASL_SCRAM PLUGINS HDRHISTOGRAM, debug 0x4002) %7|1641457180.644|DESTROY|rdkafka#producer-5| [thrd:app]: Terminating instance (destroy flags none (0x0)) %7|1641457180.644|BRKMAIN|rdkafka#producer-5| [thrd::0/internal]: :0/internal: Enter main broker thread %7|1641457180.644|CREATETOPICS|rdkafka#producer-5| [thrd:main]: CREATETOPICS worker called in state initializing: handle is terminating: Success %7|1641457180.644|ADMINFAIL|rdkafka#producer-5| [thrd:main]: Admin CREATETOPICS result error: Handle is terminating: Success %7|1641457180.644|DESTROY|rdkafka#producer-5| [thrd:main]: Destroy internal %7|1641457180.644|DESTROY|rdkafka#producer-5| [thrd:main]: Waiting for background queue thread to terminate %7|1641457180.645|BRKMAIN|rdkafka#producer-5| [thrd:localhost9092:9092/bootstrap]: localhost9092:9092/bootstrap: Enter main broker thread %7|1641457180.645|CONNECT|rdkafka#producer-5| [thrd:localhost9092:9092/bootstrap]: localhost9092:9092/bootstrap: Received CONNECT op %7|1641457180.645|STATE|rdkafka#producer-5| [thrd:localhost9092:9092/bootstrap]: localhost9092:9092/bootstrap: Broker changed state INIT -> TRY_CONNECT %7|1641457180.645|TERMINATE|rdkafka#producer-5| [thrd:localhost9092:9092/bootstrap]: localhost9092:9092/bootstrap: Handle is terminating in state TRY_CONNECT: 3 refcnts (000001C0E62DD6B8), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf %7|1641457180.645|DESTROY|rdkafka#producer-5| [thrd:main]: Removing all topics %7|1641457180.645|DESTROY|rdkafka#producer-5| [thrd:main]: Sending TERMINATE to localhost9092:9092/bootstrap %7|1641457180.645|TERM|rdkafka#producer-5| [thrd:localhost9092:9092/bootstrap]: localhost9092:9092/bootstrap: Received TERMINATE op in state TRY_CONNECT: 2 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs %7|1641457180.645|FAIL|rdkafka#producer-5| [thrd:localhost9092:9092/bootstrap]: localhost9092:9092/bootstrap: Client is terminating (after 0ms in state TRY_CONNECT) (_DESTROY) %7|1641457180.645|STATE|rdkafka#producer-5| [thrd:localhost9092:9092/bootstrap]: localhost9092:9092/bootstrap: Broker changed state TRY_CONNECT -> DOWN %7|1641457180.645|BRKTERM|rdkafka#producer-5| [thrd:localhost9092:9092/bootstrap]: localhost9092:9092/bootstrap: terminating: broker still has 2 refcnt(s), 0 buffer(s), 0 partition(s) %7|1641457180.645|CONNECT|rdkafka#producer-5| [thrd:localhost9092:9092/bootstrap]: localhost9092:9092/bootstrap: broker in state DOWN connecting %7|1641457180.645|STATE|rdkafka#producer-5| [thrd:localhost9092:9092/bootstrap]: localhost9092:9092/bootstrap: Broker changed state DOWN -> CONNECT %7|1641457180.645|TERM|rdkafka#producer-5| [thrd::0/internal]: :0/internal: Received TERMINATE op in state INIT: 2 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs %7|1641457180.645|FAIL|rdkafka#producer-5| [thrd::0/internal]: :0/internal: Client is terminating (after 151ms in state INIT) (_DESTROY) %7|1641457180.645|STATE|rdkafka#producer-5| [thrd::0/internal]: :0/internal: Broker changed state INIT -> DOWN %7|1641457180.645|BRKTERM|rdkafka#producer-5| [thrd::0/internal]: :0/internal: terminating: broker still has 2 refcnt(s), 0 buffer(s), 0 partition(s) %7|1641457180.645|TERMINATE|rdkafka#producer-5| [thrd::0/internal]: :0/internal: Handle is terminating in state DOWN: 1 refcnts (000001C0E65F9678), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf %7|1641457180.645|FAIL|rdkafka#producer-5| [thrd::0/internal]: :0/internal: Broker handle is terminating (after 0ms in state DOWN) (_DESTROY) %7|1641457182.966|FAIL|rdkafka#producer-5| [thrd:localhost9092:9092/bootstrap]: localhost9092:9092/bootstrap: Failed to resolve 'localhost9092:9092': No such host is known. (after 2320ms in state CONNECT) (_RESOLVE) %3|1641457182.966|FAIL|rdkafka#producer-5| [thrd:localhost9092:9092/bootstrap]: localhost9092:9092/bootstrap: Failed to resolve 'localhost9092:9092': No such host is known. (after 2320ms in state CONNECT) %7|1641457182.966|STATE|rdkafka#producer-5| [thrd:localhost9092:9092/bootstrap]: localhost9092:9092/bootstrap: Broker changed state CONNECT -> DOWN %7|1641457182.966|TERMINATE|rdkafka#producer-5| [thrd:localhost9092:9092/bootstrap]: localhost9092:9092/bootstrap: Handle is terminating in state DOWN: 1 refcnts (000001C0E62DD6B8), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf %7|1641457182.966|FAIL|rdkafka#producer-5| [thrd:localhost9092:9092/bootstrap]: localhost9092:9092/bootstrap: Broker handle is terminating (after 0ms in state DOWN) (_DESTROY) %7|1641457232.125|BROKER|rdkafka#producer-6| [thrd:app]: localhost:9092/bootstrap: Added new broker with NodeId -1 %7|1641457232.125|CONNECT|rdkafka#producer-6| [thrd:app]: localhost:9092/bootstrap: Selected for cluster connection: bootstrap servers added (broker has 0 connection attempt(s)) %7|1641457232.126|INIT|rdkafka#producer-6| [thrd:app]: librdkafka v1.7.0 (0x10700ff) rdkafka#producer-6 initialized (builtin.features gzip,snappy,ssl,sasl,regex,lz4,sasl_gssapi,sasl_plain,sasl_scram,plugins,zstd,sasl_oauthbearer, SSL ZLIB SNAPPY SASL_SCRAM PLUGINS HDRHISTOGRAM, debug 0x4002) %7|1641457232.126|DESTROY|rdkafka#producer-6| [thrd:app]: Terminating instance (destroy flags none (0x0)) %7|1641457232.126|CREATETOPICS|rdkafka#producer-6| [thrd:main]: CREATETOPICS worker called in state initializing: handle is terminating: Success %7|1641457232.126|ADMINFAIL|rdkafka#producer-6| [thrd:main]: Admin CREATETOPICS result error: Handle is terminating: Success %7|1641457232.126|DESTROY|rdkafka#producer-6| [thrd:main]: Destroy internal %7|1641457232.126|DESTROY|rdkafka#producer-6| [thrd:main]: Waiting for background queue thread to terminate %7|1641457232.170|BRKMAIN|rdkafka#producer-6| [thrd::0/internal]: :0/internal: Enter main broker thread %7|1641457232.170|BRKMAIN|rdkafka#producer-6| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enter main broker thread %7|1641457232.170|CONNECT|rdkafka#producer-6| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received CONNECT op %7|1641457232.170|STATE|rdkafka#producer-6| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state INIT -> TRY_CONNECT %7|1641457232.170|TERMINATE|rdkafka#producer-6| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Handle is terminating in state TRY_CONNECT: 3 refcnts (000001C0E62DE708), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf %7|1641457232.170|DESTROY|rdkafka#producer-6| [thrd:main]: Removing all topics %7|1641457232.170|DESTROY|rdkafka#producer-6| [thrd:main]: Sending TERMINATE to localhost:9092/bootstrap %7|1641457232.170|TERM|rdkafka#producer-6| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received TERMINATE op in state TRY_CONNECT: 2 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs %7|1641457232.170|FAIL|rdkafka#producer-6| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Client is terminating (after 0ms in state TRY_CONNECT) (_DESTROY) %7|1641457232.170|STATE|rdkafka#producer-6| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state TRY_CONNECT -> DOWN %7|1641457232.170|BRKTERM|rdkafka#producer-6| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: terminating: broker still has 2 refcnt(s), 0 buffer(s), 0 partition(s) %7|1641457232.170|CONNECT|rdkafka#producer-6| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: broker in state DOWN connecting %7|1641457232.170|STATE|rdkafka#producer-6| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state DOWN -> CONNECT %7|1641457232.170|TERM|rdkafka#producer-6| [thrd::0/internal]: :0/internal: Received TERMINATE op in state INIT: 2 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs %7|1641457232.170|FAIL|rdkafka#producer-6| [thrd::0/internal]: :0/internal: Client is terminating (after 49ms in state INIT) (_DESTROY) %7|1641457232.170|STATE|rdkafka#producer-6| [thrd::0/internal]: :0/internal: Broker changed state INIT -> DOWN %7|1641457232.170|BRKTERM|rdkafka#producer-6| [thrd::0/internal]: :0/internal: terminating: broker still has 2 refcnt(s), 0 buffer(s), 0 partition(s) %7|1641457232.170|TERMINATE|rdkafka#producer-6| [thrd::0/internal]: :0/internal: Handle is terminating in state DOWN: 1 refcnts (000001C0E65F9678), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf %7|1641457232.170|FAIL|rdkafka#producer-6| [thrd::0/internal]: :0/internal: Broker handle is terminating (after 0ms in state DOWN) (_DESTROY) %7|1641457232.252|CONNECT|rdkafka#producer-6| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connecting to ipv4#127.0.0.1:9092 (plaintext) with socket 2640 %7|1641457232.254|TERMINATE|rdkafka#producer-6| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Handle is terminating in state CONNECT: 1 refcnts (000001C0E62DE708), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf %7|1641457232.254|FAIL|rdkafka#producer-6| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker handle is terminating (after 83ms in state CONNECT) (_DESTROY) %7|1641457232.254|STATE|rdkafka#producer-6| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state CONNECT -> DOWN %7|1641457277.385|BROKER|rdkafka#producer-7| [thrd:app]: localhost:9092/bootstrap: Added new broker with NodeId -1 %7|1641457277.385|CONNECT|rdkafka#producer-7| [thrd:app]: localhost:9092/bootstrap: Selected for cluster connection: bootstrap servers added (broker has 0 connection attempt(s)) %7|1641457277.439|BRKMAIN|rdkafka#producer-7| [thrd::0/internal]: :0/internal: Enter main broker thread %7|1641457277.440|BRKMAIN|rdkafka#producer-7| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enter main broker thread %7|1641457277.440|CONNECT|rdkafka#producer-7| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received CONNECT op %7|1641457277.440|STATE|rdkafka#producer-7| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state INIT -> TRY_CONNECT %7|1641457277.440|CONNECT|rdkafka#producer-7| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: broker in state TRY_CONNECT connecting %7|1641457277.440|STATE|rdkafka#producer-7| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state TRY_CONNECT -> CONNECT %7|1641457277.440|INIT|rdkafka#producer-7| [thrd:app]: librdkafka v1.7.0 (0x10700ff) rdkafka#producer-7 initialized (builtin.features gzip,snappy,ssl,sasl,regex,lz4,sasl_gssapi,sasl_plain,sasl_scram,plugins,zstd,sasl_oauthbearer, SSL ZLIB SNAPPY SASL_SCRAM PLUGINS HDRHISTOGRAM, debug 0x4002) %7|1641457277.440|DESTROY|rdkafka#producer-7| [thrd:app]: Terminating instance (destroy flags none (0x0)) %7|1641457277.440|CREATETOPICS|rdkafka#producer-7| [thrd:main]: CREATETOPICS worker called in state initializing: handle is terminating: Success %7|1641457277.440|ADMINFAIL|rdkafka#producer-7| [thrd:main]: Admin CREATETOPICS result error: Handle is terminating: Success %7|1641457277.440|DESTROY|rdkafka#producer-7| [thrd:main]: Destroy internal %7|1641457277.440|DESTROY|rdkafka#producer-7| [thrd:main]: Waiting for background queue thread to terminate %7|1641457277.440|DESTROY|rdkafka#producer-7| [thrd:main]: Removing all topics %7|1641457277.440|DESTROY|rdkafka#producer-7| [thrd:main]: Sending TERMINATE to localhost:9092/bootstrap %7|1641457277.441|TERM|rdkafka#producer-7| [thrd::0/internal]: :0/internal: Received TERMINATE op in state INIT: 2 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs %7|1641457277.441|FAIL|rdkafka#producer-7| [thrd::0/internal]: :0/internal: Client is terminating (after 60ms in state INIT) (_DESTROY) %7|1641457277.441|STATE|rdkafka#producer-7| [thrd::0/internal]: :0/internal: Broker changed state INIT -> DOWN %7|1641457277.441|BRKTERM|rdkafka#producer-7| [thrd::0/internal]: :0/internal: terminating: broker still has 2 refcnt(s), 0 buffer(s), 0 partition(s) %7|1641457277.441|TERMINATE|rdkafka#producer-7| [thrd::0/internal]: :0/internal: Handle is terminating in state DOWN: 1 refcnts (000001C0E62DD6B8), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf %7|1641457277.441|FAIL|rdkafka#producer-7| [thrd::0/internal]: :0/internal: Broker handle is terminating (after 0ms in state DOWN) (_DESTROY) %7|1641457277.442|CONNECT|rdkafka#producer-7| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connecting to ipv4#127.0.0.1:9092 (plaintext) with socket 2724 %7|1641457277.444|TERMINATE|rdkafka#producer-7| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Handle is terminating in state CONNECT: 2 refcnts (000001C0E6658878), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf %7|1641457277.444|CONNECT|rdkafka#producer-7| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connected to ipv4#127.0.0.1:9092 %7|1641457277.444|CONNECTED|rdkafka#producer-7| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connected (#1) %7|1641457277.444|FEATURE|rdkafka#producer-7| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Updated enabled protocol features +ApiVersion to ApiVersion %7|1641457277.444|STATE|rdkafka#producer-7| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state CONNECT -> APIVERSION_QUERY %7|1641457277.444|TERM|rdkafka#producer-7| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received TERMINATE op in state APIVERSION_QUERY: 3 refcnts, 0 toppar(s), 0 active toppar(s), 1 outbufs, 0 waitresps, 0 retrybufs %7|1641457277.444|FAIL|rdkafka#producer-7| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Client is terminating (after 0ms in state APIVERSION_QUERY) (_DESTROY) %7|1641457277.444|FEATURE|rdkafka#producer-7| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Updated enabled protocol features -ApiVersion to %7|1641457277.444|STATE|rdkafka#producer-7| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state APIVERSION_QUERY -> DOWN %7|1641457277.444|BRKTERM|rdkafka#producer-7| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: terminating: broker still has 2 refcnt(s), 0 buffer(s), 0 partition(s) %7|1641457277.444|TERMINATE|rdkafka#producer-7| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Handle is terminating in state DOWN: 1 refcnts (000001C0E6658878), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf %7|1641457277.444|FAIL|rdkafka#producer-7| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker handle is terminating (after 0ms in state DOWN) (_DESTROY) %7|1641458167.248|BRKMAIN|rdkafka#producer-8| [thrd::0/internal]: :0/internal: Enter main broker thread %7|1641458167.250|BROKER|rdkafka#producer-8| [thrd:app]: localhost:9092/bootstrap: Added new broker with NodeId -1 %7|1641458167.250|CONNECT|rdkafka#producer-8| [thrd:app]: localhost:9092/bootstrap: Selected for cluster connection: bootstrap servers added (broker has 0 connection attempt(s)) %7|1641458167.250|INIT|rdkafka#producer-8| [thrd:app]: librdkafka v1.7.0 (0x10700ff) rdkafka#producer-8 initialized (builtin.features gzip,snappy,ssl,sasl,regex,lz4,sasl_gssapi,sasl_plain,sasl_scram,plugins,zstd,sasl_oauthbearer, SSL ZLIB SNAPPY SASL_SCRAM PLUGINS HDRHISTOGRAM, debug 0x4002) %7|1641458167.250|BRKMAIN|rdkafka#producer-8| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enter main broker thread %7|1641458167.250|DESTROY|rdkafka#producer-8| [thrd:app]: Terminating instance (destroy flags none (0x0)) %7|1641458167.250|CREATETOPICS|rdkafka#producer-8| [thrd:main]: CREATETOPICS worker called in state initializing: Success %7|1641458167.250|ADMIN|rdkafka#producer-8| [thrd:main]: CREATETOPICS: looking up controller %7|1641458167.250|CONNECT|rdkafka#producer-8| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received CONNECT op %7|1641458167.250|STATE|rdkafka#producer-8| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state INIT -> TRY_CONNECT %7|1641458167.250|TERMINATE|rdkafka#producer-8| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Handle is terminating in state TRY_CONNECT: 3 refcnts (000001C0E646EDD8), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf %7|1641458167.250|CONNECT|rdkafka#producer-8| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: lookup controller %7|1641458167.250|CONNECT|rdkafka#producer-8| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: lookup controller %7|1641458167.250|DESTROY|rdkafka#producer-8| [thrd:main]: Destroy internal %7|1641458167.250|CREATETOPICS|rdkafka#producer-8| [thrd:main]: CREATETOPICS worker called in state waiting for controller: handle is terminating: Local: Broker handle destroyed %7|1641458167.250|ADMINFAIL|rdkafka#producer-8| [thrd:main]: Admin CREATETOPICS result error: Handle is terminating: Local: Broker handle destroyed %7|1641458167.250|DESTROY|rdkafka#producer-8| [thrd:main]: Waiting for background queue thread to terminate %7|1641458167.250|DESTROY|rdkafka#producer-8| [thrd:main]: Removing all topics %7|1641458167.250|DESTROY|rdkafka#producer-8| [thrd:main]: Sending TERMINATE to localhost:9092/bootstrap %7|1641458167.250|TERM|rdkafka#producer-8| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received TERMINATE op in state TRY_CONNECT: 2 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs %7|1641458167.250|FAIL|rdkafka#producer-8| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Client is terminating (after 0ms in state TRY_CONNECT) (_DESTROY) %7|1641458167.250|STATE|rdkafka#producer-8| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state TRY_CONNECT -> DOWN %7|1641458167.250|BRKTERM|rdkafka#producer-8| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: terminating: broker still has 2 refcnt(s), 0 buffer(s), 0 partition(s) %7|1641458167.250|CONNECT|rdkafka#producer-8| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: broker in state DOWN connecting %7|1641458167.250|STATE|rdkafka#producer-8| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state DOWN -> CONNECT %7|1641458167.250|TERM|rdkafka#producer-8| [thrd::0/internal]: :0/internal: Received TERMINATE op in state INIT: 2 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs %7|1641458167.250|FAIL|rdkafka#producer-8| [thrd::0/internal]: :0/internal: Client is terminating (after 5ms in state INIT) (_DESTROY) %7|1641458167.250|STATE|rdkafka#producer-8| [thrd::0/internal]: :0/internal: Broker changed state INIT -> DOWN %7|1641458167.250|BRKTERM|rdkafka#producer-8| [thrd::0/internal]: :0/internal: terminating: broker still has 2 refcnt(s), 0 buffer(s), 0 partition(s) %7|1641458167.250|TERMINATE|rdkafka#producer-8| [thrd::0/internal]: :0/internal: Handle is terminating in state DOWN: 1 refcnts (000001C0E646BB98), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf %7|1641458167.250|FAIL|rdkafka#producer-8| [thrd::0/internal]: :0/internal: Broker handle is terminating (after 0ms in state DOWN) (_DESTROY) %7|1641458167.253|CONNECT|rdkafka#producer-8| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connecting to ipv4#127.0.0.1:9092 (plaintext) with socket 2948 %7|1641458167.255|TERMINATE|rdkafka#producer-8| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Handle is terminating in state CONNECT: 1 refcnts (000001C0E646EDD8), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf %7|1641458167.255|FAIL|rdkafka#producer-8| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker handle is terminating (after 4ms in state CONNECT) (_DESTROY) %7|1641458167.255|STATE|rdkafka#producer-8| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state CONNECT -> DOWN %7|1641461149.006|BRKMAIN|rdkafka#producer-9| [thrd::0/internal]: :0/internal: Enter main broker thread %7|1641461149.009|BROKER|rdkafka#producer-9| [thrd:app]: 127.0.0.1:9092/bootstrap: Added new broker with NodeId -1 %7|1641461149.009|CONNECT|rdkafka#producer-9| [thrd:app]: 127.0.0.1:9092/bootstrap: Selected for cluster connection: bootstrap servers added (broker has 0 connection attempt(s)) %7|1641461149.009|INIT|rdkafka#producer-9| [thrd:app]: librdkafka v1.7.0 (0x10700ff) rdkafka#producer-9 initialized (builtin.features gzip,snappy,ssl,sasl,regex,lz4,sasl_gssapi,sasl_plain,sasl_scram,plugins,zstd,sasl_oauthbearer, SSL ZLIB SNAPPY SASL_SCRAM PLUGINS HDRHISTOGRAM, debug 0x4002) %7|1641461149.009|BRKMAIN|rdkafka#producer-9| [thrd:127.0.0.1:9092/bootstrap]: 127.0.0.1:9092/bootstrap: Enter main broker thread %7|1641461149.009|DESTROY|rdkafka#producer-9| [thrd:app]: Terminating instance (destroy flags none (0x0)) %7|1641461149.009|CONNECT|rdkafka#producer-9| [thrd:127.0.0.1:9092/bootstrap]: 127.0.0.1:9092/bootstrap: Received CONNECT op %7|1641461149.009|STATE|rdkafka#producer-9| [thrd:127.0.0.1:9092/bootstrap]: 127.0.0.1:9092/bootstrap: Broker changed state INIT -> TRY_CONNECT %7|1641461149.009|TERMINATE|rdkafka#producer-9| [thrd: 127.0.0.1:9092/bootstrap]: 127.0.0.1:9092/bootstrap: Handle is terminating in state TRY_CONNECT: 3 refcnts (000001C0E646FA68), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf %7|1641461149.009|CREATETOPICS|rdkafka#producer-9| [thrd:main]: CREATETOPICS worker called in state initializing: handle is terminating: Success %7|1641461149.009|ADMINFAIL|rdkafka#producer-9| [thrd:main]: Admin CREATETOPICS result error: Handle is terminating: Success %7|1641461149.009|DESTROY|rdkafka#producer-9| [thrd:main]: Destroy internal %7|1641461149.009|DESTROY|rdkafka#producer-9| [thrd:main]: Waiting for background queue thread to terminate %7|1641461149.010|DESTROY|rdkafka#producer-9| [thrd:main]: Removing all topics %7|1641461149.010|DESTROY|rdkafka#producer-9| [thrd:main]: Sending TERMINATE to 127.0.0.1:9092/bootstrap %7|1641461149.010|TERM|rdkafka#producer-9| [thrd:127.0.0.1:9092/bootstrap]: 127.0.0.1:9092/bootstrap: Received TERMINATE op in state TRY_CONNECT: 2 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs %7|1641461149.010|FAIL|rdkafka#producer-9| [thrd:127.0.0.1:9092/bootstrap]: 127.0.0.1:9092/bootstrap: Client is terminating (after 0ms in state TRY_CONNECT) (_DESTROY) %7|1641461149.010|STATE|rdkafka#producer-9| [thrd:127.0.0.1:9092/bootstrap]: 127.0.0.1:9092/bootstrap: Broker changed state TRY_CONNECT -> DOWN %7|1641461149.010|TERM|rdkafka#producer-9| [thrd::0/internal]: :0/internal: Received TERMINATE op in state INIT: 2 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs %7|1641461149.010|BRKTERM|rdkafka#producer-9| [thrd:127.0.0.1:9092/bootstrap]: 127.0.0.1:9092/bootstrap: terminating: broker still has 2 refcnt(s), 0 buffer(s), 0 partition(s) %7|1641461149.010|FAIL|rdkafka#producer-9| [thrd::0/internal]: :0/internal: Client is terminating (after 6ms in state INIT) (_DESTROY) %7|1641461149.010|CONNECT|rdkafka#producer-9| [thrd:127.0.0.1:9092/bootstrap]: 127.0.0.1:9092/bootstrap: broker in state DOWN connecting %7|1641461149.010|STATE|rdkafka#producer-9| [thrd::0/internal]: :0/internal: Broker changed state INIT -> DOWN %7|1641461149.010|STATE|rdkafka#producer-9| [thrd:127.0.0.1:9092/bootstrap]: 127.0.0.1:9092/bootstrap: Broker changed state DOWN -> CONNECT %7|1641461149.010|BRKTERM|rdkafka#producer-9| [thrd::0/internal]: :0/internal: terminating: broker still has 2 refcnt(s), 0 buffer(s), 0 partition(s) %7|1641461149.010|TERMINATE|rdkafka#producer-9| [thrd::0/internal]: :0/internal: Handle is terminating in state DOWN: 1 refcnts (000001C0E646EDD8), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf %7|1641461149.010|FAIL|rdkafka#producer-9| [thrd::0/internal]: :0/internal: Broker handle is terminating (after 0ms in state DOWN) (_DESTROY) %7|1641461149.010|CONNECT|rdkafka#producer-9| [thrd:127.0.0.1:9092/bootstrap]: 127.0.0.1:9092/bootstrap: Connecting to ipv4#127.0.0.1:9092 (plaintext) with socket 2812 %7|1641461149.012|TERMINATE|rdkafka#producer-9| [thrd: 127.0.0.1:9092/bootstrap]: 127.0.0.1:9092/bootstrap: Handle is terminating in state CONNECT: 1 refcnts (000001C0E646FA68), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf %7|1641461149.012|FAIL|rdkafka#producer-9| [thrd:127.0.0.1:9092/bootstrap]: 127.0.0.1:9092/bootstrap: Broker handle is terminating (after 2ms in state CONNECT) (_DESTROY) %7|1641461149.012|STATE|rdkafka#producer-9| [thrd:127.0.0.1:9092/bootstrap]: 127.0.0.1:9092/bootstrap: Broker changed state CONNECT -> DOWN %7|1641471614.357|BROKER|rdkafka#producer-10| [thrd:app]: 127.0.0.1:9092/bootstrap: Added new broker with NodeId -1 %7|1641471614.357|CONNECT|rdkafka#producer-10| [thrd:app]: 127.0.0.1:9092/bootstrap: Selected for cluster connection: bootstrap servers added (broker has 0 connection attempt(s)) %7|1641471614.433|INIT|rdkafka#producer-10| [thrd:app]: librdkafka v1.7.0 (0x10700ff) rdkafka#producer-10 initialized (builtin.features gzip,snappy,ssl,sasl,regex,lz4,sasl_gssapi,sasl_plain,sasl_scram,plugins,zstd,sasl_oauthbearer, SSL ZLIB SNAPPY SASL_SCRAM PLUGINS HDRHISTOGRAM, debug 0x4002) %4|1641471614.433|CONFWARN|rdkafka#producer-10| [thrd:app]: Configuration property group.id is a consumer property and will be ignored by this producer instance %7|1641471614.433|BRKMAIN|rdkafka#producer-10| [thrd::0/internal]: :0/internal: Enter main broker thread %7|1641471614.433|CREATETOPICS|rdkafka#producer-10| [thrd:main]: CREATETOPICS worker called in state initializing: Success %7|1641471614.433|ADMIN|rdkafka#producer-10| [thrd:main]: CREATETOPICS: looking up controller %7|1641471614.433|BRKMAIN|rdkafka#producer-10| [thrd: 127.0.0.1:9092/bootstrap]: 127.0.0.1:9092/bootstrap: Enter main broker thread %7|1641471614.433|CONNECT|rdkafka#producer-10| [thrd:main]: 127.0.0.1:9092/bootstrap: Selected for cluster connection: lookup controller (broker has 0 connection attempt(s)) %7|1641471614.433|CONNECT|rdkafka#producer-10| [thrd: 127.0.0.1:9092/bootstrap]: 127.0.0.1:9092/bootstrap: Received CONNECT op %7|1641471614.433|DESTROY|rdkafka#producer-10| [thrd:app]: Terminating instance (destroy flags none (0x0)) %7|1641471614.433|STATE|rdkafka#producer-10| [thrd:127.0.0.1:9092/bootstrap]: 127.0.0.1:9092/bootstrap: Broker changed state INIT -> TRY_CONNECT %7|1641471614.433|TERMINATE|rdkafka#producer-10| [thrd: 127.0.0.1:9092/bootstrap]: 127.0.0.1:9092/bootstrap: Handle is terminating in state TRY_CONNECT: 3 refcnts (000001C0E646D4B8), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf %7|1641471614.433|CREATETOPICS|rdkafka#producer-10| [thrd:main]: CREATETOPICS worker called in state waiting for controller: handle is terminating: Success %7|1641471614.433|CONNECT|rdkafka#producer-10| [thrd: 127.0.0.1:9092/bootstrap]: 127.0.0.1:9092/bootstrap: broker in state TRY_CONNECT connecting %7|1641471614.433|STATE|rdkafka#producer-10| [thrd:127.0.0.1:9092/bootstrap]: 127.0.0.1:9092/bootstrap: Broker changed state TRY_CONNECT -> CONNECT %7|1641471614.433|ADMINFAIL|rdkafka#producer-10| [thrd:main]: Admin CREATETOPICS result error: Handle is terminating: Success %7|1641471614.433|DESTROY|rdkafka#producer-10| [thrd:main]: Destroy internal %7|1641471614.433|DESTROY|rdkafka#producer-10| [thrd:main]: Waiting for background queue thread to terminate %6|1641471614.434|BGQUEUE|rdkafka#producer-10| [thrd:background]: Purging 1 unserved events from background queue %7|1641471614.434|CONNECT|rdkafka#producer-10| [thrd: 127.0.0.1:9092/bootstrap]: 127.0.0.1:9092/bootstrap: Connecting to ipv4# 127.0.0.1:9092 (plaintext) with socket 2828 %7|1641471614.434|DESTROY|rdkafka#producer-10| [thrd:main]: Removing all topics %7|1641471614.434|DESTROY|rdkafka#producer-10| [thrd:main]: Sending TERMINATE to 127.0.0.1:9092/bootstrap %7|1641471614.434|TERM|rdkafka#producer-10| [thrd::0/internal]: :0/internal: Received TERMINATE op in state INIT: 2 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs %7|1641471614.434|FAIL|rdkafka#producer-10| [thrd::0/internal]: :0/internal: Client is terminating (after 82ms in state INIT) (_DESTROY) %7|1641471614.434|STATE|rdkafka#producer-10| [thrd::0/internal]: :0/internal: Broker changed state INIT -> DOWN %7|1641471614.434|BRKTERM|rdkafka#producer-10| [thrd::0/internal]: :0/internal: terminating: broker still has 2 refcnt(s), 0 buffer(s), 0 partition(s) %7|1641471614.434|TERMINATE|rdkafka#producer-10| [thrd::0/internal]: :0/internal: Handle is terminating in state DOWN: 1 refcnts (000001C0E646EDD8), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf %7|1641471614.434|FAIL|rdkafka#producer-10| [thrd::0/internal]: :0/internal: Broker handle is terminating (after 0ms in state DOWN) (_DESTROY) %7|1641471614.436|TERMINATE|rdkafka#producer-10| [thrd: 127.0.0.1:9092/bootstrap]: 127.0.0.1:9092/bootstrap: Handle is terminating in state CONNECT: 2 refcnts (000001C0E646D4B8), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf %7|1641471614.436|CONNECT|rdkafka#producer-10| [thrd: 127.0.0.1:9092/bootstrap]: 127.0.0.1:9092/bootstrap: Connected to ipv4# 127.0.0.1:9092 %7|1641471614.436|CONNECTED|rdkafka#producer-10| [thrd: 127.0.0.1:9092/bootstrap]: 127.0.0.1:9092/bootstrap: Connected (#1) %7|1641471614.436|FEATURE|rdkafka#producer-10| [thrd: 127.0.0.1:9092/bootstrap]: 127.0.0.1:9092/bootstrap: Updated enabled protocol features +ApiVersion to ApiVersion %7|1641471614.436|STATE|rdkafka#producer-10| [thrd:127.0.0.1:9092/bootstrap]: 127.0.0.1:9092/bootstrap: Broker changed state CONNECT -> APIVERSION_QUERY %7|1641471614.436|TERM|rdkafka#producer-10| [thrd:127.0.0.1:9092/bootstrap]: 127.0.0.1:9092/bootstrap: Received TERMINATE op in state APIVERSION_QUERY: 3 refcnts, 0 toppar(s), 0 active toppar(s), 1 outbufs, 0 waitresps, 0 retrybufs %7|1641471614.436|FAIL|rdkafka#producer-10| [thrd:127.0.0.1:9092/bootstrap]: 127.0.0.1:9092/bootstrap: Client is terminating (after 0ms in state APIVERSION_QUERY) (_DESTROY) %7|1641471614.436|FEATURE|rdkafka#producer-10| [thrd: 127.0.0.1:9092/bootstrap]: 127.0.0.1:9092/bootstrap: Updated enabled protocol features -ApiVersion to %7|1641471614.436|STATE|rdkafka#producer-10| [thrd:127.0.0.1:9092/bootstrap]: 127.0.0.1:9092/bootstrap: Broker changed state APIVERSION_QUERY -> DOWN %7|1641471614.436|BRKTERM|rdkafka#producer-10| [thrd: 127.0.0.1:9092/bootstrap]: 127.0.0.1:9092/bootstrap: terminating: broker still has 2 refcnt(s), 0 buffer(s), 0 partition(s) %7|1641471614.436|TERMINATE|rdkafka#producer-10| [thrd: 127.0.0.1:9092/bootstrap]: 127.0.0.1:9092/bootstrap: Handle is terminating in state DOWN: 1 refcnts (000001C0E646D4B8), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf %7|1641471614.436|FAIL|rdkafka#producer-10| [thrd:127.0.0.1:9092/bootstrap]: 127.0.0.1:9092/bootstrap: Broker handle is terminating (after 0ms in state DOWN) (_DESTROY) %4|1641472061.477|CONFWARN|rdkafka#producer-11| [thrd:app]: Configuration property group.id is a consumer property and will be ignored by this producer instance %7|1641472231.721|BRKMAIN|rdkafka#producer-12| [thrd::0/internal]: :0/internal: Enter main broker thread %7|1641472231.724|BROKER|rdkafka#producer-12| [thrd:app]: localhost:9092/bootstrap: Added new broker with NodeId -1 %7|1641472231.724|CONNECT|rdkafka#producer-12| [thrd:app]: localhost:9092/bootstrap: Selected for cluster connection: bootstrap servers added (broker has 0 connection attempt(s)) %7|1641472231.725|INIT|rdkafka#producer-12| [thrd:app]: librdkafka v1.7.0 (0x10700ff) rdkafka#producer-12 initialized (builtin.features gzip,snappy,ssl,sasl,regex,lz4,sasl_gssapi,sasl_plain,sasl_scram,plugins,zstd,sasl_oauthbearer, SSL ZLIB SNAPPY SASL_SCRAM PLUGINS HDRHISTOGRAM, debug 0x4002) %4|1641472231.725|CONFWARN|rdkafka#producer-12| [thrd:app]: Configuration property group.id is a consumer property and will be ignored by this producer instance %7|1641472231.725|BRKMAIN|rdkafka#producer-12| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enter main broker thread %7|1641472231.725|CONNECT|rdkafka#producer-12| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received CONNECT op %7|1641472231.725|STATE|rdkafka#producer-12| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state INIT -> TRY_CONNECT %7|1641472231.725|CONNECT|rdkafka#producer-12| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: broker in state TRY_CONNECT connecting %7|1641472231.725|STATE|rdkafka#producer-12| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state TRY_CONNECT -> CONNECT %7|1641472231.725|DESTROY|rdkafka#producer-12| [thrd:app]: Terminating instance (destroy flags none (0x0)) %7|1641472231.725|CREATETOPICS|rdkafka#producer-12| [thrd:main]: CREATETOPICS worker called in state initializing: Success %7|1641472231.725|ADMIN|rdkafka#producer-12| [thrd:main]: CREATETOPICS: looking up controller %7|1641472231.725|CONNECT|rdkafka#producer-12| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: lookup controller %7|1641472231.725|DESTROY|rdkafka#producer-12| [thrd:main]: Destroy internal %7|1641472231.725|CREATETOPICS|rdkafka#producer-12| [thrd:main]: CREATETOPICS worker called in state waiting for controller: handle is terminating: Local: Broker handle destroyed %7|1641472231.725|ADMINFAIL|rdkafka#producer-12| [thrd:main]: Admin CREATETOPICS result error: Handle is terminating: Local: Broker handle destroyed %7|1641472231.725|DESTROY|rdkafka#producer-12| [thrd:main]: Waiting for background queue thread to terminate %7|1641472231.729|CONNECT|rdkafka#producer-12| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connecting to ipv4#127.0.0.1:9092 (plaintext) with socket 2868 %7|1641472231.732|TERMINATE|rdkafka#producer-12| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Handle is terminating in state CONNECT: 3 refcnts (000001C0E646C828), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf %7|1641472231.732|CONNECT|rdkafka#producer-12| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connected to ipv4#127.0.0.1:9092 %7|1641472231.732|CONNECTED|rdkafka#producer-12| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connected (#1) %7|1641472231.732|FEATURE|rdkafka#producer-12| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Updated enabled protocol features +ApiVersion to ApiVersion %7|1641472231.732|STATE|rdkafka#producer-12| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state CONNECT -> APIVERSION_QUERY %7|1641472231.732|TERMINATE|rdkafka#producer-12| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Handle is terminating in state APIVERSION_QUERY: 3 refcnts (000001C0E646C828), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 1 request(s) in retry+outbuf %7|1641472231.747|TERMINATE|rdkafka#producer-12| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Handle is terminating in state APIVERSION_QUERY: 3 refcnts (000001C0E646C828), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf %7|1641472231.758|DESTROY|rdkafka#producer-12| [thrd:main]: Removing all topics %7|1641472231.758|DESTROY|rdkafka#producer-12| [thrd:main]: Sending TERMINATE to localhost:9092/bootstrap %7|1641472231.759|TERM|rdkafka#producer-12| [thrd::0/internal]: :0/internal: Received TERMINATE op in state INIT: 2 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs %7|1641472231.759|FAIL|rdkafka#producer-12| [thrd::0/internal]: :0/internal: Client is terminating (after 40ms in state INIT) (_DESTROY) %7|1641472231.759|TERM|rdkafka#producer-12| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received TERMINATE op in state APIVERSION_QUERY: 2 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs %7|1641472231.759|STATE|rdkafka#producer-12| [thrd::0/internal]: :0/internal: Broker changed state INIT -> DOWN %7|1641472231.759|BRKTERM|rdkafka#producer-12| [thrd::0/internal]: :0/internal: terminating: broker still has 2 refcnt(s), 0 buffer(s), 0 partition(s) %7|1641472231.759|TERMINATE|rdkafka#producer-12| [thrd::0/internal]: :0/internal: Handle is terminating in state DOWN: 1 refcnts (000001C0E646FA68), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf %7|1641472231.759|FAIL|rdkafka#producer-12| [thrd::0/internal]: :0/internal: Broker handle is terminating (after 0ms in state DOWN) (_DESTROY) %7|1641472231.759|FAIL|rdkafka#producer-12| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Client is terminating (after 26ms in state APIVERSION_QUERY) (_DESTROY) %7|1641472231.759|FEATURE|rdkafka#producer-12| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Updated enabled protocol features -ApiVersion to %7|1641472231.759|STATE|rdkafka#producer-12| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state APIVERSION_QUERY -> DOWN %7|1641472231.759|BRKTERM|rdkafka#producer-12| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: terminating: broker still has 2 refcnt(s), 0 buffer(s), 0 partition(s) %7|1641472231.759|TERMINATE|rdkafka#producer-12| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Handle is terminating in state DOWN: 1 refcnts (000001C0E646C828), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf %7|1641472231.759|FAIL|rdkafka#producer-12| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker handle is terminating (after 0ms in state DOWN) (_DESTROY) %7|1641472331.965|INIT|rdkafka#producer-13| [thrd:app]: librdkafka v1.7.0 (0x10700ff) rdkafka#producer-13 initialized (builtin.features gzip,snappy,ssl,sasl,regex,lz4,sasl_gssapi,sasl_plain,sasl_scram,plugins,zstd,sasl_oauthbearer, SSL ZLIB SNAPPY SASL_SCRAM PLUGINS HDRHISTOGRAM, debug 0x4002) %4|1641472331.965|CONFWARN|rdkafka#producer-13| [thrd:app]: Configuration property group.id is a consumer property and will be ignored by this producer instance %5|1641472331.965|CONFWARN|rdkafka#producer-13| [thrd:app]: No `bootstrap.servers` configured: client will not be able to connect to Kafka cluster %7|1641472331.965|CREATETOPICS|rdkafka#producer-13| [thrd:main]: CREATETOPICS worker called in state initializing: Success %7|1641472331.965|DESTROY|rdkafka#producer-13| [thrd:app]: Terminating instance (destroy flags none (0x0)) %7|1641472331.965|ADMIN|rdkafka#producer-13| [thrd:main]: CREATETOPICS: looking up controller %7|1641472331.965|DESTROY|rdkafka#producer-13| [thrd:main]: Destroy internal %7|1641472331.965|CREATETOPICS|rdkafka#producer-13| [thrd:main]: CREATETOPICS worker called in state waiting for controller: handle is terminating: Local: Broker handle destroyed %7|1641472331.965|ADMINFAIL|rdkafka#producer-13| [thrd:main]: Admin CREATETOPICS result error: Handle is terminating: Local: Broker handle destroyed %7|1641472331.965|BRKMAIN|rdkafka#producer-13| [thrd::0/internal]: :0/internal: Enter main broker thread %7|1641472331.965|DESTROY|rdkafka#producer-13| [thrd:main]: Waiting for background queue thread to terminate %7|1641472331.965|DESTROY|rdkafka#producer-13| [thrd:main]: Removing all topics %7|1641472331.965|TERM|rdkafka#producer-13| [thrd::0/internal]: :0/internal: Received TERMINATE op in state INIT: 2 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs %7|1641472331.965|FAIL|rdkafka#producer-13| [thrd::0/internal]: :0/internal: Client is terminating (after 3ms in state INIT) (_DESTROY) %7|1641472331.965|STATE|rdkafka#producer-13| [thrd::0/internal]: :0/internal: Broker changed state INIT -> DOWN %7|1641472331.965|BRKTERM|rdkafka#producer-13| [thrd::0/internal]: :0/internal: terminating: broker still has 2 refcnt(s), 0 buffer(s), 0 partition(s) %7|1641472331.965|TERMINATE|rdkafka#producer-13| [thrd::0/internal]: :0/internal: Handle is terminating in state DOWN: 1 refcnts (000001C0E646A278), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf %7|1641472331.965|FAIL|rdkafka#producer-13| [thrd::0/internal]: :0/internal: Broker handle is terminating (after 0ms in state DOWN) (_DESTROY) %7|1641472360.728|INIT|rdkafka#producer-14| [thrd:app]: librdkafka v1.7.0 (0x10700ff) rdkafka#producer-14 initialized (builtin.features gzip,snappy,ssl,sasl,regex,lz4,sasl_gssapi,sasl_plain,sasl_scram,plugins,zstd,sasl_oauthbearer, SSL ZLIB SNAPPY SASL_SCRAM PLUGINS HDRHISTOGRAM, debug 0x4002) %4|1641472360.728|CONFWARN|rdkafka#producer-14| [thrd:app]: Configuration property group.id is a consumer property and will be ignored by this producer instance %5|1641472360.728|CONFWARN|rdkafka#producer-14| [thrd:app]: No `bootstrap.servers` configured: client will not be able to connect to Kafka cluster %7|1641472360.728|DESTROY|rdkafka#producer-14| [thrd:app]: Terminating instance (destroy flags none (0x0)) %7|1641472360.728|CREATETOPICS|rdkafka#producer-14| [thrd:main]: CREATETOPICS worker called in state initializing: handle is terminating: Success %7|1641472360.728|ADMINFAIL|rdkafka#producer-14| [thrd:main]: Admin CREATETOPICS result error: Handle is terminating: Success %7|1641472360.728|DESTROY|rdkafka#producer-14| [thrd:main]: Destroy internal %7|1641472360.728|DESTROY|rdkafka#producer-14| [thrd:main]: Waiting for background queue thread to terminate %7|1641472360.728|BRKMAIN|rdkafka#producer-14| [thrd::0/internal]: :0/internal: Enter main broker thread %6|1641472360.728|BGQUEUE|rdkafka#producer-14| [thrd:background]: Purging 1 unserved events from background queue %7|1641472360.729|DESTROY|rdkafka#producer-14| [thrd:main]: Removing all topics %7|1641472360.729|TERM|rdkafka#producer-14| [thrd::0/internal]: :0/internal: Received TERMINATE op in state INIT: 2 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs %7|1641472360.729|FAIL|rdkafka#producer-14| [thrd::0/internal]: :0/internal: Client is terminating (after 3ms in state INIT) (_DESTROY) %7|1641472360.729|STATE|rdkafka#producer-14| [thrd::0/internal]: :0/internal: Broker changed state INIT -> DOWN %7|1641472360.729|BRKTERM|rdkafka#producer-14| [thrd::0/internal]: :0/internal: terminating: broker still has 2 refcnt(s), 0 buffer(s), 0 partition(s) %7|1641472360.729|TERMINATE|rdkafka#producer-14| [thrd::0/internal]: :0/internal: Handle is terminating in state DOWN: 1 refcnts (000001C0E646BB98), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf %7|1641472360.729|FAIL|rdkafka#producer-14| [thrd::0/internal]: :0/internal: Broker handle is terminating (after 0ms in state DOWN) (_DESTROY) %7|1641472659.534|BRKMAIN|rdkafka#producer-15| [thrd::0/internal]: :0/internal: Enter main broker thread %7|1641472659.538|BROKER|rdkafka#producer-15| [thrd:app]: localhost:9092/bootstrap: Added new broker with NodeId -1 %7|1641472659.538|CONNECT|rdkafka#producer-15| [thrd:app]: localhost:9092/bootstrap: Selected for cluster connection: bootstrap servers added (broker has 0 connection attempt(s)) %7|1641472659.538|INIT|rdkafka#producer-15| [thrd:app]: librdkafka v1.7.0 (0x10700ff) rdkafka#producer-15 initialized (builtin.features gzip,snappy,ssl,sasl,regex,lz4,sasl_gssapi,sasl_plain,sasl_scram,plugins,zstd,sasl_oauthbearer, SSL ZLIB SNAPPY SASL_SCRAM PLUGINS HDRHISTOGRAM, debug 0x4002) %4|1641472659.538|CONFWARN|rdkafka#producer-15| [thrd:app]: Configuration property group.id is a consumer property and will be ignored by this producer instance %7|1641472659.538|BRKMAIN|rdkafka#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enter main broker thread %7|1641472659.538|CONNECT|rdkafka#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received CONNECT op %7|1641472659.538|STATE|rdkafka#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state INIT -> TRY_CONNECT %7|1641472659.538|CREATETOPICS|rdkafka#producer-15| [thrd:main]: CREATETOPICS worker called in state initializing: Success %7|1641472659.538|ADMIN|rdkafka#producer-15| [thrd:main]: CREATETOPICS: looking up controller %7|1641472659.538|CONNECT|rdkafka#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: broker in state TRY_CONNECT connecting %7|1641472659.539|STATE|rdkafka#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state TRY_CONNECT -> CONNECT %7|1641472659.539|CONNECT|rdkafka#producer-15| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: lookup controller %7|1641472659.539|CONNECT|rdkafka#producer-15| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: lookup controller %7|1641472659.539|DESTROY|rdkafka#producer-15| [thrd:app]: Terminating instance (destroy flags none (0x0)) %7|1641472659.539|DESTROY|rdkafka#producer-15| [thrd:main]: Destroy internal %7|1641472659.539|CREATETOPICS|rdkafka#producer-15| [thrd:main]: CREATETOPICS worker called in state waiting for controller: handle is terminating: Local: Broker handle destroyed %7|1641472659.539|ADMINFAIL|rdkafka#producer-15| [thrd:main]: Admin CREATETOPICS result error: Handle is terminating: Local: Broker handle destroyed %7|1641472659.539|DESTROY|rdkafka#producer-15| [thrd:main]: Waiting for background queue thread to terminate %7|1641472659.539|DESTROY|rdkafka#producer-15| [thrd:main]: Removing all topics %7|1641472659.539|DESTROY|rdkafka#producer-15| [thrd:main]: Sending TERMINATE to localhost:9092/bootstrap %7|1641472659.539|TERM|rdkafka#producer-15| [thrd::0/internal]: :0/internal: Received TERMINATE op in state INIT: 2 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs %7|1641472659.539|FAIL|rdkafka#producer-15| [thrd::0/internal]: :0/internal: Client is terminating (after 7ms in state INIT) (_DESTROY) %7|1641472659.539|STATE|rdkafka#producer-15| [thrd::0/internal]: :0/internal: Broker changed state INIT -> DOWN %7|1641472659.539|BRKTERM|rdkafka#producer-15| [thrd::0/internal]: :0/internal: terminating: broker still has 2 refcnt(s), 0 buffer(s), 0 partition(s) %7|1641472659.539|TERMINATE|rdkafka#producer-15| [thrd::0/internal]: :0/internal: Handle is terminating in state DOWN: 1 refcnts (000001C0E646D4B8), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf %7|1641472659.539|FAIL|rdkafka#producer-15| [thrd::0/internal]: :0/internal: Broker handle is terminating (after 0ms in state DOWN) (_DESTROY) %7|1641472659.541|CONNECT|rdkafka#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connecting to ipv4#127.0.0.1:9092 (plaintext) with socket 2664 %7|1641472659.544|TERMINATE|rdkafka#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Handle is terminating in state CONNECT: 2 refcnts (000001C0E6468958), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf %7|1641472659.544|CONNECT|rdkafka#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connected to ipv4#127.0.0.1:9092 %7|1641472659.544|CONNECTED|rdkafka#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connected (#1) %7|1641472659.544|FEATURE|rdkafka#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Updated enabled protocol features +ApiVersion to ApiVersion %7|1641472659.544|STATE|rdkafka#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state CONNECT -> APIVERSION_QUERY %7|1641472659.544|TERM|rdkafka#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received TERMINATE op in state APIVERSION_QUERY: 3 refcnts, 0 toppar(s), 0 active toppar(s), 1 outbufs, 0 waitresps, 0 retrybufs %7|1641472659.544|FAIL|rdkafka#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Client is terminating (after 0ms in state APIVERSION_QUERY) (_DESTROY) %7|1641472659.544|FEATURE|rdkafka#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Updated enabled protocol features -ApiVersion to %7|1641472659.544|STATE|rdkafka#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state APIVERSION_QUERY -> DOWN %7|1641472659.544|BRKTERM|rdkafka#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: terminating: broker still has 2 refcnt(s), 0 buffer(s), 0 partition(s) %7|1641472659.544|TERMINATE|rdkafka#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Handle is terminating in state DOWN: 1 refcnts (000001C0E6468958), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf %7|1641472659.544|FAIL|rdkafka#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker handle is terminating (after 0ms in state DOWN) (_DESTROY) %7|1641472737.384|BRKMAIN|rdkafka#producer-16| [thrd::0/internal]: :0/internal: Enter main broker thread %7|1641472737.388|BROKER|rdkafka#producer-16| [thrd:app]: localhost:9092/bootstrap: Added new broker with NodeId -1 %7|1641472737.388|CONNECT|rdkafka#producer-16| [thrd:app]: localhost:9092/bootstrap: Selected for cluster connection: bootstrap servers added (broker has 0 connection attempt(s)) %7|1641472737.388|INIT|rdkafka#producer-16| [thrd:app]: librdkafka v1.7.0 (0x10700ff) rdkafka#producer-16 initialized (builtin.features gzip,snappy,ssl,sasl,regex,lz4,sasl_gssapi,sasl_plain,sasl_scram,plugins,zstd,sasl_oauthbearer, SSL ZLIB SNAPPY SASL_SCRAM PLUGINS HDRHISTOGRAM, debug 0x4002) %4|1641472737.388|CONFWARN|rdkafka#producer-16| [thrd:app]: Configuration property group.id is a consumer property and will be ignored by this producer instance %7|1641472737.388|BRKMAIN|rdkafka#producer-16| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enter main broker thread %7|1641472737.388|CONNECT|rdkafka#producer-16| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received CONNECT op %7|1641472737.388|STATE|rdkafka#producer-16| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state INIT -> TRY_CONNECT %7|1641472737.388|CONNECT|rdkafka#producer-16| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: broker in state TRY_CONNECT connecting %7|1641472737.388|STATE|rdkafka#producer-16| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state TRY_CONNECT -> CONNECT %7|1641472737.388|DESTROY|rdkafka#producer-16| [thrd:app]: Terminating instance (destroy flags none (0x0)) %7|1641472737.388|CREATETOPICS|rdkafka#producer-16| [thrd:main]: CREATETOPICS worker called in state initializing: Success %7|1641472737.388|ADMIN|rdkafka#producer-16| [thrd:main]: CREATETOPICS: looking up controller %7|1641472737.388|CONNECT|rdkafka#producer-16| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: lookup controller %7|1641472737.388|DESTROY|rdkafka#producer-16| [thrd:main]: Destroy internal %7|1641472737.388|CREATETOPICS|rdkafka#producer-16| [thrd:main]: CREATETOPICS worker called in state waiting for controller: handle is terminating: Local: Broker handle destroyed %7|1641472737.388|ADMINFAIL|rdkafka#producer-16| [thrd:main]: Admin CREATETOPICS result error: Handle is terminating: Local: Broker handle destroyed %7|1641472737.388|DESTROY|rdkafka#producer-16| [thrd:main]: Waiting for background queue thread to terminate %7|1641472737.389|DESTROY|rdkafka#producer-16| [thrd:main]: Removing all topics %7|1641472737.389|DESTROY|rdkafka#producer-16| [thrd:main]: Sending TERMINATE to localhost:9092/bootstrap %7|1641472737.389|TERM|rdkafka#producer-16| [thrd::0/internal]: :0/internal: Received TERMINATE op in state INIT: 2 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs %7|1641472737.389|FAIL|rdkafka#producer-16| [thrd::0/internal]: :0/internal: Client is terminating (after 8ms in state INIT) (_DESTROY) %7|1641472737.389|STATE|rdkafka#producer-16| [thrd::0/internal]: :0/internal: Broker changed state INIT -> DOWN %7|1641472737.389|BRKTERM|rdkafka#producer-16| [thrd::0/internal]: :0/internal: terminating: broker still has 2 refcnt(s), 0 buffer(s), 0 partition(s) %7|1641472737.389|TERMINATE|rdkafka#producer-16| [thrd::0/internal]: :0/internal: Handle is terminating in state DOWN: 1 refcnts (000001C0E646BB98), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf %7|1641472737.389|FAIL|rdkafka#producer-16| [thrd::0/internal]: :0/internal: Broker handle is terminating (after 0ms in state DOWN) (_DESTROY) %7|1641472737.394|CONNECT|rdkafka#producer-16| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connecting to ipv4#127.0.0.1:9092 (plaintext) with socket 2960 %7|1641472737.397|TERMINATE|rdkafka#producer-16| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Handle is terminating in state CONNECT: 2 refcnts (000001C0E646E148), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf %7|1641472737.397|CONNECT|rdkafka#producer-16| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connected to ipv4#127.0.0.1:9092 %7|1641472737.397|CONNECTED|rdkafka#producer-16| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connected (#1) %7|1641472737.397|FEATURE|rdkafka#producer-16| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Updated enabled protocol features +ApiVersion to ApiVersion %7|1641472737.397|STATE|rdkafka#producer-16| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state CONNECT -> APIVERSION_QUERY %7|1641472737.397|TERM|rdkafka#producer-16| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received TERMINATE op in state APIVERSION_QUERY: 3 refcnts, 0 toppar(s), 0 active toppar(s), 1 outbufs, 0 waitresps, 0 retrybufs %7|1641472737.397|FAIL|rdkafka#producer-16| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Client is terminating (after 0ms in state APIVERSION_QUERY) (_DESTROY) %7|1641472737.397|FEATURE|rdkafka#producer-16| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Updated enabled protocol features -ApiVersion to %7|1641472737.397|STATE|rdkafka#producer-16| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state APIVERSION_QUERY -> DOWN %7|1641472737.397|BRKTERM|rdkafka#producer-16| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: terminating: broker still has 2 refcnt(s), 0 buffer(s), 0 partition(s) %7|1641472737.397|TERMINATE|rdkafka#producer-16| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Handle is terminating in state DOWN: 1 refcnts (000001C0E646E148), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf %7|1641472737.397|FAIL|rdkafka#producer-16| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker handle is terminating (after 0ms in state DOWN) (_DESTROY) %7|1641473305.798|BRKMAIN|rdkafka#producer-17| [thrd::0/internal]: :0/internal: Enter main broker thread %7|1641473305.801|BROKER|rdkafka#producer-17| [thrd:app]: localhost:9092/bootstrap: Added new broker with NodeId -1 %7|1641473305.801|CONNECT|rdkafka#producer-17| [thrd:app]: localhost:9092/bootstrap: Selected for cluster connection: bootstrap servers added (broker has 0 connection attempt(s)) %7|1641473305.801|INIT|rdkafka#producer-17| [thrd:app]: librdkafka v1.7.0 (0x10700ff) rdkafka#producer-17 initialized (builtin.features gzip,snappy,ssl,sasl,regex,lz4,sasl_gssapi,sasl_plain,sasl_scram,plugins,zstd,sasl_oauthbearer, SSL ZLIB SNAPPY SASL_SCRAM PLUGINS HDRHISTOGRAM, debug 0x4002) %4|1641473305.801|CONFWARN|rdkafka#producer-17| [thrd:app]: Configuration property group.id is a consumer property and will be ignored by this producer instance %7|1641473305.801|BRKMAIN|rdkafka#producer-17| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enter main broker thread %7|1641473305.801|CONNECT|rdkafka#producer-17| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received CONNECT op %7|1641473305.801|STATE|rdkafka#producer-17| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state INIT -> TRY_CONNECT %7|1641473305.801|CONNECT|rdkafka#producer-17| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: broker in state TRY_CONNECT connecting %7|1641473305.801|STATE|rdkafka#producer-17| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state TRY_CONNECT -> CONNECT %7|1641473305.801|DESTROY|rdkafka#producer-17| [thrd:app]: Terminating instance (destroy flags none (0x0)) %7|1641473305.801|CREATETOPICS|rdkafka#producer-17| [thrd:main]: CREATETOPICS worker called in state initializing: Success %7|1641473305.801|ADMIN|rdkafka#producer-17| [thrd:main]: CREATETOPICS: looking up controller %7|1641473305.801|CONNECT|rdkafka#producer-17| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: lookup controller %7|1641473305.801|DESTROY|rdkafka#producer-17| [thrd:main]: Destroy internal %7|1641473305.801|CREATETOPICS|rdkafka#producer-17| [thrd:main]: CREATETOPICS worker called in state waiting for controller: handle is terminating: Local: Broker handle destroyed %7|1641473305.801|ADMINFAIL|rdkafka#producer-17| [thrd:main]: Admin CREATETOPICS result error: Handle is terminating: Local: Broker handle destroyed %7|1641473305.801|DESTROY|rdkafka#producer-17| [thrd:main]: Waiting for background queue thread to terminate %7|1641473305.802|DESTROY|rdkafka#producer-17| [thrd:main]: Removing all topics %7|1641473305.802|DESTROY|rdkafka#producer-17| [thrd:main]: Sending TERMINATE to localhost:9092/bootstrap %7|1641473305.802|TERM|rdkafka#producer-17| [thrd::0/internal]: :0/internal: Received TERMINATE op in state INIT: 2 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs %7|1641473305.802|FAIL|rdkafka#producer-17| [thrd::0/internal]: :0/internal: Client is terminating (after 6ms in state INIT) (_DESTROY) %7|1641473305.802|STATE|rdkafka#producer-17| [thrd::0/internal]: :0/internal: Broker changed state INIT -> DOWN %7|1641473305.802|BRKTERM|rdkafka#producer-17| [thrd::0/internal]: :0/internal: terminating: broker still has 2 refcnt(s), 0 buffer(s), 0 partition(s) %7|1641473305.802|TERMINATE|rdkafka#producer-17| [thrd::0/internal]: :0/internal: Handle is terminating in state DOWN: 1 refcnts (000001C0E646D4B8), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf %7|1641473305.802|FAIL|rdkafka#producer-17| [thrd::0/internal]: :0/internal: Broker handle is terminating (after 0ms in state DOWN) (_DESTROY) %7|1641473305.804|CONNECT|rdkafka#producer-17| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connecting to ipv4#127.0.0.1:9092 (plaintext) with socket 3120 %7|1641473305.806|TERMINATE|rdkafka#producer-17| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Handle is terminating in state CONNECT: 2 refcnts (000001C0E646C828), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf %7|1641473305.806|CONNECT|rdkafka#producer-17| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connected to ipv4#127.0.0.1:9092 %7|1641473305.806|CONNECTED|rdkafka#producer-17| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connected (#1) %7|1641473305.806|FEATURE|rdkafka#producer-17| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Updated enabled protocol features +ApiVersion to ApiVersion %7|1641473305.806|STATE|rdkafka#producer-17| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state CONNECT -> APIVERSION_QUERY %7|1641473305.806|TERM|rdkafka#producer-17| [thrd:localhost:9092

[jliunyu]

Hi @cjfarnold , thanks for asking. I think the error is caused by your class definition and code in constructor, I wrote it for you, hope it helps:

Topics = ["InitiateMatch","CompleteMatch"]
class setupTopics:
    def __init__(self):
        self.a = AdminClient({'bootstrap.servers': '127.0.0.1:9092',
                              'debug':'broker,admin,protocol',
                              'compression.type':'none',
                              'group.id':'mygroup'})
        newtopics = [NewTopic(topic, num_partitions=1, replication_factor=1)
            for topic in Topics]
        self.a.create_topics(newtopics)

def main():
    s = setupTopics()

[razorcd]

faced same error with:

    newtopic = NewTopic("bbb1", num_partitions=3, replication_factor=1)
    fs = AdminClient(kafkaConfig).create_topics([newtopic])

this worked:

    a = AdminClient(kafkaConfig)
    newtopic = NewTopic("bbb1", num_partitions=3, replication_factor=1)
    fs = a.create_topics([newtopic])