Hi,
I am trying to consume messages from a Weblogic-JMS queue via Confluent Weblogic JMS Source Connector but unable to do so. The connector is not getting launched and is failing with the below error:
“trace”: “org.apache.kafka.common.errors.TimeoutException: License topic could not be created\nCaused by: org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment. Call: createTopics\n”
Connector Config:
{
“name”: “weblogicSourceConnector-test”,
“config”: {
“connector.class”: “io.confluent.connect.weblogic.WeblogicSourceConnector”,
“kafka.topic”:“JMS_topic”,
“java.naming.factory.initial”: “weblogic.jndi.WLInitialContextFactory”,
“jms.destination.name”:“InboundQueue”,
“java.naming.provider.url”: “t3://localhost:7003/”,
“connection.factory.name”: “cf1”,
“java.naming.security.principal”: “",
“java.naming.security.credentials”: "*”,
“topic.creation.enable”: “true”,
“topic.creation.default.replication.factor”: “3”,
“topic.creation.default.partitions”: “3”,
“tasks.max” : “1”,
“confluent.topic.bootstrap.servers”:“:9092”
}
}
Error logs captured from the log file:
[2024-02-12 19:02:20,817] ERROR [weblogicSourceConnector-test|worker] Failed to start connector weblogicSourceConnector-test (org.apache.kafka.connect.runtime.Worker:322)
[2024-02-12 19:02:20,819] ERROR [weblogicSourceConnector-test|worker] [Worker clientId=connect-1, groupId=connect-cluster] Failed to start connector ‘weblogicSourceConnector-test’ (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1906)
[2024-02-12 19:02:34,619] ERROR [weblogicSourceConnector-test|worker] Failed to start connector weblogicSourceConnector-test (org.apache.kafka.connect.runtime.Worker:322)
[2024-02-12 19:02:34,622] ERROR [weblogicSourceConnector-test|worker] [Worker clientId=connect-1, groupId=connect-cluster] Failed to start connector ‘weblogicSourceConnector-test’ (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1906)
[2024-02-12 19:05:30,953] ERROR [weblogicSourceConnector-test|worker] WorkerConnector{id=weblogicSourceConnector-test} Error while starting connector (org.apache.kafka.connect.runtime.WorkerConnector:200)
[2024-02-12 19:05:30,955] ERROR [weblogicSourceConnector-test|worker] [Worker clientId=connect-1, groupId=connect-cluster] Failed to start connector ‘weblogicSourceConnector-test’ (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1906)
I am currently using trial version of Confluent Cloud. Kafka Connect is set up locally on my Windows WSL2 machine.
Sidenote: There are no issues in working with mongoDB sink connector. It is working perfectly fine, added this point to confirm that kafka connect is indeed working fine.
Can anyone please confirm what exactly do I need to do in order to resolve this ?
Thanks,
Anjali