filippzorin opened a new issue, #1491:
URL: https://github.com/apache/camel-kafka-connector/issues/1491
Hi everyone!
I'm started using Apache Camel with Kafka Connect.
I'm trying to consume messages from TIBCO-EMS. And I'm using
camel-sjms2-kafka-connector.
I uploaded package of `camel-sjms2-kafka-connector` version `3.18.2` into
`plugin.path` directory and I see in kafka connect logs that is loaded
successfully. Also I uploaded `tibjms.jar` file into connector directory.
Then I'm trying to create connector with config
```
{
"name": "CamelSjms2SourceConnectorConnector_0",
"config": {
"name": "CamelSjms2SourceConnectorConnector_0",
"connector.class":
"org.apache.camel.kafkaconnector.sjms2.CamelSjms2SourceConnector",
"camel.source.path.destinationType": "queue",
"camel.source.path.destinationName": "queue_name",
"camel.source.endpoint.clientId":
"apache-camel-jms-kafka-connector-tibco-test",
"camel.component.sjms2.connectionFactory":
"#class:com.tibco.tibjms.TibjmsConnectionFactory"
"camel.component.sjms2.connection-factory.userName": "xxxx",
"camel.component.sjms2.connection-factory.password": "xxxx",
"camel.component.sjms2.connection-factory.serverUrl":
"tcp://tibco-ems-host:7222"
}
}
```
I set `camel.component.sjms2.connectionFactory` to
`#class:com.tibco.tibjms.TibjmsConnectionFactory` like in example
https://github.com/apache/camel-kafka-connector/blob/main/examples/CamelJmsSourceConnector.properties,
also tried remove `#class:` prefix.
Finally I have error:
```
ERROR WorkerSourceTask{id=CamelSjms2SourceConnectorConnector_0-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)
org.apache.kafka.connect.errors.ConnectException: Failed to create and start
Camel context
...
Caused by: org.apache.camel.PropertyBindingException: Error binding property
(camel.component.sjms2.serverUrl=tcp://tibco-ems-host:7222) with name:
serverUrl on bean: org.apache.activemq.ActiveMQConnectionFactory@45eea0ee with
value: tcp://tibco-ems-host:7222
...
```
Looks like factory which I set trough
`camel.component.sjms2.connectionFactory` wasn't applied. Seems it's bug.
After that I tried to use `camel-jms-kafka-connector` version `0.11.5` with
similar configuration:
```
{
"name": "CamelJmsSourceConnectorConnector_0",
"config": {
"connector.class":
"org.apache.camel.kafkaconnector.jms.CamelJmsSourceConnector",
"camel.source.path.destinationName": "queue_name",
"camel.source.endpoint.clientId":
"apache-camel-jms-kafka-connector-011-tibco-test",
"camel.component.jms.connectionFactory":
"#class:com.tibco.tibjms.TibjmsConnectionFactory",
"camel.component.jms.password": "xxxx",
"camel.component.jms.username": "xxxx",
"camel.component.jms.connection-factory.serverUrl":
"tcp://tibco-ems-host:7222"
}
}
```
And it works! I'm not quite sure what is cause a problem, bug in
`camel-sjms2-kafka-connector` or compatibility issue with given JMS provider.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
