Class VertxKafkaEndpoint
- java.lang.Object
-
- org.apache.camel.support.service.BaseService
-
- org.apache.camel.support.service.ServiceSupport
-
- org.apache.camel.support.DefaultEndpoint
-
- org.apache.camel.component.vertx.kafka.VertxKafkaEndpoint
-
- 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
@UriEndpoint(firstVersion="3.7.0", scheme="vertx-kafka", title="Vert.x Kafka", syntax="vertx-kafka:topic", category=MESSAGING) public class VertxKafkaEndpoint extends org.apache.camel.support.DefaultEndpoint
Sent and receive messages to/from an Apache Kafka broker using vert.x Kafka client
-
-
Constructor Summary
Constructors Constructor Description VertxKafkaEndpoint()
VertxKafkaEndpoint(String uri, org.apache.camel.Component component, VertxKafkaConfiguration configuration)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description org.apache.camel.Consumer
createConsumer(org.apache.camel.Processor processor)
org.apache.camel.Exchange
createExchange(io.vertx.kafka.client.consumer.KafkaConsumerRecord<Object,Object> record)
org.apache.camel.Producer
createProducer()
VertxKafkaComponent
getComponent()
VertxKafkaConfiguration
getConfiguration()
The component configurationsio.vertx.core.Vertx
getVertx()
void
setConfiguration(VertxKafkaConfiguration configuration)
-
Methods inherited from class org.apache.camel.support.DefaultEndpoint
configureConsumer, configurePollingConsumer, configureProperties, createAsyncProducer, createEndpointUri, createExchange, createExchange, createPollingConsumer, doInit, doStart, doStop, equals, getCamelContext, 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
-
VertxKafkaEndpoint
public VertxKafkaEndpoint()
-
VertxKafkaEndpoint
public VertxKafkaEndpoint(String uri, org.apache.camel.Component component, VertxKafkaConfiguration configuration)
-
-
Method Detail
-
createConsumer
public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor) throws Exception
- Throws:
Exception
-
getComponent
public VertxKafkaComponent getComponent()
- Overrides:
getComponent
in classorg.apache.camel.support.DefaultEndpoint
-
getVertx
public io.vertx.core.Vertx getVertx()
-
createExchange
public org.apache.camel.Exchange createExchange(io.vertx.kafka.client.consumer.KafkaConsumerRecord<Object,Object> record)
-
getConfiguration
public VertxKafkaConfiguration getConfiguration()
The component configurations
-
setConfiguration
public void setConfiguration(VertxKafkaConfiguration configuration)
-
-