Testing utilities for Apache Flink connectors providing test frameworks, assertion utilities, and abstractions for comprehensive connector testing

Apache Flink connector for NiFi that enables streaming data integration between Flink and Apache NiFi using the Site-to-Site protocol

A deprecated Apache Flink connector that enables integration with Apache NiFi through the NiFi Site-to-Site protocol for bidirectional streaming data exchange.

Apache Flink Kafka 0.10 connector for streaming data processing with exactly-once processing guarantees

Apache Flink HBase 1.4 Connector provides bidirectional data integration between Flink streaming applications and HBase NoSQL database.

Apache Flink connector for Google Cloud Pub/Sub that provides streaming data integration capabilities

Apache Flink connector for Google Cloud Pub/Sub with exactly-once processing guarantees for real-time stream processing applications

Flink filesystem connector providing fault-tolerant rolling file sinks for streaming data to HDFS and Hadoop-compatible filesystems

Apache Flink connector for Elasticsearch 1.x that enables streaming data ingestion into Elasticsearch clusters

Apache Flink file connector library for unified file processing in both batch and streaming modes with support for various formats, compression, and distributed processing capabilities.

Apache Flink connector for Apache Cassandra that provides both streaming and batch data integration capabilities

Apache Flink connector for Apache Cassandra - provides sinks for streaming data into Cassandra databases

Base classes and utilities for building Apache Flink connectors with async sink patterns, source readers, and advanced streaming capabilities

Apache Flink Client APIs and utilities for submitting and interacting with Flink jobs

Apache Flink client library providing programmatic APIs and command-line interfaces for submitting, managing, and monitoring Flink jobs.

Test utilities for validating user classloader functionality in Apache Flink client components

Apache Flink batch processing connectors for Avro, JDBC, Hadoop, HBase, and HCatalog data sources

Apache Flink Avro format support library providing serialization and deserialization capabilities for Apache Avro data format within Flink streaming and batch processing applications

Architecture testing framework for Apache Flink test code using ArchUnit

Apache Flink architectural tests for production code validation using ArchUnit framework