Class DebeziumEndpoint<C extends EmbeddedDebeziumConfiguration>
- java.lang.Object
-
- org.apache.camel.support.service.BaseService
-
- org.apache.camel.support.service.ServiceSupport
-
- org.apache.camel.support.DefaultEndpoint
-
- org.apache.camel.component.debezium.DebeziumEndpoint<C>
-
- All Implemented Interfaces:
AutoCloseable
,org.apache.camel.CamelContextAware
,org.apache.camel.Endpoint
,org.apache.camel.IsSingleton
,org.apache.camel.Service
,org.apache.camel.ShutdownableService
,org.apache.camel.spi.HasId
,org.apache.camel.StatefulService
,org.apache.camel.SuspendableService
public abstract class DebeziumEndpoint<C extends EmbeddedDebeziumConfiguration> extends org.apache.camel.support.DefaultEndpoint
Base class for debezium endpoint implementation
-
-
Constructor Summary
Constructors Modifier Constructor Description protected
DebeziumEndpoint()
protected
DebeziumEndpoint(String uri, DebeziumComponent component)
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description org.apache.camel.Consumer
createConsumer(org.apache.camel.Processor processor)
org.apache.camel.Exchange
createDbzExchange(org.apache.kafka.connect.source.SourceRecord record)
ExecutorService
createExecutor()
org.apache.camel.Producer
createProducer()
protected Object
extractBodyValueFromValueStruct(org.apache.kafka.connect.data.Schema schema, Object value)
protected Object
extractFieldValueFromValueStruct(org.apache.kafka.connect.data.Schema schema, Object value, String fieldName)
abstract C
getConfiguration()
abstract void
setConfiguration(C configuration)
-
Methods inherited from class org.apache.camel.support.DefaultEndpoint
configureConsumer, configurePollingConsumer, configureProperties, createAsyncProducer, createEndpointUri, createExchange, createExchange, createPollingConsumer, doInit, doStart, doStop, equals, getCamelContext, getComponent, getEndpointKey, getEndpointUri, getExceptionHandler, getExchangePattern, getId, getPollingConsumerBlockTimeout, getPollingConsumerQueueSize, hashCode, isAutowiredEnabled, isBridgeErrorHandler, isLazyStartProducer, isLenientProperties, isPollingConsumerBlockWhenFull, isSingleton, isSynchronous, setAutowiredEnabled, setBridgeErrorHandler, setCamelContext, setComponent, setEndpointUri, setEndpointUriIfNotSpecified, setExceptionHandler, setExchangePattern, setLazyStartProducer, setPollingConsumerBlockTimeout, setPollingConsumerBlockWhenFull, setPollingConsumerQueueSize, setProperties, setSynchronous, toString
-
Methods inherited from class org.apache.camel.support.service.BaseService
build, doBuild, doFail, doLifecycleChange, doResume, doShutdown, doSuspend, fail, getStatus, init, isBuild, isInit, isNew, isRunAllowed, isShutdown, isStarted, isStarting, isStartingOrStarted, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
-
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
-
-
-
-
Constructor Detail
-
DebeziumEndpoint
protected DebeziumEndpoint(String uri, DebeziumComponent component)
-
DebeziumEndpoint
protected DebeziumEndpoint()
-
-
Method Detail
-
createConsumer
public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor) throws Exception
- Throws:
Exception
-
createExecutor
public ExecutorService createExecutor()
-
createDbzExchange
public org.apache.camel.Exchange createDbzExchange(org.apache.kafka.connect.source.SourceRecord record)
-
getConfiguration
public abstract C getConfiguration()
-
setConfiguration
public abstract void setConfiguration(C configuration)
-
extractBodyValueFromValueStruct
protected Object extractBodyValueFromValueStruct(org.apache.kafka.connect.data.Schema schema, Object value)
-
-