lensesio/stream-reactor

Issues

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

  #1376 opened a month ago by sunil-chormale-polestar
  2

• S3 connector documentation about flush options is outdated

  #1435 opened 19 days ago by nojetlag
  0

• Support configuring a poll interval in s3 Kafka Connect Source

  #1229 opened 6 months ago by jessebye
  2

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

  #1255 opened 19 days ago by JKCai
  3

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

  #1378 opened 19 days ago by replikeit
  2

• Tombstone handling in s3 backup/recovery scenario

  #1365 opened 2 months ago by warmuuh
  0

• MQTT source - possibility to add prefix to kafka topic

  #1386 opened a month ago by dberardo-com
  0

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

  #1361 opened 2 months ago by dberardo-com
  2

• S3 source connector only following the last partition

  #1366 opened 2 months ago by warmuuh
  0

• SSL for Elasticsearch

  #940 opened 2 months ago by arnitolog
  2

• Support gzip compression for S3 source connector

  #1339 opened 3 months ago by coolstone1985
  0

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

  #1307 opened 4 months ago by dberardo-com
  2

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

  #1151 opened 3 months ago by jamielwhite
  3

• Applying SMT to S3SourceConnector

  #1246 opened 4 months ago by TomVanWemmel
  3

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

  #1259 opened 5 months ago by zudiay
  7

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

  #1133 opened 7 months ago by aubreyand
  2

• Sink__consumer_offsets topic into the S3 bucket using S3 Lenses Plugins

  #924 opened 2 years ago by cchidhu
  2

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

  #1132 opened 7 months ago by jamielwhite
  2

• S3 sink connector fail to integrate with AWS Glue registry

  #1150 opened 6 months ago by JKCai
  1

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

  #1176 opened 6 months ago by douggish
  0

• S3Sink token expired

  #929 opened 2 years ago by obbiondo
  1

• AuthorizationHeaderMalformed in aws-s3-sink connector

  #898 opened 7 months ago by onion1984
  10

• S3 Sink support for ignoring tombstones

  #938 opened 7 months ago by dipeti
  3

• Can't get Redis GeoAdd working

  #990 opened 7 months ago by sebastienblanc
  2

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

  #994 opened 7 months ago by parepallykiran
  12

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

  #1001 opened 7 months ago by LarissaVerhuelsdonk
  7

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

  #1039 opened 8 months ago by yossisc
  4

• Support multi-part uploads in AWS S3 sink connector

  #1053 opened 8 months ago by brandon-powers
  1

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

  #1046 opened 8 months ago by gitomat01
  1

• JMS connector exceptions with JMSReplyTo headers

  #1026 opened 8 months ago by michaeljwood
  3

• Creating from source - jars have the wrong version

  #1021 opened 10 months ago by FireBurn
  1

• Empty Array has JsonSimpleConverter crash

  #1015 opened 10 months ago by chriline
  2

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

  #903 opened a year ago by spike83
  5

• MQTT Connector: Can't use _key in WITHTARGET

  #968 opened a year ago by jadamon42
  1

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

  #935 opened a year ago by IgorTitov012
  2

• New release published?

  #981 opened a year ago by jfuller95
  2

• Source connector - read files from day partition

  #910 opened a year ago by iamsamba
  2

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

  #939 opened 2 years ago by mukkchir
  14

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

  #956 opened a year ago by jdfoster
  0

• 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 by rajesh-emagic
  4

• Connectors versions are reported incorrectly

  #928 opened 2 years ago by jeqo
  3

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

  #894 opened 2 years ago by jeacott1
  2

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

  #922 opened 2 years ago by raphael-caylent
  1

• S3 Sink Connector - Too many index files

  #921 opened 2 years ago by galal27
  1

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

  #911 opened 2 years ago by armin-git
  1

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

  #905 opened 2 years ago by darktaiga01
  1

• Support for Elastic8

  #893 opened 2 years ago by jdeex
  2

• Misleading Date Format Pattern for CassandraSourceConnector

  #901 opened 2 years ago by jp-9
  0

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

  #897 opened 2 years ago by onion1984
  0

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

  #895 opened 2 years ago by fqlx
  1