Class KafkaPipesIteratorConfig
java.lang.Object
org.apache.tika.pipes.pipesiterator.PipesIteratorConfig
org.apache.tika.pipes.iterator.kafka.KafkaPipesIteratorConfig
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionbooleanintintintgetTopic()inthashCode()static KafkaPipesIteratorConfigMethods inherited from class org.apache.tika.pipes.pipesiterator.PipesIteratorConfig
getEmitterId, getFetcherId, setEmitterId, setFetcherId
-
Constructor Details
-
KafkaPipesIteratorConfig
public KafkaPipesIteratorConfig()
-
-
Method Details
-
load
- Throws:
TikaConfigException
-
getTopic
-
getBootstrapServers
-
getKeySerializer
-
getValueSerializer
-
getGroupId
-
getAutoOffsetReset
-
getPollDelayMs
public int getPollDelayMs() -
getEmitMax
public int getEmitMax() -
getGroupInitialRebalanceDelayMs
public int getGroupInitialRebalanceDelayMs() -
equals
- Overrides:
equalsin classPipesIteratorConfig
-
hashCode
public int hashCode()- Overrides:
hashCodein classPipesIteratorConfig
-