camel-kafka-connector
camel-kafka-connector copied to clipboard
websocketjsr356.CamelWebsocketjsr356SourceConnector query paramater
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)