camel-kafka-connector icon indicating copy to clipboard operation
camel-kafka-connector copied to clipboard

websocketjsr356.CamelWebsocketjsr356SourceConnector query paramater

Open arickbro opened this issue 4 years ago • 0 comments

Hi

is there any way to pass the query parameter to websocket server endpoint ? my websocket server required this parameter: client=radar_kafka&transform=terminal_names , but the kafka connect use it as properties

Caused by: org.apache.camel.FailedToCreateRouteException: 
Failed to create route route108: Route(route108)[From[websocket-jsr356:ws://10.204.127.81:909... 
because of Failed to resolve endpoint: websocket-jsr356://ws://10.204.127.81:9090/live/sspc-usage-stats?client=radar_kafka&transform=terminal_names due to: 
Failed to resolve endpoint: websocket-jsr356://ws://10.204.127.81:9090/live/sspc-usage-stats?client=radar_kafka&transform=terminal_names due to: 
There are 2 parameters that couldn't be set on the endpoint. 
Check the uri if the parameters are spelt correctly and that they are properties of the endpoint. 
Unknown parameters=[{client=radar_kafka, transform=terminal_names}]
	at org.apache.camel.reifier.RouteReifier.createRoute(RouteReifier.java:80)

arickbro avatar Aug 16 '21 08:08 arickbro