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

      @Deprecated public int getGroupInitialRebalanceDelayMs()
      Deprecated.

    • getAssignmentTimeoutMs

      public int getAssignmentTimeoutMs()

    • getDrainIdleMs

      public int getDrainIdleMs()

    • equals

      public boolean equals(Object o)
      Overrides:
      equals in class PipesIteratorConfig

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class PipesIteratorConfig