stream processing pipeline using dbt and Confluent Cloud
-
Updated
Apr 2, 2026
#
confluent-flink
Here are 6 public repositories matching this topic...
This library provides a collection of Python functions that interact with Confluent Cloud via its RESTful APIs.
-
Updated
Oct 8, 2025 - Python
This project demonstrates how to use Terraform to enable Tableflow in Kafka to generate and store the Iceberg Table files in an AWS S3 bucket. Then, configure Snowflake to read the Iceberg Tables using AWS Glue Data Catalog and the AWS S3 bucket where Tableflow produces the Iceberg files.
snowflake amazon-s3 confluent-kafka confluent-cloud aws-glue-data-catalog confluent-flink confluent-tableflow
-
Updated
Mar 19, 2026 - HCL
Utilize your Avro schema to identify which records require unnesting, and convert that into dynamic Flink SQL statements.
-
Updated
Mar 5, 2025 - Python
Repository to develop a Flink UDF driven by Confluent VS extension and powered by Claude Coude
-
Updated
May 5, 2026 - Java
Repository to try out the CC Flink forecast functionality
-
Updated
Feb 3, 2026
Improve this page
Add a description, image, and links to the confluent-flink topic page so that developers can more easily learn about it.
Add this topic to your repo
To associate your repository with the confluent-flink topic, visit your repo's landing page and select "manage topics."