public class KafkaUtils
extends java.lang.Object
KafkaSource and
KafkaSink| Constructor and Description |
|---|
KafkaUtils() |
| Modifier and Type | Method and Description |
|---|---|
static void |
ensureReady(java.lang.String fixtureName,
java.lang.String zkConnect,
java.lang.String topic)
Ensures that the host and port of the zookeeper connection are available and
that the topic has been created.
|
public static void ensureReady(java.lang.String fixtureName,
java.lang.String zkConnect,
java.lang.String topic)
fixtureName - The name of the fixture calling htis utility method, used for error reportingzkConnect - The Zookeeper connection stringtopic - The name of the topic to create