confluentinc/kafka-connect-storage-cloud
Kafka Connect suite of connectors for Cloud storage (Amazon S3)
JavaNOASSERTION
Issues
- 1
Failed to put when S3 object lock feature is enabled
#710 opened by wwakas - 2
S3 Object Locking requires an MD5 digest to be sent with the multipart upload request
#760 opened by mark-mckelvy - 0
- 0
Kafka connect s3 sink plugin getting "ERROR Failed to start Connect, Unable to initialize REST resources"
#765 opened by achar007 - 0
Unable to use Zstd compression with parquet
#764 opened by kartik18 - 0
- 0
- 0
[CVE] CVE-2023-25613 present in kerb-admin
#753 opened by JKrehling - 0
- 1
connector is not interoperable with other s3-compliant cloud storage providers
#747 opened by mhmcdonald - 0
[Feature request] S3SinkConnector support for default storage-class (object tiering)
#742 opened by arshk123 - 1
Create possibility to use your own writer.
#631 opened by gotpist1 - 0
S3 Kafka Sink: Tombstone encoded partition doesn't support timebased partioning
#732 opened by joaopmoniz - 4
Does it support generating topics.dir from topics.regex for s3 folder structure?
#654 opened by akshay-agarwal-17 - 0
- 0
- 0
Add ZSTD compression support for JSON output
#727 opened by der-eismann - 0
- 5
Null values being replaced with default
#716 opened by andyhuynh3 - 2
AWS MSK S3 Sink Connector to Deserialize AVRO without Schema Registry
#708 opened by GauravBhandariTSB - 1
Direct Memory Buffer Leak?
#707 opened by ozturkberkay - 0
io.confluent.connect.s3.format.parquet.ParquetFormat and ParquetRecordWriterProvider writes value in record field of type map and enum as bytes in Parquet result
#713 opened by richard-urena - 0
Request for Feature: Confirming Completion and Handling Old Data in S3 Kafka Connector
#712 opened by vibhormishra-sg - 1
commit timeout question
#709 opened by mujianping - 1
Where is S3 source connector?
#701 opened by realthered - 1
Unable to build v10.5.7 tag locally, missing io.confluent:common:[7.6.0, 7.6.1)
#704 opened by frankgrimes97 - 0
java.lang.IllegalStateException
#699 opened by moghadas76 - 1
- 0
Handling Close call in ICR mode
#694 opened by kumarpritam863 - 5
Convert to Parquet S3 Sink problems
#677 opened by davira - 3
CSV format
#645 opened by gkozyryatskyy - 0
Add option to keep tombstone events?
#683 opened by michelraymond - 1
Wrong Last Modified Time of S3 Object
#681 opened by YunanJeong - 7
class java.nio.HeapByteBuffer cannot be cast to class org.apache.avro.generic.GenericRecord
#675 opened by applejag - 0
Error on Parquet format class with compression
#656 opened by alexa22013 - 2
Ignore null headers and keys
#602 opened by aljoshare - 1
S3 Sink connector overwrites partition settings
#643 opened by olivernaaris - 3
Prevent clearing topic-partitions that are still assigned during a rebalance
#649 opened by SatyaKuppam - 1
CCMSG-2361 - to be released
#626 opened by au-raman - 0
don't sink during blackout time
#650 opened by tooptoop4 - 0
Document for this project is invalidated
#646 opened by scalalang2 - 1
- 0
- 3
CVE-2014-125087
#636 opened by tooptoop4 - 0
ParquetRecordWriterProvider.write() generates error logs any time a writer is opened
#635 opened by stalbot15 - 2
Implement AAD authentication support for Azure Blob connectors (sink/source)
#608 opened by yuhusolutions - 3
- 2
host exception while reading hive table from pyspark..it is showing list of tables but not able to read data from hive table
#591 opened by abhi413sh - 0
Update storage common version to 11.0.6
#607 opened by capitalg - 1
CVE-2022-40150
#576 opened by AnatoliAliaksandrou