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
没有评论:
发表评论