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

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

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

Some exemplar filters