org.springframework.xd.test.fixtures

Class KafkaSource

java.lang.Object

org.springframework.xd.test.fixtures.AbstractModuleFixture<KafkaSource>

org.springframework.xd.test.fixtures.KafkaSource

public class KafkaSource
extends AbstractModuleFixture<KafkaSource>

A test fixture that represents the kafka source

Author:

Glenn Renfro

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	DEFAULT_OUTPUT_TYPE
static java.lang.String	DEFAULT_TOPIC
static java.lang.String	DEFAULT_ZK_CLIENT

Fields inherited from class org.springframework.xd.test.fixtures.AbstractModuleFixture

label

Constructor Summary

Constructors

Constructor and Description
KafkaSource(java.lang.String zkConnect) Initializes a KafkaSource fixture;

Method Summary

Methods

Modifier and Type	Method and Description
KafkaSource	ensureReady() Ensure that the zookeeper socket is available by polling it for up to 2 seconds and creates the topic required by this source.
KafkaSource	outputType(java.lang.String outputType) set the outputType for the kafka source
protected java.lang.String	toDSL() Returns a representation of the module suitable for inclusion in a stream definition, e.g. file --dir=xxxx --name=yyyy
KafkaSource	topic(java.lang.String topic) sets the topic for the kafka source
static KafkaSource	withDefaults() Returns an instance of the KafkaSource using defaults.
KafkaSource	zkConnect(java.lang.String zkConnect) set the zkConnect for the kafka source

Methods inherited from class org.springframework.xd.test.fixtures.AbstractModuleFixture

label, toString

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_ZK_CLIENT

public static final java.lang.String DEFAULT_ZK_CLIENT

See Also:

Constant Field Values

DEFAULT_TOPIC

public static final java.lang.String DEFAULT_TOPIC

See Also:

Constant Field Values

DEFAULT_OUTPUT_TYPE

public static final java.lang.String DEFAULT_OUTPUT_TYPE

See Also:

Constant Field Values

Constructor Detail

KafkaSource

public KafkaSource(java.lang.String zkConnect)

Initializes a KafkaSource fixture;

Parameters:

zkConnect - The zookeeper connection string.

Method Detail

withDefaults

public static KafkaSource withDefaults()

Returns an instance of the KafkaSource using defaults.

Returns:

instance of the KafkaSource

toDSL

protected java.lang.String toDSL()

Description copied from class: AbstractModuleFixture

Returns a representation of the module suitable for inclusion in a stream definition, e.g. file --dir=xxxx --name=yyyy

Specified by:

toDSL in class AbstractModuleFixture<KafkaSource>

topic

public KafkaSource topic(java.lang.String topic)

sets the topic for the kafka source

Parameters:

topic - the topic that data will be posted.

Returns:

instance of the KafkaSource

zkConnect

public KafkaSource zkConnect(java.lang.String zkConnect)

set the zkConnect for the kafka source

Parameters:

zkConnect - the zookeeper connection string to be used

Returns:

instance of the kafka source

outputType

public KafkaSource outputType(java.lang.String outputType)

set the outputType for the kafka source

Parameters:

outputType - the output type to be used.

Returns:

instance of the kafka source

ensureReady

public KafkaSource ensureReady()

Ensure that the zookeeper socket is available by polling it for up to 2 seconds and creates the topic required by this source.

Returns:

instance of the kafka source

Throws:

java.lang.IllegalStateException - if can not connect in 2 seconds.