Package org.apache.flink.tests.util.kafka

Interface Summary

Interface	Description
KafkaResource	Generic interface for interacting with Kafka.
KafkaResourceFactory	A factory for KafkaResource implementations.

Class Summary

Class	Description
LocalStandaloneKafkaResource	KafkaResource that downloads kafka and sets up a local kafka cluster with the bundled zookeeper.
LocalStandaloneKafkaResourceFactory	A KafkaResourceFactory for the LocalStandaloneKafkaResourceFactory.