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

emit

Methods inherited from class AbstractTikaExtension

getExtensionConfig

Methods inherited from class Object

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

Methods inherited from interface 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