camel-websocket-source-kafka-connector source configuration

Connector Description: Websocket endpoints for communicating with clients

When using camel-websocket-source-kafka-connector as source make sure to use the following Maven dependency to have support for the connector:

<dependency>
  <groupId>org.apache.camel.kafkaconnector</groupId>
  <artifactId>camel-websocket-source-kafka-connector</artifactId>
  <version>x.x.x</version>
  <!-- use the same version as your Camel Kafka connector version -->
</dependency>

To use this source connector in Kafka connect you’ll need to set the following connector.class

connector.class=org.apache.camel.kafkaconnector.websocketsource.CamelWebsocketsourceSourceConnector

The camel-websocket-source source connector supports 15 options, which are listed below.

Name Description Default Priority

camel.kamelet.websocket-source.websocketHost

The hostname.

"0.0.0.0"

MEDIUM

camel.kamelet.websocket-source.websocketPort

The port number.

9292

MEDIUM

camel.kamelet.websocket-source.resourceUri

Required The name of the websocket channel to use.

HIGH

camel.kamelet.websocket-source.maxBinaryMessageSize

Can be used to set the size in bytes that the websocket created by the websocketServlet may be accept before closing. (Default is -1 - or unlimited).

-1

MEDIUM

camel.kamelet.websocket-source.bridgeErrorHandler

Allows for bridging the consumer to the Camel routing Error Handler.

false

MEDIUM

camel.kamelet.websocket-source.sessionSupport

Whether to enable session support which enables HttpSession for each http request.

false

MEDIUM

camel.kamelet.websocket-source.subprotocol

Comma-separated list of subprotocols that are supported by the application.

"any"

MEDIUM

camel.kamelet.websocket-source.lazyStartProducer

Whether the producer should be started lazy (on the first message).

false

MEDIUM

camel.kamelet.websocket-source.sendTimeout

Timeout in millis when sending to a websocket channel. The default timeout is 30000 (30 seconds).

30000

MEDIUM

camel.kamelet.websocket-source.bufferSize

Set the buffer size of the websocketServlet.

8192

MEDIUM

camel.kamelet.websocket-source.maxIdleTime

SetSet the time in ms that the websocket created by the websocketServlet may be idle before closing.

300000

MEDIUM

camel.kamelet.websocket-source.allowedOrigins

The CORS allowed origins. Use to allow all.

""

MEDIUM

camel.kamelet.websocket-source.crossOriginFilterOn

Whether to enable CORS.

false

MEDIUM

camel.kamelet.websocket-source.filterPath

Context path for filtering CORS.

""

MEDIUM

camel.kamelet.websocket-source.enableJmx

Enable JMX support.

false

MEDIUM

The camel-websocket-source source connector has no converters out of the box.

The camel-websocket-source source connector has no transforms out of the box.

The camel-websocket-source source connector has no aggregation strategies out of the box.

Back to top