apache / camel-kafka-connector-examples

Apache Camel Kafka Connector Examples
https://camel.apache.org
64 stars 43 forks source link

Examples for websocket kafka connector (as a client) #343

Open ee07dazn opened 1 year ago

ee07dazn commented 1 year ago

Hello

I am trying to use websocket source from here . My problem is I am not getting any error and even if i provide a non-existent wes socket enspoint like wss://stream.binance.com:9443/ws/randomusdt@kline_1m, the connector is not failing or throwiing any errors. it simply says Either no records were produced by the task since the last offset commit, or every record has been filtered out by a transformation or dropped due to transformation or conversion errors. And i get the same message when i provide a genuine endpoint like wss://stream.binance.com:9443/ws/btcusdt@kline_1m.

Can someone please help or suggest ..i am completely stuck.

The version of the connector i am using is 0.6.1