Package com.adaptris.kafka

Class KafkaConnection

java.lang.Object

com.adaptris.core.AdaptrisConnectionImp

com.adaptris.core.NoOpConnection

com.adaptris.kafka.KafkaConnection

All Implemented Interfaces:

AdaptrisComponent, AdaptrisConnection, ComponentLifecycle, ComponentLifecycleExtension, StateManagedComponent

@ComponentProfile(summary="Connection to Apache Kafka",
                  tag="connections,kafka")
public class KafkaConnection
extends NoOpConnection

Wraps the Map<String,Object> object used to create KafkaConsumer KafkaProducer instances.

In the adapter configuration file this class is aliased as apache-kafka-connection which is the preferred alternative to the fully qualified classname when building your configuration.

Field Summary

Fields inherited from class com.adaptris.core.AdaptrisConnectionImp

log

Constructor Summary

Constructors

Constructor	Description
KafkaConnection()
KafkaConnection(ConfigBuilder builder)

Method Summary

Modifier and Type	Method	Description
java.util.Map<java.lang.String,java.lang.Object>	buildConfig(ConfigBuilder.KeyFilter filter)
@NotNull @NonNull ConfigBuilder	getConfigBuilder()
void	setConfigBuilder(@NotNull @NonNull ConfigBuilder configBuilder)

Methods inherited from class com.adaptris.core.NoOpConnection

closeConnection, initConnection, prepareConnection, startConnection, stopConnection

Methods inherited from class com.adaptris.core.AdaptrisConnectionImp

addExceptionListener, addMessageConsumer, addMessageProducer, changeState, cloneForTesting, close, connectionErrorHandler, getConnectionErrorHandler, getUniqueId, getWorkersFirstOnShutdown, init, prepare, requestClose, requestInit, requestStart, requestStop, retrieveComponentState, retrieveConnection, retrieveExceptionListeners, retrieveMessageConsumers, retrieveMessageProducers, setConnectionErrorHandler, setUniqueId, setWorkersFirstOnShutdown, start, stop, workersFirstOnShutdown

Methods inherited from class java.lang.Object

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

Constructor Detail

KafkaConnection

public KafkaConnection()

KafkaConnection

public KafkaConnection(ConfigBuilder builder)

Method Detail

buildConfig

public java.util.Map<java.lang.String,java.lang.Object> buildConfig(ConfigBuilder.KeyFilter filter)
                                                                   throws CoreException

Throws:

CoreException

getConfigBuilder

@NotNull
@NonNull
public @NotNull @NonNull ConfigBuilder getConfigBuilder()

setConfigBuilder

public void setConfigBuilder(@NotNull @NonNull
                             @NotNull @NonNull ConfigBuilder configBuilder)