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 theMap<String,Object>
object used to createKafkaConsumer
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
All Methods Instance Methods Concrete Methods Modifier and Type Method Description java.util.Map<java.lang.String,java.lang.Object>
buildConfig(ConfigBuilder.KeyFilter filter)
ConfigBuilder
getConfigBuilder()
void
setConfigBuilder(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
-
-
-
-
Constructor Detail
-
KafkaConnection
public KafkaConnection()
-
KafkaConnection
public KafkaConnection(ConfigBuilder builder)
-
-
Method Detail
-
getConfigBuilder
public ConfigBuilder getConfigBuilder()
-
setConfigBuilder
public void setConfigBuilder(ConfigBuilder configBuilder)
-
buildConfig
public java.util.Map<java.lang.String,java.lang.Object> buildConfig(ConfigBuilder.KeyFilter filter) throws CoreException
- Throws:
CoreException
-
-