org.springframework.xd.test.kafka

Class KafkaTestSupport

java.lang.Object

org.springframework.xd.test.AbstractExternalResourceTestSupport<java.lang.String>

org.springframework.xd.test.kafka.KafkaTestSupport

All Implemented Interfaces:

org.junit.rules.TestRule

public class KafkaTestSupport
extends AbstractExternalResourceTestSupport<java.lang.String>

JUnit Rule that starts an embedded Kafka server (with an associated Zookeeper)

Since:

1.1

Author:

Ilayaperumal Gopinathan, Marius Bogoevici

Field Summary

Fields

Modifier and Type	Field and Description
static boolean	embedded

Fields inherited from class org.springframework.xd.test.AbstractExternalResourceTestSupport

logger, resource, XD_EXTERNAL_SERVERS_REQUIRED

Constructor Summary

Constructors

Constructor and Description
KafkaTestSupport()

Method Summary

Methods

Modifier and Type	Method and Description
protected void	cleanupResource() Perform cleanup of the AbstractExternalResourceTestSupport.resource field, which is guaranteed to be non null.
java.lang.String	getBrokerAddress()
org.I0Itec.zkclient.ZkClient	getZkClient()
java.lang.String	getZkConnectString()
protected void	obtainResource() Try to obtain and validate a resource.

Methods inherited from class org.springframework.xd.test.AbstractExternalResourceTestSupport

apply, getResource

Methods inherited from class java.lang.Object

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

Field Detail

embedded

public static final boolean embedded

Constructor Detail

KafkaTestSupport

public KafkaTestSupport()

Method Detail

getZkConnectString

public java.lang.String getZkConnectString()

getZkClient

public org.I0Itec.zkclient.ZkClient getZkClient()

getBrokerAddress

public java.lang.String getBrokerAddress()

obtainResource

protected void obtainResource()
                       throws java.lang.Exception

Description copied from class: AbstractExternalResourceTestSupport

Try to obtain and validate a resource. Implementors should either set the AbstractExternalResourceTestSupport.resource field with a valid resource and return normally, or throw an exception.

Specified by:

obtainResource in class AbstractExternalResourceTestSupport<java.lang.String>

Throws:

java.lang.Exception

cleanupResource

protected void cleanupResource()
                        throws java.lang.Exception

Description copied from class: AbstractExternalResourceTestSupport

Perform cleanup of the AbstractExternalResourceTestSupport.resource field, which is guaranteed to be non null.

Specified by:

cleanupResource in class AbstractExternalResourceTestSupport<java.lang.String>

Throws:

java.lang.Exception - any exception thrown by this method will be logged and swallowed