Package org.apache.tika.pipes.iterator.kafka

Class KafkaPipesIteratorConfig

java.lang.Object

org.apache.tika.pipes.pipesiterator.PipesIteratorConfig

org.apache.tika.pipes.iterator.kafka.KafkaPipesIteratorConfig

public class KafkaPipesIteratorConfig
extends PipesIteratorConfig

Constructor Summary

Constructors

Constructor	Description
KafkaPipesIteratorConfig()

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object o)
String	getAutoOffsetReset()
String	getBootstrapServers()
int	getEmitMax()
String	getGroupId()
int	getGroupInitialRebalanceDelayMs()
String	getKeySerializer()
int	getPollDelayMs()
String	getTopic()
String	getValueSerializer()
int	hashCode()
static KafkaPipesIteratorConfig	load(String json)

Methods inherited from class org.apache.tika.pipes.pipesiterator.PipesIteratorConfig

getEmitterId, getFetcherId, setEmitterId, setFetcherId

Methods inherited from class java.lang.Object

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

Constructor Details

KafkaPipesIteratorConfig

public KafkaPipesIteratorConfig()

Method Details

load

public static KafkaPipesIteratorConfig load(String json)
                                     throws TikaConfigException

Throws:

TikaConfigException

getTopic

public String getTopic()

getBootstrapServers

public String getBootstrapServers()

getKeySerializer

public String getKeySerializer()

getValueSerializer

public String getValueSerializer()

getGroupId

public String getGroupId()

getAutoOffsetReset

public String getAutoOffsetReset()

getPollDelayMs

public int getPollDelayMs()

getEmitMax

public int getEmitMax()

getGroupInitialRebalanceDelayMs

public int getGroupInitialRebalanceDelayMs()

equals

public boolean equals(Object o)

Overrides:

equals in class PipesIteratorConfig

hashCode

public int hashCode()

Overrides:

hashCode in class PipesIteratorConfig