Package com.floragunn.searchguard.auditlog.sink

Class KafkaSink

java.lang.Object

com.floragunn.searchguard.auditlog.sink.AuditLogSink

com.floragunn.searchguard.auditlog.sink.KafkaSink

public class KafkaSink
extends AuditLogSink

Field Summary

Fields inherited from class com.floragunn.searchguard.auditlog.sink.AuditLogSink

fallbackSink, log, settings, settingsPrefix

Constructor Summary

Constructors

Constructor	Description
KafkaSink(String name, org.elasticsearch.common.settings.Settings settings, String settingsPrefix, AuditLogSink fallbackSink)

Method Summary

Modifier and Type	Method	Description
void	close()
protected boolean	doStore(AuditMessage msg)
boolean	isHandlingBackpressure()

Methods inherited from class com.floragunn.searchguard.auditlog.sink.AuditLogSink

equals, getExpandedIndexName, getFallbackSink, getName, getSinkSettings, hashCode, store, toString

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

KafkaSink

public KafkaSink(String name,
                 org.elasticsearch.common.settings.Settings settings,
                 String settingsPrefix,
                 AuditLogSink fallbackSink)

Method Detail

doStore

protected boolean doStore(AuditMessage msg)

Specified by:

doStore in class AuditLogSink

isHandlingBackpressure

public boolean isHandlingBackpressure()

Overrides:

isHandlingBackpressure in class AuditLogSink

close

public void close()
           throws IOException

Overrides:

close in class AuditLogSink

Throws:

IOException