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:
us...@infra.apache.org


Reply via email to