com.yahoo.bullet.dsl.connector

Class KafkaConnector

java.lang.Object

com.yahoo.bullet.dsl.connector.BulletConnector

com.yahoo.bullet.dsl.connector.KafkaConnector

All Implemented Interfaces:

Serializable, AutoCloseable

public class KafkaConnector
extends BulletConnector

A BulletConnector that reads and deserializes messages from Kafka.

See Also:

Serialized Form

Field Summary

Fields inherited from class com.yahoo.bullet.dsl.connector.BulletConnector

config

Constructor Summary

Constructors

Constructor and Description
KafkaConnector(com.yahoo.bullet.common.BulletConfig bulletConfig) Constructs a KafkaConnector from a given configuration.

Method Summary

Modifier and Type	Method and Description
void	close()
void	initialize() Initializes the BulletConnector.
List<Object>	read() Reads and deserializes messages from a data source.

Methods inherited from class com.yahoo.bullet.dsl.connector.BulletConnector

from

Methods inherited from class java.lang.Object

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

Constructor Detail

KafkaConnector

public KafkaConnector(com.yahoo.bullet.common.BulletConfig bulletConfig)

Constructs a KafkaConnector from a given configuration.

Parameters:

bulletConfig - The configuration that specifies the settings for a KafkaConnector.

Method Detail

initialize

public void initialize()

Description copied from class: BulletConnector

Initializes the BulletConnector. Must be called before read().

Specified by:

initialize in class BulletConnector

read

public List<Object> read()
                  throws BulletDSLException

Description copied from class: BulletConnector

Reads and deserializes messages from a data source. A timeout duration can be set in the configuration.

Specified by:

read in class BulletConnector

Returns:

A list of deserialized objects.

Throws:

BulletDSLException - if there is a connection or reading error.

close

public void close()