2021年3月13日星期六

Confluent Sink Connector for Azure Data Lake Gen2 fails with TimeoutException: License topic could not be created

I am working with Confluent and trying to write data from a topic to Azure Data Lake Gen2 using the sink connector. I have set up a Connect Image which contains the connector, deployed it in AKS using Confluent Operator, and configured it to write messages from a topic to storage, however every time I send messages to the topic, the Connecter enters a FAILED state with the following message:

{"name":"adls-gen2-sink",   "connector":{"state":"FAILED","worker_id":"connectors-0.connectors.operator.svc.cluster.local:9083",   "trace":"org.apache.kafka.common.errors.TimeoutException: License topic could not be created\n     Caused by: org.apache.kafka.common.errors.TimeoutException: Call(callName=createTopics, deadlineMs=1615683285588, tries=1, nextAllowedTryMs=1615683285689) timed out at 1615683285589 after 1 attempt(s)\n     Caused by: org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.\n"},   "tasks":[],"type":"sink"}  
https://stackoverflow.com/questions/66620416/confluent-sink-connector-for-azure-data-lake-gen2-fails-with-timeoutexception-l March 14, 2021 at 10:05AM

没有评论:

发表评论