org.springframework.xd.test.fixtures.util

Class KafkaUtils

java.lang.Object

org.springframework.xd.test.fixtures.util.KafkaUtils

public class KafkaUtils
extends java.lang.Object

Utility methods for working with Kafka. Used by KafkaSource and KafkaSink

Author:

Mark Pollack, Gary Russell

Constructor Summary

Constructors

Constructor and Description
KafkaUtils()

Method Summary

Methods

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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

KafkaUtils

public KafkaUtils()

Method Detail

ensureReady

public 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.

Parameters:

fixtureName - The name of the fixture calling htis utility method, used for error reporting

zkConnect - The Zookeeper connection string

topic - The name of the topic to create