default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.additionalProperties(Map<String,Object> additionalProperties) |
Sets additional properties for either kafka consumer or kafka
producer in case they can't be set directly on the camel
configurations (e.g: new Kafka properties that are not reflected yet
in Camel configurations), the properties have to be prefixed with
additionalProperties..
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.allowManualCommit(boolean allowManualCommit) |
Whether to allow doing manual commits via KafkaManualCommit.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.autoCommitEnable(Boolean autoCommitEnable) |
If true, periodically commit to ZooKeeper the offset of messages
already fetched by the consumer.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.autoCommitIntervalMs(Integer autoCommitIntervalMs) |
The frequency in ms that the consumer offsets are committed to
zookeeper.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.autoCommitOnStop(String autoCommitOnStop) |
Whether to perform an explicit auto commit when the consumer stops to
ensure the broker has a commit from the last consumed message.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.autoOffsetReset(String autoOffsetReset) |
What to do when there is no initial offset in ZooKeeper or if an
offset is out of range: earliest : automatically reset the offset to
the earliest offset latest : automatically reset the offset to the
latest offset fail: throw exception to the consumer.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.autowiredEnabled(boolean autowiredEnabled) |
Whether autowiring is enabled.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.breakOnFirstError(boolean breakOnFirstError) |
This options controls what happens when a consumer is processing an
exchange and it fails.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.bridgeErrorHandler(boolean bridgeErrorHandler) |
Allows for bridging the consumer to the Camel routing Error Handler,
which mean any exceptions occurred while the consumer is trying to
pickup incoming messages, or the likes, will now be processed as a
message and handled by the routing Error Handler.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.brokers(String brokers) |
URL of the Kafka brokers to use.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.bufferMemorySize(Integer bufferMemorySize) |
The total bytes of memory the producer can use to buffer records
waiting to be sent to the server.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.checkCrcs(Boolean checkCrcs) |
Automatically check the CRC32 of the records consumed.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.clientId(String clientId) |
The client id is a user-specified string sent in each request to help
trace calls.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.compressionCodec(String compressionCodec) |
This parameter allows you to specify the compression codec for all
data generated by this producer.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.configuration(org.apache.camel.component.kafka.KafkaConfiguration configuration) |
Allows to pre-configure the Kafka component with common options that
the endpoints will reuse.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.connectionMaxIdleMs(Integer connectionMaxIdleMs) |
Close idle connections after the number of milliseconds specified by
this config.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.consumerRequestTimeoutMs(Integer consumerRequestTimeoutMs) |
The configuration controls the maximum amount of time the client will
wait for the response of a request.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.consumersCount(int consumersCount) |
The number of consumers that connect to kafka server.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.consumerStreams(int consumerStreams) |
Number of concurrent consumers on the consumer.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.deliveryTimeoutMs(Integer deliveryTimeoutMs) |
An upper bound on the time to report success or failure after a call
to send() returns.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.enableIdempotence(boolean enableIdempotence) |
If set to 'true' the producer will ensure that exactly one copy of
each message is written in the stream.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.fetchMaxBytes(Integer fetchMaxBytes) |
The maximum amount of data the server should return for a fetch
request This is not an absolute maximum, if the first message in the
first non-empty partition of the fetch is larger than this value, the
message will still be returned to ensure that the consumer can make
progress.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.fetchMinBytes(Integer fetchMinBytes) |
The minimum amount of data the server should return for a fetch
request.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.fetchWaitMaxMs(Integer fetchWaitMaxMs) |
The maximum amount of time the server will block before answering the
fetch request if there isn't sufficient data to immediately satisfy
fetch.min.bytes.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.groupId(String groupId) |
A string that uniquely identifies the group of consumer processes to
which this consumer belongs.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.groupInstanceId(String groupInstanceId) |
A unique identifier of the consumer instance provided by the end
user.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.headerDeserializer(org.apache.camel.component.kafka.serde.KafkaHeaderDeserializer headerDeserializer) |
To use a custom KafkaHeaderDeserializer to deserialize kafka headers
values.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.headerFilterStrategy(org.apache.camel.spi.HeaderFilterStrategy headerFilterStrategy) |
To use a custom HeaderFilterStrategy to filter header to and from
Camel message.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.headerSerializer(org.apache.camel.component.kafka.serde.KafkaHeaderSerializer headerSerializer) |
To use a custom KafkaHeaderSerializer to serialize kafka headers
values.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.heartbeatIntervalMs(Integer heartbeatIntervalMs) |
The expected time between heartbeats to the consumer coordinator when
using Kafka's group management facilities.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.interceptorClasses(String interceptorClasses) |
Sets interceptors for producer or consumers.
|
static KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.kafka() |
Kafka (camel-kafka)
Sent and receive messages to/from an Apache Kafka broker.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.kafkaClientFactory(org.apache.camel.component.kafka.KafkaClientFactory kafkaClientFactory) |
Factory to use for creating
org.apache.kafka.clients.consumer.KafkaConsumer and
org.apache.kafka.clients.producer.KafkaProducer instances.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.kafkaManualCommitFactory(org.apache.camel.component.kafka.KafkaManualCommitFactory kafkaManualCommitFactory) |
Factory to use for creating KafkaManualCommit instances.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.kerberosBeforeReloginMinTime(Integer kerberosBeforeReloginMinTime) |
Login thread sleep time between refresh attempts.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.kerberosInitCmd(String kerberosInitCmd) |
Kerberos kinit command path.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.kerberosPrincipalToLocalRules(String kerberosPrincipalToLocalRules) |
A list of rules for mapping from principal names to short names
(typically operating system usernames).
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.kerberosRenewJitter(Double kerberosRenewJitter) |
Percentage of random jitter added to the renewal time.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.kerberosRenewWindowFactor(Double kerberosRenewWindowFactor) |
Login thread will sleep until the specified window factor of time
from last refresh to ticket's expiry has been reached, at which time
it will try to renew the ticket.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.key(String key) |
The record key (or null if no key is specified).
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.keyDeserializer(String keyDeserializer) |
Deserializer class for key that implements the Deserializer
interface.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.keySerializer(String keySerializer) |
The serializer class for keys (defaults to the same as for messages
if nothing is given).
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.lazyStartProducer(boolean lazyStartProducer) |
Whether the producer should be started lazy (on the first message).
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.lingerMs(Integer lingerMs) |
The producer groups together any records that arrive in between
request transmissions into a single batched request.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.maxBlockMs(Integer maxBlockMs) |
The configuration controls how long sending to kafka will block.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.maxInFlightRequest(Integer maxInFlightRequest) |
The maximum number of unacknowledged requests the client will send on
a single connection before blocking.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.maxPartitionFetchBytes(Integer maxPartitionFetchBytes) |
The maximum amount of data per-partition the server will return.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.maxPollIntervalMs(Long maxPollIntervalMs) |
The maximum delay between invocations of poll() when using consumer
group management.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.maxPollRecords(Integer maxPollRecords) |
The maximum number of records returned in a single call to poll().
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.maxRequestSize(Integer maxRequestSize) |
The maximum size of a request.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.metadataMaxAgeMs(Integer metadataMaxAgeMs) |
The period of time in milliseconds after which we force a refresh of
metadata even if we haven't seen any partition leadership changes to
proactively discover any new brokers or partitions.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.metricReporters(String metricReporters) |
A list of classes to use as metrics reporters.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.metricsSampleWindowMs(Integer metricsSampleWindowMs) |
The number of samples maintained to compute metrics.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.noOfMetricsSample(Integer noOfMetricsSample) |
The number of samples maintained to compute metrics.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.offsetRepository(org.apache.camel.spi.StateRepository<String,String> offsetRepository) |
The offset repository to use in order to locally store the offset of
each partition of the topic.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.partitionAssignor(String partitionAssignor) |
The class name of the partition assignment strategy that the client
will use to distribute partition ownership amongst consumer instances
when group management is used.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.partitioner(String partitioner) |
The partitioner class for partitioning messages amongst sub-topics.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.partitionKey(Integer partitionKey) |
The partition to which the record will be sent (or null if no
partition was specified).
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.pollExceptionStrategy(org.apache.camel.component.kafka.PollExceptionStrategy pollExceptionStrategy) |
To use a custom strategy with the consumer to control how to handle
exceptions thrown from the Kafka broker while pooling messages.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.pollOnError(org.apache.camel.component.kafka.PollOnError pollOnError) |
What to do if kafka threw an exception while polling for new
messages.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.pollTimeoutMs(Long pollTimeoutMs) |
The timeout used when polling the KafkaConsumer.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.producerBatchSize(Integer producerBatchSize) |
The producer will attempt to batch records together into fewer
requests whenever multiple records are being sent to the same
partition.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.queueBufferingMaxMessages(Integer queueBufferingMaxMessages) |
The maximum number of unsent messages that can be queued up the
producer when using async mode before either the producer must be
blocked or data must be dropped.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.receiveBufferBytes(Integer receiveBufferBytes) |
The size of the TCP receive buffer (SO_RCVBUF) to use when reading
data.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.reconnectBackoffMaxMs(Integer reconnectBackoffMaxMs) |
The maximum amount of time in milliseconds to wait when reconnecting
to a broker that has repeatedly failed to connect.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.reconnectBackoffMs(Integer reconnectBackoffMs) |
The amount of time to wait before attempting to reconnect to a given
host.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.recordMetadata(boolean recordMetadata) |
Whether the producer should store the RecordMetadata results from
sending to Kafka.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.requestRequiredAcks(String requestRequiredAcks) |
The number of acknowledgments the producer requires the leader to
have received before considering a request complete.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.requestTimeoutMs(Integer requestTimeoutMs) |
The amount of time the broker will wait trying to meet the
request.required.acks requirement before sending back an error to the
client.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.retries(Integer retries) |
Setting a value greater than zero will cause the client to resend any
record whose send fails with a potentially transient error.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.retryBackoffMs(Integer retryBackoffMs) |
Before each retry, the producer refreshes the metadata of relevant
topics to see if a new leader has been elected.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.saslJaasConfig(String saslJaasConfig) |
Expose the kafka sasl.jaas.config parameter Example:
org.apache.kafka.common.security.plain.PlainLoginModule required
username=USERNAME password=PASSWORD;.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.saslKerberosServiceName(String saslKerberosServiceName) |
The Kerberos principal name that Kafka runs as.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.saslMechanism(String saslMechanism) |
The Simple Authentication and Security Layer (SASL) Mechanism used.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.schemaRegistryURL(String schemaRegistryURL) |
URL of the Confluent Platform schema registry servers to use.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.securityProtocol(String securityProtocol) |
Protocol used to communicate with brokers.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.seekTo(String seekTo) |
Set if KafkaConsumer will read from beginning or end on startup:
beginning : read from beginning end : read from end This is replacing
the earlier property seekToBeginning.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.sendBufferBytes(Integer sendBufferBytes) |
Socket write buffer size.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.sessionTimeoutMs(Integer sessionTimeoutMs) |
The timeout used to detect failures when using Kafka's group
management facilities.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.shutdownTimeout(int shutdownTimeout) |
Timeout in milli seconds to wait gracefully for the consumer or
producer to shutdown and terminate its worker threads.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.specificAvroReader(boolean specificAvroReader) |
This enables the use of a specific Avro reader for use with the
Confluent Platform schema registry and the
io.confluent.kafka.serializers.KafkaAvroDeserializer.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.sslCipherSuites(String sslCipherSuites) |
A list of cipher suites.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.sslContextParameters(org.apache.camel.support.jsse.SSLContextParameters sslContextParameters) |
SSL configuration using a Camel SSLContextParameters object.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.sslEnabledProtocols(String sslEnabledProtocols) |
The list of protocols enabled for SSL connections.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.sslEndpointAlgorithm(String sslEndpointAlgorithm) |
The endpoint identification algorithm to validate server hostname
using server certificate.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.sslKeymanagerAlgorithm(String sslKeymanagerAlgorithm) |
The algorithm used by key manager factory for SSL connections.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.sslKeyPassword(String sslKeyPassword) |
The password of the private key in the key store file.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.sslKeystoreLocation(String sslKeystoreLocation) |
The location of the key store file.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.sslKeystorePassword(String sslKeystorePassword) |
The store password for the key store file.This is optional for client
and only needed if ssl.keystore.location is configured.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.sslKeystoreType(String sslKeystoreType) |
The file format of the key store file.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.sslProtocol(String sslProtocol) |
The SSL protocol used to generate the SSLContext.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.sslProvider(String sslProvider) |
The name of the security provider used for SSL connections.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.sslTrustmanagerAlgorithm(String sslTrustmanagerAlgorithm) |
The algorithm used by trust manager factory for SSL connections.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.sslTruststoreLocation(String sslTruststoreLocation) |
The location of the trust store file.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.sslTruststorePassword(String sslTruststorePassword) |
The password for the trust store file.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.sslTruststoreType(String sslTruststoreType) |
The file format of the trust store file.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.synchronous(boolean synchronous) |
Sets whether synchronous processing should be strictly used.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.topicIsPattern(boolean topicIsPattern) |
Whether the topic is a pattern (regular expression).
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.useGlobalSslContextParameters(boolean useGlobalSslContextParameters) |
Enable usage of global SSL context parameters.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.valueDeserializer(String valueDeserializer) |
Deserializer class for value that implements the Deserializer
interface.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.valueSerializer(String valueSerializer) |
The serializer class for messages.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.workerPool(ExecutorService workerPool) |
To use a 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.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.workerPoolCoreSize(Integer workerPoolCoreSize) |
Number of core threads for the 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.
|
default KafkaComponentBuilderFactory.KafkaComponentBuilder |
KafkaComponentBuilderFactory.KafkaComponentBuilder.workerPoolMaxSize(Integer workerPoolMaxSize) |
Maximum number of threads for the 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.
|