Class KafkaPipesIteratorFactory

java.lang.Object
org.apache.tika.pipes.iterator.kafka.KafkaPipesIteratorFactory
All Implemented Interfaces:
PipesIteratorFactory, TikaExtensionFactory<PipesIterator>, org.pf4j.ExtensionPoint
@Extension public class KafkaPipesIteratorFactory extends Object implements PipesIteratorFactory
Factory for creating Kafka pipes iterators.

Example JSON configuration: 

"pipes-iterator": {
  "kafka-pipes-iterator": {
    "topic": "my-topic",
    "bootstrapServers": "localhost:9092",
    "groupId": "my-group",
    "autoOffsetReset": "earliest",
    "fetcherId": "my-fetcher",
    "emitterId": "my-emitter"
  }
}