stream-reactor

stream-reactor copied to clipboard

Include release workflow to create a new release when a new tag is created. * The release workflow will call the build.yaml workflow using the `workflow_call` pattern, so all tests...

LauraMoraB

Support gzip compression for S3 connector

2

It would be nice if S3 source/sink connectors could support reading/dumping gzip files.

akamac

Cassandra Sink: exception java.lang.NoClassDefFoundError: Could not initialize class com.landoop.json.sql.JacksonJson$

36

Hi, we are running Kafka Connect Cassandra Sink connector using com.datamountaineer.kafka-connect-cassandra **v2.0.1** and got this exception below. I wonder if any of you ever seen it before. Looks like it...

z11373

S3 Source Connector not flushing anything

7

Hi guys, I am trying to connect the s3 source connector to a minio instance. The creation of the Kafka connector is fine but nothing gets logged out after source...

ewinata

AWS S3 sink connect surrounds messages with quotes

1

# Issue Guidelines How can I configure the S3 Sink to write messages to S3 objects without surrounding quotes? I would expect the `source_topic` and `target_topic` to be identical when...

aidan-melen

FTP Source - Handle large files with blocking the Connect framework

1

Move the poller into an separate thread.

andrewstevenson

Error: Unable to instantiate org.apache.hadoop.hive.metastore.HiveMetaStoreClient

1

# Issue Guidelines Please review these questions before submitting any issue? ### What version of the Stream Reactor are you reporting this issue for? 2.1.3 ### Are you running the...

juergenhemelt

Unsupported record 443:java.lang.Short if message includes header values (S3 SinkConnector)

1

Hi guys, I'm getting the following error message and I can't find any cause for it. **I have noticed that if the message contains some header values**, this error occurs....

Alexander-ac

davidsloan

MQTT Source connector throwing NoClassDefinition Found Error when processing message

10

Hi, I am trying to deploy Kafka Connect with MQTT Source connector on Kubernetes. I am using Strimzi operator to orchestrate the deployment. I have done the deployment and MQTT...

anuragp89