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

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",
     "baseConfig": {
       "fetcherId": "my-fetcher",
       "emitterId": "my-emitter"
     }
   }
 }