org.springframework.xd.test.fixtures

Class KafkaSink

java.lang.Object

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

org.springframework.xd.test.fixtures.KafkaSink

public class KafkaSink
extends AbstractModuleFixture<KafkaSink>

A test fixture that represents the kafka sink

Author:

Glenn Renfro

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	DEFAULT_BROKER_LIST
static java.lang.String	DEFAULT_TOPIC

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

label

Constructor Summary

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
KafkaSink	brokerList(java.lang.String zkConnect) Set the brokerList for the sink
KafkaSink	ensureReady() Ensure that the kafka broker socket is available by polling it for up to 2 seconds
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
KafkaSink	topic(java.lang.String topic) Set the topic that the sink will publish to
static KafkaSink	withDefaults() Returns an instance of the KafkaSink using defaults.

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_BROKER_LIST

public static final java.lang.String DEFAULT_BROKER_LIST

See Also:

Constant Field Values

DEFAULT_TOPIC

public static final java.lang.String DEFAULT_TOPIC

See Also:

Constant Field Values

Constructor Detail

KafkaSink

public KafkaSink(java.lang.String zkConnect)

Initializes a Sink fixture;

Parameters:

zkConnect - The list of brokers to connect.

Method Detail

withDefaults

public static KafkaSink withDefaults()

Returns an instance of the KafkaSink using defaults.

Returns:

instance of the KafkaSink

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<KafkaSink>

brokerList

public KafkaSink brokerList(java.lang.String zkConnect)

Set the brokerList for the sink

Parameters:

zkConnect - A list of brokers that the sink can connect

Returns:

instance of Kafka sink

topic

public KafkaSink topic(java.lang.String topic)

Set the topic that the sink will publish to

Parameters:

topic - the topic the sink will publish

Returns:

instance of the kafka sink

ensureReady

public KafkaSink ensureReady()

Ensure that the kafka broker socket is available by polling it for up to 2 seconds

Returns:

instance of the KafkaSink

Throws:

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