confluentinc/kafka-connect-storage-common
Shared software among connectors that target distributed filesystems and cloud storage.
JavaNOASSERTION
Issues
- 0
- 1
changelog missing
#202 opened by raphaelauv - 1
Upgrade parquet to latest version (1.13.1)
#341 opened by BDeus - 1
Upgrade parquet to 1.12.x
#277 opened by BDeus - 0
- 1
add a property to tell timestamp extractor whether timestamp value is in seconds or milliseconds
#121 opened by bagipriyank - 0
- 0
Allow no use topic name as partition part
#291 opened by ostetsenko - 0
Extend list of basic partitioner: FieldAndTimeBasedPartitioner.java & HeaderAndTimeBasedPartitioner.java
#290 opened by ostetsenko - 4
kafka s3 sink connect complains Error retrieving Avro value schema version for id 12345
#284 opened by jma562 - 1
- 1
- 1
- 1
Partitioning with key
#267 opened by arezvani - 11
S3 Source custom partition Caused by: NoSuchMethodException: after creation
#239 opened by artemio77 - 0
- 2
- 1
when flush.size > 1, a timeout parameter is needed to trigger force flush regardless of new records read or not.
#275 opened by jma562 - 0
- 2
FAQ instructions to compile kafka is incorrect
#166 opened by Hubbitus - 2
How to modify the filename of the S3 object?
#154 opened by matias-dls - 1
- 10
- 0
- 1
Deprecated HiveFactory Support
#179 opened by serefacet - 2
Build Failure when I try to install using Maven: Failed to execute goal on project kafka-connect-storage-hive
#60 opened by smj19 - 2
- 5
Improve to storage partitioning scheme to be flexible and configurable at runtime.
#126 opened by hariprasad-k - 0
Field partitioner does not support multiple event type feature with schema references
#170 opened by gokhansari - 0
Connect Randomly Dropping Most Messages
#167 opened by cogitaria-admin - 0
Support all primitive types in FieldPartitioner
#157 opened by daehokimm - 0
Kafka Connect REST API Security
#147 opened by billwenboli - 4
- 14
io.confluent.connect.storage.errors.PartitionException: Error encoding partition
#131 opened by Adeljoo - 11
on-resolvable parent POM for io.confluent:kafka-connect-storage-common-parent:6.0.0?
#130 opened by Adeljoo - 3
- 4
TimestampExtractor fails to extract timestamp with RecordField from a protobuf event
#120 opened by bagipriyank - 5
How to add a custom partitioner
#107 opened by abhisheksahani - 6
How could I persist Object Meta Data along with Object into S3 using the Connector
#109 opened by FelixKJose - 1
- 0
Conflict between partition fields and the data source
#103 opened by nutteen - 2
Custom 'path.format' of 'FieldPartitioner'
#92 opened by counter2015 - 1
- 3
FieldPartition with lowercase field names
#78 opened by rajilion - 2
Partitioner classes misuse PartitionerConfig
#66 opened by dcsobral - 1
RecordFieldTimestampExtractor does not tolerate string timestamps without milliseconds
#61 opened by robobario - 0
Interface Partitioner is inefficient
#75 opened by dcsobral - 0
- 0
- 3
KafkaConnect issue with SASL/Kerberos
#54 opened by chitenderkumar