Constructor and Description |
---|
KafkaEmitter(KafkaEmitterConfig config,
com.fasterxml.jackson.databind.ObjectMapper jsonMapper) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
emit(Event event) |
void |
flush() |
void |
start() |
public KafkaEmitter(KafkaEmitterConfig config, com.fasterxml.jackson.databind.ObjectMapper jsonMapper)
public void flush() throws IOException
flush
in interface Emitter
flush
in interface Flushable
IOException
public void close() throws IOException
close
in interface Emitter
close
in interface Closeable
close
in interface AutoCloseable
IOException
Copyright © 2011–2018. All rights reserved.