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

Class KafkaEmitter

java.lang.Object

org.apache.tika.plugins.AbstractTikaExtension

org.apache.tika.pipes.api.emitter.AbstractEmitter

org.apache.tika.pipes.emitter.kafka.KafkaEmitter

All Implemented Interfaces:

Emitter, TikaExtension

public class KafkaEmitter
extends AbstractEmitter

Emitter to write parsed documents into a specified Apache Kafka topic.

Example JSON configuration:

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

Field Summary

Fields inherited from class org.apache.tika.plugins.AbstractTikaExtension

pluginConfig

Method Summary

Modifier and Type	Method	Description
static KafkaEmitter	build(ExtensionConfig extensionConfig)
void	emit(String emitKey, List<Metadata> metadataList, ParseContext parseContext)

Methods inherited from class org.apache.tika.pipes.api.emitter.AbstractEmitter

emit

Methods inherited from class org.apache.tika.plugins.AbstractTikaExtension

getExtensionConfig

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.tika.plugins.TikaExtension

getExtensionConfig

Method Details

build

public static KafkaEmitter build(ExtensionConfig extensionConfig)
                          throws TikaConfigException,
IOException

Throws:

TikaConfigException

IOException

emit

public void emit(String emitKey,
 List<Metadata> metadataList,
 ParseContext parseContext)
          throws IOException

Throws:

IOException