public class KafkaComponent extends UriEndpointComponent
shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending
Constructor and Description |
---|
KafkaComponent() |
KafkaComponent(CamelContext context) |
Modifier and Type | Method and Description |
---|---|
protected KafkaEndpoint |
createEndpoint(String uri,
String remaining,
Map<String,Object> params)
A factory method allowing derived components to create a new endpoint
from the given URI, remaining path and optional parameters
|
ExecutorService |
getWorkerPool() |
void |
setWorkerPool(ExecutorService workerPool)
To use a shared custom worker pool for continue routing
Exchange after kafka server has acknowledge
the message that was sent to it from KafkaProducer using asynchronous non-blocking processing. |
createComponentConfiguration, createParameterConfigurationMap, getEndpointClass, getParameterConfigurationMap, populateParameterConfigurationMap, setEndpointClass
afterConfiguration, createConfiguration, createEndpoint, doStart, doStop, getAndRemoveOrResolveReferenceParameter, getAndRemoveOrResolveReferenceParameter, getAndRemoveParameter, getAndRemoveParameter, getCamelContext, ifStartsWithReturnRemainder, preProcessUri, resolveAndRemoveReferenceListParameter, resolveAndRemoveReferenceListParameter, resolveAndRemoveReferenceParameter, resolveAndRemoveReferenceParameter, setCamelContext, setProperties, setProperties, useIntrospectionOnEndpoint, useRawUri, validateParameters, validateURI
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
public KafkaComponent()
public KafkaComponent(CamelContext context)
protected KafkaEndpoint createEndpoint(String uri, String remaining, Map<String,Object> params) throws Exception
DefaultComponent
createEndpoint
in class DefaultComponent
uri
- the full URI of the endpointremaining
- the remaining part of the URI without the query
parameters or component prefixparams
- the optional parameters passed inException
- is thrown if error creating the endpointpublic ExecutorService getWorkerPool()
public void setWorkerPool(ExecutorService workerPool)
Exchange
after kafka server has acknowledge
the message that was sent to it from KafkaProducer
using asynchronous non-blocking processing.
If using this option then you must handle the lifecycle of the thread pool to shut the pool down when no longer needed.Copyright © 2007–2016 The Apache Software Foundation. All rights reserved.