Aiven-Open/cloud-storage-connectors-for-apache-kafka

Ver en GitHub

Repository containing Cloud Storage Connectors for Apache Kafka®

Estrellas: 58
Forks: 39
Issues abiertos para principiantes: 0
Issues indexados: 65
Merge medio: 2 d 10 h
PR fusionados (30 d): 5

Lenguaje dominante: Java
Licencia: Apache-2.0
Último push a GitHub: 7/9/2026
Última indexación: 13/9/2026
Guía de contribución: Guía de contribución
Código de conducta: Código de conducta
Etiquetas para principiantes: good first issue

Abierto Todos

65 issues abiertos indexados

Brush up configuration definition Abierto

GCS

Aiven-Open/cloud-storage-connectors-for-apache-kafka#265 · 0 comentarios · 0 reacciones · 1 asignado · Indexado el 13/9/2026
S3 Source Connector Abierto

S3

Aiven-Open/cloud-storage-connectors-for-apache-kafka#281 · 8 comentarios · 3 reacciones · 0 asignados · Indexado el 13/9/2026
Configuration to include avro schema Abierto

GCS

Aiven-Open/cloud-storage-connectors-for-apache-kafka#264 · 2 comentarios · 0 reacciones · 0 asignados · Indexado el 13/9/2026
Group data every hour Abierto

GCS

Aiven-Open/cloud-storage-connectors-for-apache-kafka#263 · 2 comentarios · 2 reacciones · 0 asignados · Indexado el 13/9/2026
Including Fields In File Templates Abierto

GCS

Aiven-Open/cloud-storage-connectors-for-apache-kafka#262 · 1 comentario · 0 reacciones · 0 asignados · Indexado el 13/9/2026
Issue on "Date Format" using the S3 Sink Connector from Avro to Parquet Abierto

S3

Aiven-Open/cloud-storage-connectors-for-apache-kafka#280 · 1 comentario · 2 reacciones · 0 asignados · Indexado el 13/9/2026
file in s3 without return line for each event Abierto

S3

Aiven-Open/cloud-storage-connectors-for-apache-kafka#279 · 1 comentario · 0 reacciones · 0 asignados · Indexado el 13/9/2026
GcsSinkTaskGroupByTopicPartitionPropertiesTest.limited takes very long time Abierto

GCS

Aiven-Open/cloud-storage-connectors-for-apache-kafka#261 · 0 comentarios · 0 reacciones · 0 asignados · Indexado el 13/9/2026
[QUESTION] How to properly encode CSV files for easy readability (for BigQuery external tables)? Abierto

GCS

Aiven-Open/cloud-storage-connectors-for-apache-kafka#260 · 0 comentarios · 0 reacciones · 0 asignados · Indexado el 13/9/2026
file.name.prefix doesn't seem to work Abierto

S3

Aiven-Open/cloud-storage-connectors-for-apache-kafka#278 · 0 comentarios · 0 reacciones · 0 asignados · Indexado el 13/9/2026
Heap OOM issue when trying to sing a Debezium snapshot to GCS Abierto

GCS

Aiven-Open/cloud-storage-connectors-for-apache-kafka#259 · 2 comentarios · 1 reacción · 0 asignados · Indexado el 13/9/2026
Just hold latest 10 record of each key or just hold data of 10 minutes ago Abierto

S3

Aiven-Open/cloud-storage-connectors-for-apache-kafka#277 · 4 comentarios · 0 reacciones · 0 asignados · Indexado el 13/9/2026
The s3 file only has startoffset. How to obtain the endoffset Abierto

S3

Aiven-Open/cloud-storage-connectors-for-apache-kafka#276 · 2 comentarios · 0 reacciones · 0 asignados · Indexado el 13/9/2026
Compatibility shim library Abierto

Aiven-Open/cloud-storage-connectors-for-apache-kafka#127 · 0 comentarios · 1 reacción · 0 asignados · Indexado el 13/9/2026
What should be the config for output to be in parquet format? Abierto

GCS

Aiven-Open/cloud-storage-connectors-for-apache-kafka#258 · 0 comentarios · 2 reacciones · 0 asignados · Indexado el 13/9/2026
AWS ECS Task or (likely) EKS pod with pre-mounted IAM credentials unsupported Abierto

S3

Aiven-Open/cloud-storage-connectors-for-apache-kafka#275 · 0 comentarios · 1 reacción · 0 asignados · Indexado el 13/9/2026
Error when using zstd compression with parquet output format Abierto

GCS

Aiven-Open/cloud-storage-connectors-for-apache-kafka#257 · 1 comentario · 1 reacción · 0 asignados · Indexado el 13/9/2026
[avro workaround] Pulling avro data but using an SMT to transform avro to json Abierto

GCS

Aiven-Open/cloud-storage-connectors-for-apache-kafka#256 · 0 comentarios · 0 reacciones · 0 asignados · Indexado el 13/9/2026
Support dynamic fields partitioned without requiring Avro scheme Abierto

S3

Aiven-Open/cloud-storage-connectors-for-apache-kafka#274 · 0 comentarios · 1 reacción · 0 asignados · Indexado el 13/9/2026
[File size flush inteverval] Best practices for reducing network costs Abierto

GCS

Aiven-Open/cloud-storage-connectors-for-apache-kafka#255 · 3 comentarios · 1 reacción · 0 asignados · Indexado el 13/9/2026
There is an issue handling avro schema with default value defined as String Abierto

S3

Aiven-Open/cloud-storage-connectors-for-apache-kafka#273 · 2 comentarios · 0 reacciones · 0 asignados · Indexado el 13/9/2026
Add extensions for file format Abierto

enhancement

Aiven-Open/cloud-storage-connectors-for-apache-kafka#158 · 0 comentarios · 0 reacciones · 0 asignados · Indexado el 13/9/2026
Refactor Schema Builder Abierto

enhancement

Aiven-Open/cloud-storage-connectors-for-apache-kafka#159 · 0 comentarios · 0 reacciones · 0 asignados · Indexado el 13/9/2026
java.lang.NoClassDefFoundError Abierto

S3

Aiven-Open/cloud-storage-connectors-for-apache-kafka#272 · 1 comentario · 0 reacciones · 0 asignados · Indexado el 13/9/2026
Consumer offsets not committed when using KeyRecordGrouper Abierto

S3

Aiven-Open/cloud-storage-connectors-for-apache-kafka#271 · 0 comentarios · 0 reacciones · 0 asignados · Indexado el 13/9/2026
Out-of-Memory errors when sinking large topics Abierto

S3

Aiven-Open/cloud-storage-connectors-for-apache-kafka#270 · 14 comentarios · 1 reacción · 0 asignados · Indexado el 13/9/2026
Use environment variables for AWS Access Key ID/Secret Access Key Config Abierto

S3

Aiven-Open/cloud-storage-connectors-for-apache-kafka#269 · 0 comentarios · 0 reacciones · 0 asignados · Indexado el 13/9/2026
What happens if first record does not have headers but further records in the same batch do? Abierto

Aiven-Open/cloud-storage-connectors-for-apache-kafka#227 · 0 comentarios · 0 reacciones · 0 asignados · Indexado el 13/9/2026
Extend timestamp variable parameters in File name format Abierto

S3

Aiven-Open/cloud-storage-connectors-for-apache-kafka#268 · 3 comentarios · 0 reacciones · 1 asignado · Indexado el 13/9/2026
Query: Tombstone records support Abierto

S3

Aiven-Open/cloud-storage-connectors-for-apache-kafka#267 · 0 comentarios · 0 reacciones · 0 asignados · Indexado el 13/9/2026
Handling tombstone events Abierto

GCS

Aiven-Open/cloud-storage-connectors-for-apache-kafka#254 · 2 comentarios · 0 reacciones · 0 asignados · Indexado el 13/9/2026
AvroConverter class not found Abierto

documentation S3

Aiven-Open/cloud-storage-connectors-for-apache-kafka#266 · 5 comentarios · 0 reacciones · 0 asignados · Indexado el 13/9/2026
Custom Record Grouping Abierto

Aiven-Open/cloud-storage-connectors-for-apache-kafka#297 · 3 comentarios · 0 reacciones · 0 asignados · Indexado el 13/9/2026
Parallel file writing Abierto

Aiven-Open/cloud-storage-connectors-for-apache-kafka#311 · 4 comentarios · 0 reacciones · 0 asignados · Indexado el 13/9/2026
Release Azure Blob Source Connector as a downloadable jar. Abierto

enhancement

Aiven-Open/cloud-storage-connectors-for-apache-kafka#366 · 7 comentarios · 0 reacciones · 0 asignados · Indexado el 13/9/2026
MSK Connect Auth Issue Abierto

Aiven-Open/cloud-storage-connectors-for-apache-kafka#427 · 3 comentarios · 1 reacción · 0 asignados · Indexado el 13/9/2026
NPE when header value is null Abierto

Aiven-Open/cloud-storage-connectors-for-apache-kafka#434 · 5 comentarios · 0 reacciones · 1 asignado · Indexado el 13/9/2026
Azure Blob Sink Connector Flush Behavior Abierto

Aiven-Open/cloud-storage-connectors-for-apache-kafka#496 · 3 comentarios · 0 reacciones · 0 asignados · Indexado el 13/9/2026
Avro output type for GCS sink doesn't use `schema.registry.url` to store schema Abierto

bug Common code

Aiven-Open/cloud-storage-connectors-for-apache-kafka#503 · 2 comentarios · 0 reacciones · 0 asignados · Indexado el 13/9/2026
Improve error handling on misconfigured connectors Abierto

enhancement good first issue

Aiven-Open/cloud-storage-connectors-for-apache-kafka#504 · 1 comentario · 0 reacciones · 0 asignados · Indexado el 13/9/2026
S3 source failing to serialise S3 sink files Abierto

bug conflicts

Aiven-Open/cloud-storage-connectors-for-apache-kafka#512 · 6 comentarios · 0 reacciones · 0 asignados · Indexado el 13/9/2026
Add configuration documentation for all connectors. Abierto

documentation enhancement

Aiven-Open/cloud-storage-connectors-for-apache-kafka#514 · 0 comentarios · 0 reacciones · 0 asignados · Indexado el 13/9/2026
Add configuration documentation for S3 Sink Abierto

documentation good first issue

Aiven-Open/cloud-storage-connectors-for-apache-kafka#515 · 0 comentarios · 0 reacciones · 1 asignado · Indexado el 13/9/2026
Add configuration documentation for Azure sink Abierto

documentation good first issue

Aiven-Open/cloud-storage-connectors-for-apache-kafka#516 · 0 comentarios · 0 reacciones · 0 asignados · Indexado el 13/9/2026
Add configuration documentation for GCS sink connector Abierto

documentation good first issue

Aiven-Open/cloud-storage-connectors-for-apache-kafka#517 · 0 comentarios · 0 reacciones · 0 asignados · Indexado el 13/9/2026
Migrate common.grouper tests from gcs integration code. Abierto

enhancement good first issue

Aiven-Open/cloud-storage-connectors-for-apache-kafka#529 · 0 comentarios · 0 reacciones · 0 asignados · Indexado el 13/9/2026
Migrate deprecated configuration option processing ExtendedConfigKey processing. Abierto

enhancement good first issue S3

Aiven-Open/cloud-storage-connectors-for-apache-kafka#533 · 1 comentario · 0 reacciones · 0 asignados · Indexado el 13/9/2026
Update documentation to take advantage of ExtendedConfigKey data Abierto

documentation enhancement

Aiven-Open/cloud-storage-connectors-for-apache-kafka#534 · 0 comentarios · 0 reacciones · 0 asignados · Indexado el 13/9/2026
Migrate Sink integration tests into a single common base test Abierto

enhancement

Aiven-Open/cloud-storage-connectors-for-apache-kafka#535 · 0 comentarios · 0 reacciones · 0 asignados · Indexado el 13/9/2026
Migrate S3 Sink integration tests to common base test Abierto

enhancement S3

Aiven-Open/cloud-storage-connectors-for-apache-kafka#536 · 0 comentarios · 0 reacciones · 0 asignados · Indexado el 13/9/2026

Un resumen breve de issues de GitHub para principiantes.