gcs-connector-for-apache-kafka
gcs-connector-for-apache-kafka copied to clipboard
Aiven-Open
Aiven's GCS Sink Connector for Apache Kafka®
I'm hive partitioning in my GCS bucket with the format `{{bucket}}/{{topic}}/v={{one-field}}/dt={{date}}`. Is there a plan to implement file name templating from fields in the key/value? I guess this relies on...
Hey, currently when we group by say key whats the time period ill which it will group ? Is there a way to group data every hour and send to...
Would it be possible to change some configuration to include the avro schema instead of just payload? On documentation we have, can schema be enabled? > Value/Key schema will not...
Bumps [com.github.luben:zstd-jni](https://github.com/luben/zstd-jni) from 1.5.6-1 to 1.5.6-4. Commits 76acf0f v1.5.6-4 4f4896f Move the Mac OS target in the build script 3252917 Revert "For Intel Mac OS target version 10.14" 4cd2f81 For...
![dependabot[bot] avatar](https://avatars.githubusercontent.com/in/29110?v=4 "dependabot[bot] avatar"){kind=avatar}
Bumps com.github.spotbugs from 6.0.13 to 6.0.19. [](https://docs.github.com/en/github/managing-security-vulnerabilities/about-dependabot-security-updates#about-compatibility-scores) Dependabot will resolve any conflicts with this PR as long as you don't alter it yourself. You can also trigger a...
I'm running Kafka Connect in GKE and using Workload Identity to provision a GCP service account into the container. This is working perfectly on v0.9.1. Attempting to upgrade to v0.10.0...
I am trying to use the connector for writing postgres CDC data [(Debezium connector for PostgreSQL)](https://debezium.io/documentation/reference/stable/connectors/postgresql.html) in parquet format to GCS. When there is a tombstone record (value is null)...
Bumps [com.github.spotbugs:spotbugs-annotations](https://github.com/spotbugs/spotbugs) from 4.8.4 to 4.8.6. Release notes Sourced from com.github.spotbugs:spotbugs-annotations's releases. SpotBugs 4.8.6 CHANGELOG Fixed Do not report BC_UNCONFIRMED_CAST for Java 21's type switches when the switch instruction is...
Bumps [net.jqwik:jqwik-engine](https://github.com/jqwik-team/jqwik) from 1.8.3 to 1.9.0. Release notes Sourced from net.jqwik:jqwik-engine's releases. Kotlin 2.0 and Nullability Annotations New and Enhanced Features Upgraded to Kotlin 2.0.0 Upgraded to JUnit Platform 1.10.3...