Class | Description |
---|---|
EmbeddedZookeeper |
A port of kafka.zk.EmbeddedZookeeper, compatible with Zookeeper 3.4 API
|
KafkaTestSupport |
JUnit
Rule that starts an embedded Kafka server (with an associated Zookeeper) |
TestKafkaCluster |
A test Kafka + ZooKeeper pair for testing purposes.
|
Copyright © 2017 Pivotal Software, Inc.. All rights reserved.