Provides the abstract API for a KafkaCluster and meta-annotation for annotations that constrain provided clusters.

The proxy code which provides the runtime environment in which filters execute

Provides a JUnit5 extension for providing KafkaCluster implementations to tests and running tests over multiple cluster configurations.

Support code to simplify writing integration tests for filters

Provides two implementations of KafkaCluster and some common constraint annotations for clusters.

Testing Tools

Kroxylicious Proxy

Integration tests where Kroxylicious is tested end-to-end with a real Kafka cluster.

A runnable proxy application. Provides the main() method.

A Maven Archetype to generate an independent Custom Filter project, demonstrating how to structure a Filter and integration test it against Apache Kafka

Integration tests where the runtime and filters are tested end-to-end with a real Kafka cluster.