Package org.apache.flink.statefun.e2e.common.kafka

Class Summary

Class	Description
KafkaIOVerifier<PK,PV,CK,CV>	A utility to make test assertions by means of writing inputs to Kafka, and then matching on outputs read from Kafka.
KafkaProtobufSerializer<T extends com.google.protobuf.Message>	A Kafka Serializer and Deserializer that uses Protobuf for serialization.