[GitHub] [camel-kafka-connector] tadayosi commented on issue #924: Camel-Netty-* connectors are not working

[GitBox <gi...@apache.org>]

tadayosi commented on issue #924:
URL: https://github.com/apache/camel-kafka-connector/issues/924#issuecomment-788547729


   I think I figured out what's causing the issue and #665. It turns out it's potentially broader than just a couple of connectors. It's an issue in how the `EndpointUriFactory`s map properties to the endpoint URL, which is used in the `TaskHelper`. For Netty, the endpoint syntax is defined as `netty:protocol:host:port` as follows:
   https://github.com/apache/camel/blob/master/components/camel-netty/src/generated/java/org/apache/camel/component/netty/NettyEndpointUriFactory.java#L18
   https://github.com/apache/camel/blob/master/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyEndpoint.java#L43
   but it really should be `netty:protocol://host:port`. So I think Camel upstream needs to be fixed first.
   
   For the time being, a workaround would be to use `camel.source.path.host=//localhost` or `camel.sink.path.host=//localhost`.
   
   But I suspect there are potentially more components/connectors that have the same issue. I wonder if it's easy for the Camel core side to generate some basic tests against the EndpointUriFactories that check its url syntax with the mandatory properties (like `protocol`, `host`, and `port`, etc.).


----------------------------------------------------------------
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.

For queries about this service, please contact Infrastructure at:
users@infra.apache.org