Package org.apache.tika.pipes.emitter.kafka

Class KafkaEmitterFactory

java.lang.Object
org.apache.tika.pipes.emitter.kafka.KafkaEmitterFactory
All Implemented Interfaces:
EmitterFactory, TikaExtensionFactory<Emitter>, org.pf4j.ExtensionPoint
@Extension public class KafkaEmitterFactory extends Object implements EmitterFactory
Factory for creating Kafka emitters.

Example JSON configuration: 

 "emitters": {
   "kafka-emitter": {
     "my-kafka-emitter": {
       "topic": "my-topic",
       "bootstrapServers": "localhost:9092",
       "acks": "all",
       "lingerMs": 5000
     }
   }
 }