This library wraps Kafka's embedded test cluster, allowing you to more easily create and run integration tests using JUnit against a "real" kafka server running within the context of your tests. No ...

Kafka Connect Transforms This Kafka Connect Single Message Transformation (SMT) converts Kafka record keys or values into JSON format, serializing the entire structure into a single field containing a ...