Package Name Changes

Synopsis 

From Stream Reactor V6 we have changed some of the connector package names to the io.lenses namespace for consistency between connectors.

If you are upgrading you will need to adjust your connector configurations.

Configuration - Connector Class 

Instructions 

Change the value of the connector.class to replace com.datamountaineer with io.lenses.

Example: 

Former Connector Class 

connector.class=com.datamountaineer.streamreactor.connect.cassandra.sink.CassandraSinkConnector

New Connector Class 

connector.class=io.lenses.streamreactor.connect.cassandra.sink.CassandraSinkConnector

Configuration - Converters 

Instructions 

Several converters are provided as part of our connectors. These are configured in KCQL in the JMS and MQTT connectors.

Example 

Former KCQL Configuration 

-- Select from a JMS topic and write to a Kafka topic with a json converter
INSERT INTO topicA
SELECT * FROM jms_queue
WITHTYPE TOPIC
WITHCONVERTER=`com.datamountaineer.streamreactor.connect.converters.source.AvroConverter`

New KCQL Configuration 

-- Select from a JMS topic and write to a Kafka topic with a json converter
INSERT INTO topicA
SELECT * FROM jms_queue
WITHTYPE TOPIC
WITHCONVERTER=`io.lenses.streamreactor.connect.converters.source.AvroConverter`