stream-reactor
stream-reactor copied to clipboard
lensesio
A collection of open source Apache 2.0 Kafka Connector maintained by Lenses.io.
My Hadoop version is apache-hadoop-2.6.3, hive version is apache-hive-1.2.1,kafka-connect-hive version is kafka-connect-hive-1.2.1-2.1.0-all.jar. I according to the Hive Source (https://docs.lenses.io/connectors/source/hive.html) examples created hive_connect database and started hive-source-connetor, but I met this...
Hello, We are using the MQTT source connector to retrieve messages from our broker using QoS 1. We noticed that the messages having the `dup` flag set are skipped by...
This should resolve issue: #766 This introduces a new configuration parameter: `connect.mqtt.process.duplicates` By default this is set to false (the current behaviour). By setting to 'true' you instruct the MQTT...
# Issue Guidelines name=mqtt-sink connector.class=com.datamountaineer.streamreactor.connect.mqtt.sink.MqttSinkConnector tasks.max=2 topics=kafka-topic connect.mqtt.client.id=dm_sink_id, connect.mqtt.kcql=INSERT INTO /landoop/mqtt_topic SELECT * FROM kafka-topic If mqtt.client.id is defined and tasks.max>1 workers will failed because workers are used the same...
To fix #867 No additional configuration is required.
This introduces new functionality to ensure that the original partitions are passed back into Kafka Connect when reading from the source. The following two new properties are introduced: ``connect.s3.source.partition.extractor.type`` -...
# Issue Guidelines Please review these questions before submitting any issue? ### What version of the Stream Reactor are you reporting this issue for? kafka-connect-aws-s3-3.0.1-2.5.0 ### Are you running the...
# Issue Guidelines Please review these questions before submitting any issue? ### What version of the Stream Reactor are you reporting this issue for? 3.3.0 ### Are you running the...
Hi, I'm trying to deploy to S3 sink into [AWS MSK Connect](https://aws.amazon.com/msk/features/msk-connect/) as a plugin. I'm using the shadowJar suggested in the [documentation](https://github.com/lensesio/stream-reactor/tree/4685270d18c747fa8170598972da34df7492f1f4/kafka-connect-aws-s3#building) but it is specifically excludes certain packages...
# Issue Guidelines Please review these questions before submitting any issue? ### What version of the Stream Reactor are you reporting this issue for? 3.0.1-2.5.0 ### Are you running the...
