🔥 connect/connect-snowflake-sink #7425
Description
🆕💥 New issue !
👍 CP 8.1.1 🔢 Connector v3.4.0 (📅 release date 2025-11-05) 🕐 2025-12-04 09:38 📄 snowflake-sink-proxy.sh 🔗 https://github.com/vdesabou/kafka-docker-playground/actions/runs/19921980533/job/57113131373
🔥 CP 8.1.1 🔢 Connector v3.4.0 (📅 release date 2025-11-05) 🕐 2025-12-04 09:42 📄 snowflake-sink.sh 🔗 https://github.com/vdesabou/kafka-docker-playground/actions/runs/19921980533/job/57113131373
Logs
09:38:24 ℹ️ 💀 kill all docker containers (disable with 'playground config container-kill-all-before-run false')
09:38:24 ℹ️ 💀 kill all docker containers
09:38:25 ℹ️ 🚀 Running example with flags
09:38:25 ℹ️ ⛳ Flags used are --tag=8.1.1
09:38:26 ℹ️ 🚀 Number of examples ran so far: 15
09:38:26 ℹ️ 🤖CI status: 🟢 ok
🔗test url: https://github.com/vdesabou/kafka-docker-playground/actions/runs/19744923494/job/56577674485
09:38:26 ℹ️ ####################################################
09:38:26 ℹ️ 🚀 Executing snowflake-sink.sh in dir /home/runner/work/kafka-docker-playground/kafka-docker-playground/connect/connect-snowflake-sink
09:38:26 ℹ️ ####################################################
09:38:27 ℹ️ 🧰 Checking if Docker image confluentinc/cp-server-connect-base:8.1.1 contains additional tools
09:38:27 ℹ️ ⏳ it can take a while if image is downloaded for the first time
09:38:27 ℹ️ Using sudo to remove /home/runner/work/kafka-docker-playground/kafka-docker-playground/scripts/../confluent-hub
09:38:27 ℹ️ 🎱 Installing connector snowflakeinc/snowflake-kafka-connector:latest
Downloading component Snowflake Sink Connector 3.4.0, provided by Snowflake, Inc. from Confluent Hub and installing into /usr/share/confluent-hub-components
09:38:33 ℹ️ 💫 Using connector:
09:38:33 ℹ️ 🔗 Plugin: snowflakeinc/snowflake-kafka-connector:3.4.0
09:38:33 ℹ️ 📅 Release date: 2025-11-05
09:38:33 ℹ️ 🌐 Documentation: https://docs.snowflake.net/manuals/user-guide/kafka-connector.html
09:38:33 ℹ️ 🎓 To specify different version, check the documentation https://kafka-docker-playground.io/#/how-to-use?id=🔗-for-connectors
09:38:33 ℹ️ 🛰️ Starting up Confluent Platform in Kraft mode as ENABLE_KRAFT environment variable is set
Generating RSA private key, 2048 bit long modulus
.....................+++
...............+++
e is 65537 (0x10001)
writing RSA key
/home/runner/work/kafka-docker-playground/kafka-docker-playground/connect/connect-snowflake-sink
09:38:33 ℹ️ Create a Snowflake DB
Installing version: 1.1.86
- SnowSQL * v1.1.86
Type SQL statements or !help
+-------------------------------------+
| status |
|-------------------------------------|
| PGDBRUNNER811 successfully dropped. |
+-------------------------------------+
1 Row(s) produced. Time Elapsed: 0.221s
+----------------------------------------------+
| status |
|----------------------------------------------|
| Database PGDBRUNNER811 successfully created. |
+----------------------------------------------+
1 Row(s) produced. Time Elapsed: 0.243s
Goodbye!
09:38:39 ℹ️ Create a Snowflake ROLE
Installing version: 1.1.86
- SnowSQL * v1.1.86
Type SQL statements or !help
+----------------------------------+
| status |
|----------------------------------|
| Statement executed successfully. |
+----------------------------------+
1 Row(s) produced. Time Elapsed: 0.167s
+---------------------------------------+
| status |
|---------------------------------------|
| PGROLERUNNER811 successfully dropped. |
+---------------------------------------+
1 Row(s) produced. Time Elapsed: 0.321s
+--------------------------------------------+
| status |
|--------------------------------------------|
| Role PGROLERUNNER811 successfully created. |
+--------------------------------------------+
1 Row(s) produced. Time Elapsed: 0.243s
+----------------------------------+
| status |
|----------------------------------|
| Statement executed successfully. |
+----------------------------------+
1 Row(s) produced. Time Elapsed: 0.216s
+----------------------------------+
| status |
|----------------------------------|
| Statement executed successfully. |
+----------------------------------+
1 Row(s) produced. Time Elapsed: 0.250s
+----------------------------------+
| status |
|----------------------------------|
| Statement executed successfully. |
+----------------------------------+
1 Row(s) produced. Time Elapsed: 0.194s
+----------------------------------+
| status |
|----------------------------------|
| Statement executed successfully. |
+----------------------------------+
1 Row(s) produced. Time Elapsed: 0.251s
+----------------------------------+
| status |
|----------------------------------|
| Statement executed successfully. |
+----------------------------------+
1 Row(s) produced. Time Elapsed: 0.224s
+----------------------------------+
| status |
|----------------------------------|
| Statement executed successfully. |
+----------------------------------+
1 Row(s) produced. Time Elapsed: 0.234s
+----------------------------------+
| status |
|----------------------------------|
| Statement executed successfully. |
+----------------------------------+
1 Row(s) produced. Time Elapsed: 0.187s
+----------------------------------+
| status |
|----------------------------------|
| Statement executed successfully. |
+----------------------------------+
1 Row(s) produced. Time Elapsed: 0.173s
+----------------------------------+
| status |
|----------------------------------|
| Statement executed successfully. |
+----------------------------------+
1 Row(s) produced. Time Elapsed: 0.167s
Goodbye!
09:38:47 ℹ️ Create a Snowflake WAREHOUSE (for admin purpose as KafkaConnect is Serverless)
Installing version: 1.1.86
- SnowSQL * v1.1.86
Type SQL statements or !help
+----------------------------------+
| status |
|----------------------------------|
| Statement executed successfully. |
+----------------------------------+
1 Row(s) produced. Time Elapsed: 0.208s
+-----------------------------------------------+
| status |
|-----------------------------------------------|
| Warehouse PGWHRUNNER811 successfully created. |
+-----------------------------------------------+
1 Row(s) produced. Time Elapsed: 0.285s
+----------------------------------+
| status |
|----------------------------------|
| Statement executed successfully. |
+----------------------------------+
1 Row(s) produced. Time Elapsed: 0.246s
Goodbye!
09:38:52 ℹ️ Create a Snowflake USER
Installing version: 1.1.86
- SnowSQL * v1.1.86
Type SQL statements or !help
+----------------------------------+
| status |
|----------------------------------|
| Statement executed successfully. |
+----------------------------------+
1 Row(s) produced. Time Elapsed: 0.201s
+---------------------------------------+
| status |
|---------------------------------------|
| PGUSERRUNNER811 successfully dropped. |
+---------------------------------------+
1 Row(s) produced. Time Elapsed: 0.252s
+--------------------------------------------+
| status |
|--------------------------------------------|
| User PGUSERRUNNER811 successfully created. |
+--------------------------------------------+
1 Row(s) produced. Time Elapsed: 0.941s
+----------------------------------+
| status |
|----------------------------------|
| Statement executed successfully. |
+----------------------------------+
1 Row(s) produced. Time Elapsed: 0.194s
+----------------------------------+
| status |
|----------------------------------|
| Statement executed successfully. |
+----------------------------------+
1 Row(s) produced. Time Elapsed: 0.222s
Goodbye!
09:38:59 ℹ️ 💀 kill all docker containers (disable with 'playground config container-kill-all-before-run false')
09:38:59 ℹ️ 💀 kill all docker containers
09:38:59 ℹ️ 🧰 Checking if Docker image confluentinc/cp-server-connect-base:8.1.1 contains additional tools
09:38:59 ℹ️ ⏳ it can take a while if image is downloaded for the first time
09:38:59 ℹ️ 🛰️ Starting up Confluent Platform in Kraft mode as ENABLE_KRAFT environment variable is set
09:39:00 ℹ️ 🛑 zookeeper is disabled
09:39:00 ℹ️ 🛑 control-center is disabled
09:39:00 ℹ️ 🛑 Starting services without Flink
09:39:00 ℹ️ 🛑 ksqldb is disabled
09:39:00 ℹ️ 🛑 REST Proxy is disabled
09:39:01 ℹ️ 🛑 Grafana is disabled
09:39:01 ℹ️ 🛑 kcat is disabled
09:39:01 ℹ️ 🛑 conduktor is disabled
Network plaintext_default Creating
Network plaintext_default Created
Container controller Creating
Container prometheus-c3-v2 Creating
Container prometheus-c3-v2 Created
Container controller Created
Container alertmanager-c3-v2 Creating
Container broker Creating
Container alertmanager-c3-v2 Created
Container broker Created
Container schema-registry Creating
Container schema-registry Created
Container connect Creating
Container connect Created
Container prometheus-c3-v2 Starting
Container controller Starting
Container prometheus-c3-v2 Started
Container alertmanager-c3-v2 Starting
Container controller Started
Container broker Starting
Container alertmanager-c3-v2 Started
Container broker Started
Container schema-registry Starting
Container schema-registry Started
Container connect Starting
Container connect Started
09:39:03 ℹ️ 📝 To see the actual properties file, use cli command 'playground container get-properties -c '
09:39:04 ℹ️ ✨ If you modify a docker-compose file and want to re-create the container(s), run cli command 'playground container recreate'
09:39:04 ℹ️ ⌛ Waiting up to 300 seconds for connect to start
09:39:34 ℹ️ 🚦 containers have started!
09:39:34 ℹ️ 📊 JMX metrics are available locally on those ports:
09:39:34 ℹ️ - kraft-controller : 10005
09:39:34 ℹ️ - zookeeper : 9999
09:39:34 ℹ️ - broker : 10000
09:39:34 ℹ️ - schema-registry : 10001
09:39:34 ℹ️ - connect : 10002
09:39:34 ℹ️ Sending messages to topic test_table
09:39:35 ℹ️ 🔮 value schema was identified as avro
09:39:35 ℹ️ ✨ generating value data...
09:39:38 ℹ️ ✨ 3 records were generated
{"u_name":"Ashly","u_price":0.2276324,"u_quantity":1}
{"u_name":"Austyn","u_price":0.7247554,"u_quantity":2}
{"u_name":"Evelyn","u_price":0.59874356,"u_quantity":3}
09:39:38 ℹ️ ✨ topic test_table does not exist, it will be created..
09:39:39 ℹ️ 🆕 Creating topic test_table
WARNING: Due to limitations in metric names, topics with a period ('.') or underscore ('_') could collide. To avoid issues it is best to use either, but not both.
Created topic test_table.
09:39:41 ℹ️ 📤 producing 3 records to topic test_table
09:39:44 ℹ️ 📤 produced 3 records to topic test_table, took: 0min 3sec
09:39:44 ℹ️ Creating Snowflake Sink connector
09:39:45 ℹ️ 🛠️ Creating 🌎onprem connector snowflake-sink
09:39:49 ℹ️ ✅ 🌎onprem connector snowflake-sink was successfully created
09:39:50 ℹ️ 🔩 list of all available parameters for 🌎onprem connector snowflake-sink (com.snowflake.kafka.connector.SnowflakeSinkConnector) and version 3.4.0 (with default value when applicable)
"behavior.on.null.values": "default",
"buffer.count.records": "10000",
"buffer.flush.time": "120",
"buffer.size.bytes": "5000000",
"enable.mdc.logging": "false",
"enable.streaming.channel.offset.migration": "false",
"enable.streaming.channel.offset.verification": "true",
"enable.streaming.client.optimization": "true",
"enable.task.fail.on.authorization.errors": "false",
"errors.deadletterqueue.topic.name": "STRING",
"errors.log.enable": "false",
"errors.tolerance": "none",
"jmx": "true",
"jvm.nonProxy.hosts": "STRING",
"jvm.proxy.host": "STRING",
"jvm.proxy.password": "[hidden]",
"jvm.proxy.port": "STRING",
"jvm.proxy.username": "STRING",
"key.converter.converter.encoding": "UTF-8",
"key.converter.converter.type": "",
"provider": "UNKNOWN",
"snowflake.authenticator": "snowflake_jwt",
"snowflake.database.name": "",
"snowflake.ingestion.method": "snowpipe",
"snowflake.metadata.all": "true",
"snowflake.metadata.createtime": "true",
"snowflake.metadata.offset.and.partition": "true",
"snowflake.metadata.topic": "true",
"snowflake.oauth.client.id": "STRING",
"snowflake.oauth.client.secret": "[hidden]",
"snowflake.oauth.refresh.token": "[hidden]",
"snowflake.oauth.token.endpoint": "",
"snowflake.private.key": "[hidden]",
"snowflake.private.key.passphrase": "[hidden]",
"snowflake.role.name": "",
"snowflake.schema.name": "",
"snowflake.snowpipe.stageFileNameExtensionEnabled": "true",
"snowflake.snowpipe.v2CleanerEnabled": "true",
"snowflake.snowpipe.v2CleanerThreads": "1",
"snowflake.streaming.channel.name.include.connector.name": "false",
"snowflake.streaming.client.provider.override.map": "STRING",
"snowflake.streaming.closeChannelsInParallel.enabled": "true",
"snowflake.streaming.enable.single.buffer": "true",
"snowflake.streaming.iceberg.enabled": "false",
"snowflake.streaming.max.client.lag": "1",
"snowflake.streaming.max.memory.limit.bytes": "-1",
"snowflake.streaming.metadata.connectorPushTime": "true",
"snowflake.test.rebalancing": "false",
"snowflake.topic2table.map": "STRING",
"snowflake.url.name": "",
"snowflake.user.name": "",
09:39:53 ℹ️ 🧩 Displaying status for 🌎onprem connector snowflake-sink
Name Status Tasks Stack Trace
###################################################################
snowflake-sink ✅ RUNNING 0:🟢 RUNNING[connect] -
###################################################################
09:39:54 ℹ️ 🌐 documentation for 🌎onprem connector snowflake-kafka-connector is available at:
https://docs.snowflake.net/manuals/user-guide/kafka-connector.html
09:41:54 ℹ️ Confirm that the messages were delivered to the Snowflake table (logged as PGUSERRUNNER811 user)
Installing version: 1.1.86
- SnowSQL * v1.1.86
Type SQL statements or !help
+----------------------------------+
| status |
|----------------------------------|
| Statement executed successfully. |
+----------------------------------+
1 Row(s) produced. Time Elapsed: 0.180s
+----------------------------------+
| status |
|----------------------------------|
| Statement executed successfully. |
+----------------------------------+
1 Row(s) produced. Time Elapsed: 0.192s
+----------------------------------+
| status |
|----------------------------------|
| Statement executed successfully. |
+----------------------------------+
1 Row(s) produced. Time Elapsed: 0.176s
+----------------------------------+
| status |
|----------------------------------|
| Statement executed successfully. |
+----------------------------------+
1 Row(s) produced. Time Elapsed: 0.167s
+-----------------+----------------+
| RECORD_METADATA | RECORD_CONTENT |
|-----------------+----------------|
+-----------------+----------------+
0 Row(s) produced. Time Elapsed: 0.210s
Goodbye!
09:42:00 🔥 ####################################################
09:42:00 🔥 🔥 RESULT: FAILURE for snowflake-sink.sh (took: 3min 34sec - )
09:42:00 🔥 ####################################################
09:42:00 ℹ️ 🧑🚒 you can troubleshoot the issue by running:
playground container display-error-all-containers
09:42:00 ℹ️ 🧑🚒 open full logs with '<playground container logs --open --container ', example:
playground container logs --open --container connect
09:33:52 ℹ️ 🆕 Listing last updated connector plugins (within 3 days) for confluentinc vendor
🔌 confluentinc/kafka-connect-aws-dynamodb - 🔢 v1.5.2 - 📅 release date: 2025-12-02 (2 days ago) - 🌐 documentation: https://docs.confluent.io/kafka-connect-aws-dynamodb/current/index.html
🔌 confluentinc/kafka-connect-hdfs3 - 🔢 v3.0.5 - 📅 release date: 2025-12-04 (0 days ago) - 🌐 documentation: https://docs.confluent.io/kafka-connect-hdfs3-sink/current/index.html
🔌 confluentinc/kafka-connect-kinesis - 🔢 v2.0.1 - 📅 release date: 2025-12-03 (1 days ago) - 🌐 documentation: https://docs.confluent.io/kafka-connect-kinesis/current/index.html
🔌 confluentinc/kafka-connect-solace-source - 🔢 v1.2.10 - 📅 release date: 2025-12-03 (1 days ago) - 🌐 documentation: https://docs.confluent.io/kafka-connect-solace/current/source/index.html
🔌 confluentinc/kafka-connect-splunk-source - 🔢 v1.1.7 - 📅 release date: 2025-12-02 (2 days ago) - 🌐 documentation: https://docs.confluent.io/kafka-connect-splunk-source/current/index.html
🔌 confluentinc/kafka-connect-sqs - 🔢 v2.0.8 - 📅 release date: 2025-12-03 (1 days ago) - 🌐 documentation: https://docs.confluent.io/kafka-connect-sqs/current/index.html
🔌 confluentinc/kafka-connect-tibco-source - 🔢 v1.2.10 - 📅 release date: 2025-12-03 (1 days ago) - 🌐 documentation: https://docs.confluent.io/kafka-connect-tibco/current/source/index.html
09:42:03 ℹ️ 🎯 Version currently used for confluent platform
8.1.1
09:42:04 ℹ️ 💯 Listing last 5 versions for connector plugin snowflakeinc/snowflake-kafka-connector
🔢 v3.2.3 - 📅 release date: 2025-07-14 (143 days ago)
🔢 v3.2.4 - 📅 release date: 2025-07-31 (126 days ago)
🔢 v3.3.0 - 📅 release date: 2025-08-26 (100 days ago)
🔢 v3.3.1 - 📅 release date: 2025-10-23 (42 days ago)
🔢 v3.4.0 - 📅 release date: 2025-11-05 (29 days ago)
🌐 documentation: https://docs.snowflake.net/manuals/user-guide/kafka-connector.html
09:42:04 ℹ️ 👻 Version currently used for snowflakeinc/snowflake-kafka-connector is latest
🔢 v3.4.0 - 📅 release date: 2025-11-05
09:42:05 ℹ️ 🧩 Displaying status for 🌎onprem connector snowflake-sink
Name Status Tasks Stack Trace
###################################################################
snowflake-sink ✅ RUNNING 0:🛑 FAILED[connect] tasks: org.apache.kafka.connect.errors.ConnectException: Exiting WorkerSinkTask due to unrecoverable exception.
at org.apache.kafka.connect.runtime.WorkerSinkTask.deliverMessages(WorkerSinkTask.java:743)
at org.apache.kafka.connect.runtime.WorkerSinkTask.poll(WorkerSinkTask.java:388)
at org.apache.kafka.connect.runtime.WorkerSinkTask.iteration(WorkerSinkTask.java:285)
at org.apache.kafka.connect.runtime.WorkerSinkTask.execute(WorkerSinkTask.java:249)
at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:283)
at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:339)
at org.apache.kafka.connect.runtime.isolation.Plugins.lambda$withClassLoader$0(Plugins.java:356)
at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
at java.base/java.util.concurrent.FutureTask.run(Unknown Source)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
at java.base/java.lang.Thread.run(Unknown Source)
Caused by: com.snowflake.kafka.connector.internal.SnowflakeKafkaConnectorException: [SF_KAFKA_CONNECTOR] Exception: Failed to create table
Error Code: 2007
Detail: Failed to create table on Snowflake, please check that you have permission to do so.
Message: Cannot perform CREATE TABLE. This session does not have a current database. Call 'USE DATABASE', or use a qualified name.
net.snowflake.client.jdbc.SnowflakeUtil.checkErrorAndThrowExceptionSub(SnowflakeUtil.java:180)
net.snowflake.client.jdbc.SnowflakeUtil.checkErrorAndThrowException(SnowflakeUtil.java:112)
net.snowflake.client.core.StmtUtil.pollForOutput(StmtUtil.java:511)
net.snowflake.client.core.StmtUtil.execute(StmtUtil.java:416)
net.snowflake.client.core.SFStatement.executeHelper(SFStatement.java:502)
net.snowflake.client.core.SFStatement.executeQueryInternal(SFStatement.java:211)
net.snowflake.client.core.SFStatement.executeQuery(SFStatement.java:145)
net.snowflake.client.core.SFStatement.execute(SFStatement.java:779)
net.snowflake.client.core.SFStatement.execute(SFStatement.java:697)
net.snowflake.client.jdbc.SnowflakeStatementV1.executeInternal(SnowflakeStatementV1.java:350)
net.snowflake.client.jdbc.SnowflakePreparedStatementV1.execute(SnowflakePreparedStatementV1.java:529)
com.snowflake.kafka.connector.internal.SnowflakeConnectionServiceV1.createTable(SnowflakeConnectionServiceV1.java:128)
com.snowflake.kafka.connector.internal.SnowflakeConnectionServiceV1.createTable(SnowflakeConnectionServiceV1.java:139)
com.snowflake.kafka.connector.internal.SnowflakeSinkServiceV1$ServiceContext.createTableAndStage(SnowflakeSinkServiceV1.java:1267)
com.snowflake.kafka.connector.internal.SnowflakeSinkServiceV1$ServiceContext.init(SnowflakeSinkServiceV1.java:646)
com.snowflake.kafka.connector.internal.SnowflakeSinkServiceV1$ServiceContext.insert(SnowflakeSinkServiceV1.java:817)
com.snowflake.kafka.connector.internal.SnowflakeSinkServiceV1$ServiceContext.access$300(SnowflakeSinkServiceV1.java:497)
com.snowflake.kafka.connector.internal.SnowflakeSinkServiceV1.insert(SnowflakeSinkServiceV1.java:270)
com.snowflake.kafka.connector.internal.SnowflakeSinkServiceV1.insert(SnowflakeSinkServiceV1.java:217)
com.snowflake.kafka.connector.SnowflakeSinkTask.put(SnowflakeSinkTask.java:313)
org.apache.kafka.connect.runtime.WorkerSinkTask.deliverMessages(WorkerSinkTask.java:709)
org.apache.kafka.connect.runtime.WorkerSinkTask.poll(WorkerSinkTask.java:388)
org.apache.kafka.connect.runtime.WorkerSinkTask.iteration(WorkerSinkTask.java:285)
org.apache.kafka.connect.runtime.WorkerSinkTask.execute(WorkerSinkTask.java:249)
org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:283)
org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:339)
org.apache.kafka.connect.runtime.isolation.Plugins.lambda$withClassLoader$0(Plugins.java:356)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
at com.snowflake.kafka.connector.internal.SnowflakeErrors.getException(SnowflakeErrors.java:415)
at com.snowflake.kafka.connector.internal.SnowflakeErrors.getException(SnowflakeErrors.java:387)
at com.snowflake.kafka.connector.internal.SnowflakeErrors.getException(SnowflakeErrors.java:377)
at com.snowflake.kafka.connector.internal.SnowflakeConnectionServiceV1.createTable(SnowflakeConnectionServiceV1.java:131)
at com.snowflake.kafka.connector.internal.SnowflakeConnectionServiceV1.createTable(SnowflakeConnectionServiceV1.java:139)
at com.snowflake.kafka.connector.internal.SnowflakeSinkServiceV1$ServiceContext.createTableAndStage(SnowflakeSinkServiceV1.java:1267)
at com.snowflake.kafka.connector.internal.SnowflakeSinkServiceV1$ServiceContext.init(SnowflakeSinkServiceV1.java:646)
at com.snowflake.kafka.connector.internal.SnowflakeSinkServiceV1$ServiceContext.insert(SnowflakeSinkServiceV1.java:817)
at com.snowflake.kafka.connector.internal.SnowflakeSinkServiceV1$ServiceContext.access$300(SnowflakeSinkServiceV1.java:497)
at com.snowflake.kafka.connector.internal.SnowflakeSinkServiceV1.insert(SnowflakeSinkServiceV1.java:270)
at com.snowflake.kafka.connector.internal.SnowflakeSinkServiceV1.insert(SnowflakeSinkServiceV1.java:217)
at com.snowflake.kafka.connector.SnowflakeSinkTask.put(SnowflakeSinkTask.java:313)
at org.apache.kafka.connect.runtime.WorkerSinkTask.deliverMessages(WorkerSinkTask.java:709)
... 11 more
###################################################################
09:42:05 ℹ️ 🌐 documentation is available at:
https://docs.snowflake.com/en/user-guide/kafka-connector.html
09:42:06 ℹ️ 🌐 documentation for 🌎onprem connector snowflake-kafka-connector is available at:
https://docs.snowflake.net/manuals/user-guide/kafka-connector.html
09:42:06 🔥 💀 The test snowflake-sink.sh (default_retry) has failed after 1 attempts.
09:42:06 🔥 ####################################################
09:42:06 🔥 🐳 docker ps
CONTAINER ID IMAGE COMMAND CREATED STATUS PORTS NAMES
ff291a9fac0a confluentinc/cp-server-connect-base:8.1.1 "/etc/confluent/dock…" 3 minutes ago Up 3 minutes 0.0.0.0:5005->5005/tcp, [::]:5005->5005/tcp, 0.0.0.0:8083->8083/tcp, [::]:8083->8083/tcp, 0.0.0.0:10002->10002/tcp, [::]:10002->10002/tcp, 9092/tcp connect
2d41f76dc567 confluentinc/cp-schema-registry:8.1.1 "/etc/confluent/dock…" 3 minutes ago Up 3 minutes 0.0.0.0:8081->8081/tcp, [::]:8081->8081/tcp, 0.0.0.0:10001->10001/tcp, [::]:10001->10001/tcp schema-registry
ab395a511e4e confluentinc/cp-server:8.1.1 "/etc/confluent/dock…" 3 minutes ago Up 3 minutes 0.0.0.0:9092->9092/tcp, [::]:9092->9092/tcp, 0.0.0.0:10000->10000/tcp, [::]:10000->10000/tcp, 0.0.0.0:29092->29092/tcp, [::]:29092->29092/tcp broker
fc0186317fd2 confluentinc/cp-enterprise-alertmanager:2.0.0 "alertmanager-start …" 3 minutes ago Up 3 minutes 9093/tcp alertmanager-c3-v2
6c0d70951ed2 confluentinc/cp-server:8.1.1 "/etc/confluent/dock…" 3 minutes ago Up 3 minutes 9092/tcp, 0.0.0.0:10005->10005/tcp, [::]:10005->10005/tcp controller
6fc93146c2b3 confluentinc/cp-enterprise-prometheus:2.0.0 "prometheus-start --…" 3 minutes ago Up 3 minutes 9090/tcp prometheus-c3-v2
09:42:06 🔥 ####################################################
09:42:06 🔥 ####################################################
09:42:06 🔥 connect logs
com.snowflake.kafka.connector.SnowflakeSinkTask.put(SnowflakeSinkTask.java:313)
org.apache.kafka.connect.runtime.WorkerSinkTask.deliverMessages(WorkerSinkTask.java:709)
org.apache.kafka.connect.runtime.WorkerSinkTask.poll(WorkerSinkTask.java:388)
org.apache.kafka.connect.runtime.WorkerSinkTask.iteration(WorkerSinkTask.java:285)
org.apache.kafka.connect.runtime.WorkerSinkTask.execute(WorkerSinkTask.java:249)
org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:283)
org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:339)
org.apache.kafka.connect.runtime.isolation.Plugins.lambda$withClassLoader$0(Plugins.java:356)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source) (org.apache.kafka.connect.runtime.WorkerSinkTask:741)
com.snowflake.kafka.connector.internal.SnowflakeKafkaConnectorException: [SF_KAFKA_CONNECTOR] Exception: Failed to create table
Error Code: 2007
Detail: Failed to create table on Snowflake, please check that you have permission to do so.
Message: Cannot perform CREATE TABLE. This session does not have a current database. Call 'USE DATABASE', or use a qualified name.
net.snowflake.client.jdbc.SnowflakeUtil.checkErrorAndThrowExceptionSub(SnowflakeUtil.java:180)
net.snowflake.client.jdbc.SnowflakeUtil.checkErrorAndThrowException(SnowflakeUtil.java:112)
net.snowflake.client.core.StmtUtil.pollForOutput(StmtUtil.java:511)
net.snowflake.client.core.StmtUtil.execute(StmtUtil.java:416)
net.snowflake.client.core.SFStatement.executeHelper(SFStatement.java:502)
net.snowflake.client.core.SFStatement.executeQueryInternal(SFStatement.java:211)
net.snowflake.client.core.SFStatement.executeQuery(SFStatement.java:145)
net.snowflake.client.core.SFStatement.execute(SFStatement.java:779)
net.snowflake.client.core.SFStatement.execute(SFStatement.java:697)
net.snowflake.client.jdbc.SnowflakeStatementV1.executeInternal(SnowflakeStatementV1.java:350)
net.snowflake.client.jdbc.SnowflakePreparedStatementV1.execute(SnowflakePreparedStatementV1.java:529)
com.snowflake.kafka.connector.internal.SnowflakeConnectionServiceV1.createTable(SnowflakeConnectionServiceV1.java:128)
com.snowflake.kafka.connector.internal.SnowflakeConnectionServiceV1.createTable(SnowflakeConnectionServiceV1.java:139)
com.snowflake.kafka.connector.internal.SnowflakeSinkServiceV1$ServiceContext.createTableAndStage(SnowflakeSinkServiceV1.java:1267)
com.snowflake.kafka.connector.internal.SnowflakeSinkServiceV1$ServiceContext.init(SnowflakeSinkServiceV1.java:646)
com.snowflake.kafka.connector.internal.SnowflakeSinkServiceV1$ServiceContext.insert(SnowflakeSinkServiceV1.java:817)
com.snowflake.kafka.connector.internal.SnowflakeSinkServiceV1$ServiceContext.access$300(SnowflakeSinkServiceV1.java:497)
com.snowflake.kafka.connector.internal.SnowflakeSinkServiceV1.insert(SnowflakeSinkServiceV1.java:270)
com.snowflake.kafka.connector.internal.SnowflakeSinkServiceV1.insert(SnowflakeSinkServiceV1.java:217)
com.snowflake.kafka.connector.SnowflakeSinkTask.put(SnowflakeSinkTask.java:313)
org.apache.kafka.connect.runtime.WorkerSinkTask.deliverMessages(WorkerSinkTask.java:709)
org.apache.kafka.connect.runtime.WorkerSinkTask.poll(WorkerSinkTask.java:388)
org.apache.kafka.connect.runtime.WorkerSinkTask.iteration(WorkerSinkTask.java:285)
org.apache.kafka.connect.runtime.WorkerSinkTask.execute(WorkerSinkTask.java:249)
org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:283)
org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:339)
org.apache.kafka.connect.runtime.isolation.Plugins.lambda$withClassLoader$0(Plugins.java:356)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
at com.snowflake.kafka.connector.internal.SnowflakeErrors.getException(SnowflakeErrors.java:415) ~[snowflake-kafka-connector-3.4.0.jar:?]
at com.snowflake.kafka.connector.internal.SnowflakeErrors.getException(SnowflakeErrors.java:387) ~[snowflake-kafka-connector-3.4.0.jar:?]
at com.snowflake.kafka.connector.internal.SnowflakeErrors.getException(SnowflakeErrors.java:377) ~[snowflake-kafka-connector-3.4.0.jar:?]
at com.snowflake.kafka.connector.internal.SnowflakeConnectionServiceV1.createTable(SnowflakeConnectionServiceV1.java:131) ~[snowflake-kafka-connector-3.4.0.jar:?]
at com.snowflake.kafka.connector.internal.SnowflakeConnectionServiceV1.createTable(SnowflakeConnectionServiceV1.java:139) ~[snowflake-kafka-connector-3.4.0.jar:?]
at com.snowflake.kafka.connector.internal.SnowflakeSinkServiceV1$ServiceContext.createTableAndStage(SnowflakeSinkServiceV1.java:1267) ~[snowflake-kafka-connector-3.4.0.jar:?]
at com.snowflake.kafka.connector.internal.SnowflakeSinkServiceV1$ServiceContext.init(SnowflakeSinkServiceV1.java:646) ~[snowflake-kafka-connector-3.4.0.jar:?]
at com.snowflake.kafka.connector.internal.SnowflakeSinkServiceV1$ServiceContext.insert(SnowflakeSinkServiceV1.java:817) ~[snowflake-kafka-connector-3.4.0.jar:?]
at com.snowflake.kafka.connector.internal.SnowflakeSinkServiceV1$ServiceContext.access$300(SnowflakeSinkServiceV1.java:497) ~[snowflake-kafka-connector-3.4.0.jar:?]
at com.snowflake.kafka.connector.internal.SnowflakeSinkServiceV1.insert(SnowflakeSinkServiceV1.java:270) ~[snowflake-kafka-connector-3.4.0.jar:?]
at com.snowflake.kafka.connector.internal.SnowflakeSinkServiceV1.insert(SnowflakeSinkServiceV1.java:217) ~[snowflake-kafka-connector-3.4.0.jar:?]
at com.snowflake.kafka.connector.SnowflakeSinkTask.put(SnowflakeSinkTask.java:313) ~[snowflake-kafka-connector-3.4.0.jar:?]
at org.apache.kafka.connect.runtime.WorkerSinkTask.deliverMessages(WorkerSinkTask.java:709) ~[connect-runtime-8.1.1-ce.jar:?]
at org.apache.kafka.connect.runtime.WorkerSinkTask.poll(WorkerSinkTask.java:388) ~[connect-runtime-8.1.1-ce.jar:?]
at org.apache.kafka.connect.runtime.WorkerSinkTask.iteration(WorkerSinkTask.java:285) ~[connect-runtime-8.1.1-ce.jar:?]
at org.apache.kafka.connect.runtime.WorkerSinkTask.execute(WorkerSinkTask.java:249) ~[connect-runtime-8.1.1-ce.jar:?]
at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:283) ~[connect-runtime-8.1.1-ce.jar:?]
at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:339) ~[connect-runtime-8.1.1-ce.jar:?]
at org.apache.kafka.connect.runtime.isolation.Plugins.lambda$withClassLoader$0(Plugins.java:356) ~[connect-runtime-8.1.1-ce.jar:?]
at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) ~[?:?]
at java.base/java.util.concurrent.FutureTask.run(Unknown Source) ~[?:?]
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) ~[?:?]
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) ~[?:?]
at java.base/java.lang.Thread.run(Unknown Source) [?:?]
[2025-12-04 09:39:56,266] INFO [snowflake-sink|task-0] [SF_KAFKA_CONNECTOR] Precommit started for 1 partitions (com.snowflake.kafka.connector.SnowflakeSinkTask:46)
[2025-12-04 09:39:56,266] INFO [snowflake-sink|task-0] [SF_KAFKA_CONNECTOR] No files to commit, returning 0 offset (com.snowflake.kafka.connector.internal.SnowflakeSinkServiceV1:46)
[2025-12-04 09:39:56,266] INFO [snowflake-sink|task-0] [SF_KAFKA_CONNECTOR] Successfully called PRECOMMIT on all 1 partitions, safe to commit 0 partitions, executionTime: 0 ms (com.snowflake.kafka.connector.SnowflakeSinkTask:46)
[2025-12-04 09:39:56,266] INFO [snowflake-sink|task-0] [SF_KAFKA_CONNECTOR] Client closed (com.snowflake.kafka.connector.internal.StageFilesProcessor$ProgressRegister:46)
[2025-12-04 09:39:56,267] INFO [snowflake-sink|task-0] [SF_KAFKA_CONNECTOR] IngestService Closed (com.snowflake.kafka.connector.internal.SnowflakeIngestionServiceV1:46)
[2025-12-04 09:39:56,268] INFO [snowflake-sink|task-0] [SF_KAFKA_CONNECTOR] pipe SNOWFLAKE_KAFKA_CONNECTOR_snowflake_sink_1996731346_PIPE_test_table_0: service closed (com.snowflake.kafka.connector.internal.SnowflakeSinkServiceV1:46)
[2025-12-04 09:39:56,268] INFO [snowflake-sink|task-0] [SF_KAFKA_CONNECTOR] task closed, execution time: 0 milliseconds (com.snowflake.kafka.connector.SnowflakeSinkTask:46)
[2025-12-04 09:39:56,269] ERROR [snowflake-sink|task-0] WorkerSinkTask{id=snowflake-sink-0} Task threw an uncaught and unrecoverable exception. Task is being killed and will not recover until manually restarted (org.apache.kafka.connect.runtime.WorkerTask:291)
org.apache.kafka.connect.errors.ConnectException: Exiting WorkerSinkTask due to unrecoverable exception.
at org.apache.kafka.connect.runtime.WorkerSinkTask.deliverMessages(WorkerSinkTask.java:743) ~[connect-runtime-8.1.1-ce.jar:?]
at org.apache.kafka.connect.runtime.WorkerSinkTask.poll(WorkerSinkTask.java:388) ~[connect-runtime-8.1.1-ce.jar:?]
at org.apache.kafka.connect.runtime.WorkerSinkTask.iteration(WorkerSinkTask.java:285) ~[connect-runtime-8.1.1-ce.jar:?]
at org.apache.kafka.connect.runtime.WorkerSinkTask.execute(WorkerSinkTask.java:249) ~[connect-runtime-8.1.1-ce.jar:?]
at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:283) ~[connect-runtime-8.1.1-ce.jar:?]
at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:339) ~[connect-runtime-8.1.1-ce.jar:?]
at org.apache.kafka.connect.runtime.isolation.Plugins.lambda$withClassLoader$0(Plugins.java:356) ~[connect-runtime-8.1.1-ce.jar:?]
at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) ~[?:?]
at java.base/java.util.concurrent.FutureTask.run(Unknown Source) ~[?:?]
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) ~[?:?]
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) ~[?:?]
at java.base/java.lang.Thread.run(Unknown Source) [?:?]
Caused by: com.snowflake.kafka.connector.internal.SnowflakeKafkaConnectorException: [SF_KAFKA_CONNECTOR] Exception: Failed to create table
Error Code: 2007
Detail: Failed to create table on Snowflake, please check that you have permission to do so.
Message: Cannot perform CREATE TABLE. This session does not have a current database. Call 'USE DATABASE', or use a qualified name.
net.snowflake.client.jdbc.SnowflakeUtil.checkErrorAndThrowExceptionSub(SnowflakeUtil.java:180)
net.snowflake.client.jdbc.SnowflakeUtil.checkErrorAndThrowException(SnowflakeUtil.java:112)
net.snowflake.client.core.StmtUtil.pollForOutput(StmtUtil.java:511)
net.snowflake.client.core.StmtUtil.execute(StmtUtil.java:416)
net.snowflake.client.core.SFStatement.executeHelper(SFStatement.java:502)
net.snowflake.client.core.SFStatement.executeQueryInternal(SFStatement.java:211)
net.snowflake.client.core.SFStatement.executeQuery(SFStatement.java:145)
net.snowflake.client.core.SFStatement.execute(SFStatement.java:779)
net.snowflake.client.core.SFStatement.execute(SFStatement.java:697)
net.snowflake.client.jdbc.SnowflakeStatementV1.executeInternal(SnowflakeStatementV1.java:350)
net.snowflake.client.jdbc.SnowflakePreparedStatementV1.execute(SnowflakePreparedStatementV1.java:529)
com.snowflake.kafka.connector.internal.SnowflakeConnectionServiceV1.createTable(SnowflakeConnectionServiceV1.java:128)
com.snowflake.kafka.connector.internal.SnowflakeConnectionServiceV1.createTable(SnowflakeConnectionServiceV1.java:139)
com.snowflake.kafka.connector.internal.SnowflakeSinkServiceV1$ServiceContext.createTableAndStage(SnowflakeSinkServiceV1.java:1267)
com.snowflake.kafka.connector.internal.SnowflakeSinkServiceV1$ServiceContext.init(SnowflakeSinkServiceV1.java:646)
com.snowflake.kafka.connector.internal.SnowflakeSinkServiceV1$ServiceContext.insert(SnowflakeSinkServiceV1.java:817)
com.snowflake.kafka.connector.internal.SnowflakeSinkServiceV1$ServiceContext.access$300(SnowflakeSinkServiceV1.java:497)
com.snowflake.kafka.connector.internal.SnowflakeSinkServiceV1.insert(SnowflakeSinkServiceV1.java:270)
com.snowflake.kafka.connector.internal.SnowflakeSinkServiceV1.insert(SnowflakeSinkServiceV1.java:217)
com.snowflake.kafka.connector.SnowflakeSinkTask.put(SnowflakeSinkTask.java:313)
org.apache.kafka.connect.runtime.WorkerSinkTask.deliverMessages(WorkerSinkTask.java:709)
org.apache.kafka.connect.runtime.WorkerSinkTask.poll(WorkerSinkTask.java:388)
org.apache.kafka.connect.runtime.WorkerSinkTask.iteration(WorkerSinkTask.java:285)
org.apache.kafka.connect.runtime.WorkerSinkTask.execute(WorkerSinkTask.java:249)
org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:283)
org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:339)
org.apache.kafka.connect.runtime.isolation.Plugins.lambda$withClassLoader$0(Plugins.java:356)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
at com.snowflake.kafka.connector.internal.SnowflakeErrors.getException(SnowflakeErrors.java:415) ~[snowflake-kafka-connector-3.4.0.jar:?]
at com.snowflake.kafka.connector.internal.SnowflakeErrors.getException(SnowflakeErrors.java:387) ~[snowflake-kafka-connector-3.4.0.jar:?]
at com.snowflake.kafka.connector.internal.SnowflakeErrors.getException(SnowflakeErrors.java:377) ~[snowflake-kafka-connector-3.4.0.jar:?]
at com.snowflake.kafka.connector.internal.SnowflakeConnectionServiceV1.createTable(SnowflakeConnectionServiceV1.java:131) ~[snowflake-kafka-connector-3.4.0.jar:?]
at com.snowflake.kafka.connector.internal.SnowflakeConnectionServiceV1.createTable(SnowflakeConnectionServiceV1.java:139) ~[snowflake-kafka-connector-3.4.0.jar:?]
at com.snowflake.kafka.connector.internal.SnowflakeSinkServiceV1$ServiceContext.createTableAndStage(SnowflakeSinkServiceV1.java:1267) ~[snowflake-kafka-connector-3.4.0.jar:?]
at com.snowflake.kafka.connector.internal.SnowflakeSinkServiceV1$ServiceContext.init(SnowflakeSinkServiceV1.java:646) ~[snowflake-kafka-connector-3.4.0.jar:?]
at com.snowflake.kafka.connector.internal.SnowflakeSinkServiceV1$ServiceContext.insert(SnowflakeSinkServiceV1.java:817) ~[snowflake-kafka-connector-3.4.0.jar:?]
at com.snowflake.kafka.connector.internal.SnowflakeSinkServiceV1$ServiceContext.access$300(SnowflakeSinkServiceV1.java:497) ~[snowflake-kafka-connector-3.4.0.jar:?]
at com.snowflake.kafka.connector.internal.SnowflakeSinkServiceV1.insert(SnowflakeSinkServiceV1.java:270) ~[snowflake-kafka-connector-3.4.0.jar:?]
at com.snowflake.kafka.connector.internal.SnowflakeSinkServiceV1.insert(SnowflakeSinkServiceV1.java:217) ~[snowflake-kafka-connector-3.4.0.jar:?]
at com.snowflake.kafka.connector.SnowflakeSinkTask.put(SnowflakeSinkTask.java:313) ~[snowflake-kafka-connector-3.4.0.jar:?]
at org.apache.kafka.connect.runtime.WorkerSinkTask.deliverMessages(WorkerSinkTask.java:709) ~[connect-runtime-8.1.1-ce.jar:?]
... 11 more
[2025-12-04 09:39:56,269] INFO [snowflake-sink|task-0] [SF_KAFKA_CONNECTOR] task stopped, total task runtime: 4174 milliseconds (com.snowflake.kafka.connector.SnowflakeSinkTask:46)
[2025-12-04 09:39:56,270] INFO [snowflake-sink|task-0] [Consumer clientId=connector-consumer-snowflake-sink-0, groupId=connect-snowflake-sink] Revoke previously assigned partitions [test_table-0] (org.apache.kafka.clients.consumer.internals.ConsumerRebalanceListenerInvoker:83)
[2025-12-04 09:39:56,270] INFO [snowflake-sink|task-0] [Consumer clientId=connector-consumer-snowflake-sink-0, groupId=connect-snowflake-sink] Member connector-consumer-snowflake-sink-0-ea985ee0-1138-443a-8318-b698a23b3920 sending LeaveGroup request to coordinator broker:9092 (id: 2147483646 rack: null isFenced: false) due to the consumer is being closed (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1174)
[2025-12-04 09:39:56,271] INFO [snowflake-sink|task-0] [Consumer clientId=connector-consumer-snowflake-sink-0, groupId=connect-snowflake-sink] Resetting generation and member id due to: consumer pro-actively leaving the group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1062)
[2025-12-04 09:39:56,271] INFO [snowflake-sink|task-0] [Consumer clientId=connector-consumer-snowflake-sink-0, groupId=connect-snowflake-sink] Request joining group due to: consumer pro-actively leaving the group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1109)
[2025-12-04 09:39:56,281] INFO [snowflake-sink|task-0] App info kafka.consumer for connector-consumer-snowflake-sink-0 unregistered (org.apache.kafka.common.utils.AppInfoParser:95)
09:42:06 ❗ ####################################################
09:42:06 🔥 ####################################################
09:42:06 🔥 schema-registry logs
09:42:06 ❗ ####################################################
09:42:06 🔥 ####################################################
09:42:06 🔥 broker logs
[2025-12-04 09:39:13,402] ERROR Unable to submit events without credentials (io.confluent.telemetry.events.exporter.http.HttpExporter)
[2025-12-04 09:39:13,407] ERROR Unable to submit events without credentials (io.confluent.telemetry.events.exporter.http.HttpExporter)
09:42:07 ❗ ####################################################
09:42:07 🔥 ####################################################
09:42:07 🔥 alertmanager-c3-v2 logs
09:42:07 ❗ ####################################################
09:42:07 🔥 ####################################################
09:42:07 🔥 controller logs
[2025-12-04 09:39:12,233] ERROR Unable to submit events without credentials (io.confluent.telemetry.events.exporter.http.HttpExporter)
[2025-12-04 09:39:12,360] ERROR Uncaught exception in SBK_DataBalanceEngine-0: (io.confluent.databalancer.ConfluentDataBalanceEngine)
09:42:07 ❗ ####################################################
09:42:07 🔥 ####################################################
09:42:07 🔥 prometheus-c3-v2 logs
09:42:07 ❗ ####################################################