You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by GitBox <gi...@apache.org> on 2022/12/21 21:40:33 UTC
[GitHub] [camel-kafka-connector] filippzorin opened a new issue, #1491: Unable to set ConnectionFactory for `camel-sjms2-kafka-connector`
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-unsubscribe@camel.apache.org.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [camel-kafka-connector] valdar closed issue #1491: Unable to set `password` for `camel-sjms2-kafka-connector`
Posted by GitBox <gi...@apache.org>.
valdar closed issue #1491: Unable to set `password` for `camel-sjms2-kafka-connector`
URL: https://github.com/apache/camel-kafka-connector/issues/1491
--
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-unsubscribe@camel.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [camel-kafka-connector] valdar commented on issue #1491: Unable to set `password` for `camel-sjms2-kafka-connector`
Posted by GitBox <gi...@apache.org>.
valdar commented on issue #1491:
URL: https://github.com/apache/camel-kafka-connector/issues/1491#issuecomment-1364371359
Hello can you try with:
`"camel.component.sjms2.connection-factory.userName": "xxxx",
"camel.component.sjms2.connection-factory.userPassword": "xxxx"`
?
--
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-unsubscribe@camel.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [camel-kafka-connector] filippzorin commented on issue #1491: Unable to set `password` for `camel-sjms2-kafka-connector`
Posted by GitBox <gi...@apache.org>.
filippzorin commented on issue #1491:
URL: https://github.com/apache/camel-kafka-connector/issues/1491#issuecomment-1364411356
@valdar it works! Thank you. But how did you figure it out? Where in source code can I check what property should I set?
--
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-unsubscribe@camel.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [camel-kafka-connector] valdar commented on issue #1491: Unable to set `password` for `camel-sjms2-kafka-connector`
Posted by GitBox <gi...@apache.org>.
valdar commented on issue #1491:
URL: https://github.com/apache/camel-kafka-connector/issues/1491#issuecomment-1364499322
@filippzorin I figured it out looking at the tibco connection factory javadoc: https://docs.tibco.com/pub/ems/8.5.1/doc/html/api/javadoc/com/tibco/tibjms/TibjmsTopicConnectionFactory.html looking at the setters inherited from class com.tibco.tibjms.TibjmsConnectionFactory
--
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-unsubscribe@camel.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org