Class DebeziumEndpoint<C extends EmbeddedDebeziumConfiguration>

  • 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
    • Field Summary

      • Fields inherited from class org.apache.camel.support.service.BaseService

        BUILT, FAILED, INITIALIZED, INITIALIZING, lock, NEW, SHUTDOWN, SHUTTING_DOWN, STARTED, STARTING, status, STOPPED, STOPPING, SUSPENDED, SUSPENDING
    • 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 interface org.apache.camel.Endpoint

        getEndpointBaseUri, isSingletonProducer
      • Methods inherited from interface org.apache.camel.Service

        build, close, init, start, stop
      • Methods inherited from interface org.apache.camel.ShutdownableService

        shutdown
      • Methods inherited from interface org.apache.camel.StatefulService

        getStatus, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isSuspending
      • Methods inherited from interface org.apache.camel.SuspendableService

        isSuspended, resume, suspend
    • Constructor Detail

      • DebeziumEndpoint

        protected DebeziumEndpoint()
    • Method Detail

      • createProducer

        public org.apache.camel.Producer createProducer()
                                                 throws Exception
        Throws:
        Exception
      • createConsumer

        public org.apache.camel.Consumer createConsumer​(org.apache.camel.Processor processor)
                                                 throws Exception
        Throws:
        Exception
      • 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)
      • extractFieldValueFromValueStruct

        protected Object extractFieldValueFromValueStruct​(org.apache.kafka.connect.data.Schema schema,
                                                          Object value,
                                                          String fieldName)