lensesio/stream-reactor

Issues

• S3 connector documentation about flush options is outdated

  #1435 opened 9 days ago
  1

• MQTT source - possibility to add prefix to kafka topic

  #1386 opened a month ago
  0

• GCS Source connector: Reached the end of stream with xx bytes left to read

  #1378 opened 20 days ago
  2

• S3 Source Connector throwing exception (Unable to instantiate request handler chain for client.)

  #1376 opened a month ago
  2

• S3 source connector only following the last partition

  #1366 opened 2 months ago
  0

• Tombstone handling in s3 backup/recovery scenario

  #1365 opened 2 months ago
  0

• MQTT source - possibility to pass default number of partition a replication factor

  #1361 opened 2 months ago
  2

• Support gzip compression for S3 source connector

  #1339 opened 3 months ago
  0

• MQTT source: how to keep track of origin topic when using wildcard subscriptions

  #1307 opened 4 months ago
  2

• Kafka to HTTP Sink: Issue with setting the Content Type Header

  #1259 opened 5 months ago
  7

• S3 source connector: Reached the end of stream with xx bytes left to read

  #1255 opened 20 days ago
  3

• Applying SMT to S3SourceConnector

  #1246 opened 4 months ago
  3

• Support configuring a poll interval in s3 Kafka Connect Source

  #1229 opened 6 months ago
  2

• MQTT sink connector requires CA certificate configured when using self-signed client certs

  #1176 opened 6 months ago
  0

• S3 Sink connector does not write full record when store.envelope is true

  #1151 opened 3 months ago
  3

• S3 sink connector fail to integrate with AWS Glue registry

  #1150 opened 6 months ago
  1

• S3 Sink Connector fails with an UnknownHostException for the s3 bucket

  #1133 opened 7 months ago
  2

• S3 Sink connector reports consumer lag of 1 despite processing all records

  #1132 opened 7 months ago
  2

• Support multi-part uploads in AWS S3 sink connector

  #1053 opened 8 months ago
  1

• Client is not connected by using the lenses mqtt sink connector

  #1046 opened 8 months ago
  1

• [Question] - kafka-connect-aws-s3 - SDK version?

  #1039 opened 8 months ago
  4

• JMS connector exceptions with JMSReplyTo headers

  #1026 opened 8 months ago
  3

• Creating from source - jars have the wrong version

  #1021 opened 10 months ago
  1

• Empty Array has JsonSimpleConverter crash

  #1015 opened 10 months ago
  2

• Exception: "No NetworkModule installed" in Mqtt-Source-Connector when building version 5.0.0 from source

  #1001 opened 7 months ago
  7

• S3 Sink fails with error - Unsupported record :java.math.BigDecimal

  #994 opened 7 months ago
  12

• Can't get Redis GeoAdd working

  #990 opened 7 months ago
  2

• New release published?

  #981 opened a year ago
  2

• MQTT Connector: Can't use _key in WITHTARGET

  #968 opened a year ago
  1

• AWS S3 Sink fails to remove index files for GCP Cloud Storage via the S3 compatible APIs

  #956 opened a year ago
  0

• SSL for Elasticsearch

  #940 opened 2 months ago
  2

• [Bug]: MalformedInputException in MQTT Source connector in Azure K8s

  #939 opened 2 years ago
  14

• S3 Sink support for ignoring tombstones

  #938 opened 7 months ago
  3

• S3 Source Connector - org.apache.kafka.common.errors.RecordTooLargeException

  #935 opened a year ago
  2

• S3Sink token expired

  #929 opened 2 years ago
  1

• Connectors versions are reported incorrectly

  #928 opened 2 years ago
  3

• Sink__consumer_offsets topic into the S3 bucket using S3 Lenses Plugins

  #924 opened 2 years ago
  2

• how to handle JSON serialization between AWS S3 Sink and Source connectors

  #922 opened 2 years ago
  1

• S3 Sink Connector - Too many index files

  #921 opened 2 years ago
  1

• SimpleJsonConverter cannot convert nested jason in SimpleJsonConverter.java on kafka-connect-redis-kafka-3-1-4.0.0

  #911 opened 2 years ago
  1

• Source connector - read files from day partition

  #910 opened a year ago
  2

• Kudu Sink: java.lang.NoClassDefFoundError: io/confluent/kafka/schemaregistry/client/rest/RestService

  #905 opened 2 years ago
  1

• In MQTT sink connector(kafka-connect-mqtt-1.2.2-2.1.0-all) throw exception Caused by: com.fasterxml.jackson.databind.JsonMappingException: Scala module 2.13.3 requires Jackson Databind version >= 2.13.0 and < 2.14.0

  #904 opened 2 years ago
  4

• S3 source connector only following the last folder (partition)

  #903 opened a year ago
  5

• Misleading Date Format Pattern for CassandraSourceConnector

  #901 opened 2 years ago
  0

• AuthorizationHeaderMalformed in aws-s3-sink connector

  #898 opened 7 months ago
  10

• Can't find fileNamingStrategy in config for aws-s3 sink connector

  #897 opened 2 years ago
  0

• Recommend settings for maintaining stream backup durability - Should I use `FLUSH_INTERVAL` or `FLUSH_COUNT`?

  #895 opened 2 years ago
  1

• s3 sink, how to partition by date formatted from a field value?

  #894 opened 2 years ago
  2

• Support for Elastic8

  #893 opened 2 years ago
  2