io.confluent.security.audit.telemetry.exporter

Class NonBlockingKafkaExporter

java.lang.Object

io.confluent.security.audit.telemetry.exporter.NonBlockingKafkaExporter

All Implemented Interfaces:

io.confluent.telemetry.events.exporter.Exporter<io.confluent.telemetry.api.events.Event>, AutoCloseable, org.apache.kafka.common.Configurable, org.apache.kafka.common.Reconfigurable

public class NonBlockingKafkaExporter
extends Object
implements io.confluent.telemetry.events.exporter.Exporter<io.confluent.telemetry.api.events.Event>

The NonBlockingKafkaExporter sends events to topics based on their content. It doesnot block on producer metadata refresh or creation of topics.

Constructor Summary

Constructors

Constructor and Description
NonBlockingKafkaExporter()

Method Summary

Modifier and Type	Method and Description
void	close()
NonBlockingKafkaExporterConfig	config()
void	configure(Map<String,?> configs)
CompletableFuture<Boolean>	emit(io.confluent.telemetry.api.events.Event event)
CompletableFuture<Boolean>	emit(io.confluent.telemetry.api.events.Event event, Runnable onSuccess, Runnable onFailure)
Instant	lastMetadataRefresh()
Set<String>	reconfigurableConfigs()
void	reconfigure(Map<String,?> configs)
boolean	routeReady(io.confluent.telemetry.api.events.Event event)
void	validateReconfiguration(Map<String,?> configs)

Methods inherited from class java.lang.Object

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

Constructor Detail

NonBlockingKafkaExporter

public NonBlockingKafkaExporter()

Method Detail

configure

public void configure(Map<String,?> configs)

Specified by:

configure in interface org.apache.kafka.common.Configurable

emit

public CompletableFuture<Boolean> emit(io.confluent.telemetry.api.events.Event event)

Specified by:

emit in interface io.confluent.telemetry.events.exporter.Exporter<io.confluent.telemetry.api.events.Event>

emit

public CompletableFuture<Boolean> emit(io.confluent.telemetry.api.events.Event event,
                                       Runnable onSuccess,
                                       Runnable onFailure)

routeReady

public boolean routeReady(io.confluent.telemetry.api.events.Event event)

Specified by:

routeReady in interface io.confluent.telemetry.events.exporter.Exporter<io.confluent.telemetry.api.events.Event>

close

public void close()

Specified by:

close in interface AutoCloseable

reconfigurableConfigs

public Set<String> reconfigurableConfigs()

Specified by:

reconfigurableConfigs in interface org.apache.kafka.common.Reconfigurable

validateReconfiguration

public void validateReconfiguration(Map<String,?> configs)
                             throws org.apache.kafka.common.config.ConfigException

Specified by:

validateReconfiguration in interface org.apache.kafka.common.Reconfigurable

Throws:

org.apache.kafka.common.config.ConfigException

reconfigure

public void reconfigure(Map<String,?> configs)

Specified by:

reconfigure in interface org.apache.kafka.common.Reconfigurable

lastMetadataRefresh

public Instant lastMetadataRefresh()

config

public NonBlockingKafkaExporterConfig config()