default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.acks(String acks) |
The number of acknowledgments the producer requires the leader to
have received before considering a request complete.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.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 VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.allowAutoCreateTopics(boolean allowAutoCreateTopics) |
Allow automatic topic creation on the broker when subscribing to or
assigning a topic.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.autoCommitIntervalMs(int autoCommitIntervalMs) |
The frequency in milliseconds that the consumer offsets are
auto-committed to Kafka if enable.auto.commit is set to true.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.autoOffsetReset(String autoOffsetReset) |
What to do when there is no initial offset in Kafka or if the current
offset does not exist any more on the server (e.g.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.autowiredEnabled(boolean autowiredEnabled) |
Whether autowiring is enabled.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.batchSize(int batchSize) |
The producer will attempt to batch records together into fewer
requests whenever multiple records are being sent to the same
partition.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.bootstrapServers(String bootstrapServers) |
A list of host/port pairs to use for establishing the initial
connection to the Kafka cluster.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.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 VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.bufferMemory(long bufferMemory) |
The total bytes of memory the producer can use to buffer records
waiting to be sent to the server.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.checkCrcs(boolean checkCrcs) |
Automatically check the CRC32 of the records consumed.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.clientDnsLookup(String clientDnsLookup) |
Controls how the client uses DNS lookups.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.clientId(String clientId) |
An id string to pass to the server when making requests.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.clientRack(String clientRack) |
A rack identifier for this client.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.compressionType(String compressionType) |
The compression type for all data generated by the producer.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.configuration(org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration configuration) |
The component configurations.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.connectionsMaxIdleMs(long connectionsMaxIdleMs) |
Close idle connections after the number of milliseconds specified by
this config.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.defaultApiTimeoutMs(int defaultApiTimeoutMs) |
Specifies the timeout (in milliseconds) for client APIs.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.deliveryTimeoutMs(int deliveryTimeoutMs) |
An upper bound on the time to report success or failure after a call
to send() returns.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.enableAutoCommit(boolean enableAutoCommit) |
If true the consumer's offset will be periodically committed in the
background.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.enableIdempotence(boolean enableIdempotence) |
When set to 'true', the producer will ensure that exactly one copy of
each message is written in the stream.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.excludeInternalTopics(boolean excludeInternalTopics) |
Whether internal topics matching a subscribed pattern should be
excluded from the subscription.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.fetchMaxBytes(int fetchMaxBytes) |
The maximum amount of data the server should return for a fetch
request.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.fetchMaxWaitMs(int fetchMaxWaitMs) |
The maximum amount of time the server will block before answering the
fetch request if there isn't sufficient data to immediately satisfy
the requirement given by fetch.min.bytes.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.fetchMinBytes(int fetchMinBytes) |
The minimum amount of data the server should return for a fetch
request.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.groupId(String groupId) |
A unique string that identifies the consumer group this consumer
belongs to.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.groupInstanceId(String groupInstanceId) |
A unique identifier of the consumer instance provided by the end
user.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.headerFilterStrategy(org.apache.camel.spi.HeaderFilterStrategy headerFilterStrategy) |
To use a custom HeaderFilterStrategy to filter header to and from
Camel message.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.heartbeatIntervalMs(int heartbeatIntervalMs) |
The expected time between heartbeats to the consumer coordinator when
using Kafka's group management facilities.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.interceptorClasses(String interceptorClasses) |
A list of classes to use as interceptors.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.isolationLevel(String isolationLevel) |
Controls how to read messages written transactionally.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.keyDeserializer(String keyDeserializer) |
Deserializer class for key that implements the
org.apache.kafka.common.serialization.Deserializer interface.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.keySerializer(String keySerializer) |
Serializer class for key that implements the
org.apache.kafka.common.serialization.Serializer interface.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.lazyStartProducer(boolean lazyStartProducer) |
Whether the producer should be started lazy (on the first message).
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.lingerMs(long lingerMs) |
The producer groups together any records that arrive in between
request transmissions into a single batched request.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.maxBlockMs(long maxBlockMs) |
The configuration controls how long KafkaProducer.send() and
KafkaProducer.partitionsFor() will block.These methods can be blocked
either because the buffer is full or metadata unavailable.Blocking in
the user-supplied serializers or partitioner will not be counted
against this timeout.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.maxInFlightRequestsPerConnection(int maxInFlightRequestsPerConnection) |
The maximum number of unacknowledged requests the client will send on
a single connection before blocking.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.maxPartitionFetchBytes(int maxPartitionFetchBytes) |
The maximum amount of data per-partition the server will return.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.maxPollIntervalMs(int maxPollIntervalMs) |
The maximum delay between invocations of poll() when using consumer
group management.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.maxPollRecords(int maxPollRecords) |
The maximum number of records returned in a single call to poll().
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.maxRequestSize(int maxRequestSize) |
The maximum size of a request in bytes.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.metadataMaxAgeMs(long 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 VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.metadataMaxIdleMs(long metadataMaxIdleMs) |
Controls how long the producer will cache metadata for a topic that's
idle.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.metricReporters(String metricReporters) |
A list of classes to use as metrics reporters.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.metricsNumSamples(int metricsNumSamples) |
The number of samples maintained to compute metrics.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.metricsRecordingLevel(String metricsRecordingLevel) |
The highest recording level for metrics.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.metricsSampleWindowMs(long metricsSampleWindowMs) |
The window of time a metrics sample is computed over.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.partitionAssignmentStrategy(String partitionAssignmentStrategy) |
A list of class names or class types, ordered by preference, of
supported partition assignment strategies that the client will use to
distribute partition ownership amongst consumer instances when group
management is used.In addition to the default class specified below,
you can use the
org.apache.kafka.clients.consumer.RoundRobinAssignorclass for round
robin assignments of partitions to consumers.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.partitionerClass(String partitionerClass) |
Partitioner class that implements the
org.apache.kafka.clients.producer.Partitioner interface.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.partitionId(Integer partitionId) |
The partition to which the record will be sent (or null if no
partition was specified) or read from a particular partition if set.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.receiveBufferBytes(int receiveBufferBytes) |
The size of the TCP receive buffer (SO_RCVBUF) to use when reading
data.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.reconnectBackoffMaxMs(long reconnectBackoffMaxMs) |
The maximum amount of time in milliseconds to wait when reconnecting
to a broker that has repeatedly failed to connect.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.reconnectBackoffMs(long reconnectBackoffMs) |
The base amount of time to wait before attempting to reconnect to a
given host.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.requestTimeoutMs(int requestTimeoutMs) |
The configuration controls the maximum amount of time the client will
wait for the response of a request.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.retries(int retries) |
Setting a value greater than zero will cause the client to resend any
record whose send fails with a potentially transient error.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.retryBackoffMs(long retryBackoffMs) |
The amount of time to wait before attempting to retry a failed
request to a given topic partition.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.saslClientCallbackHandlerClass(String saslClientCallbackHandlerClass) |
The fully qualified name of a SASL client callback handler class that
implements the AuthenticateCallbackHandler interface.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.saslJaasConfig(String saslJaasConfig) |
JAAS login context parameters for SASL connections in the format used
by JAAS configuration files.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.saslKerberosKinitCmd(String saslKerberosKinitCmd) |
Kerberos kinit command path.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.saslKerberosMinTimeBeforeRelogin(long saslKerberosMinTimeBeforeRelogin) |
Login thread sleep time between refresh attempts.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.saslKerberosServiceName(String saslKerberosServiceName) |
The Kerberos principal name that Kafka runs as.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.saslKerberosTicketRenewJitter(double saslKerberosTicketRenewJitter) |
Percentage of random jitter added to the renewal time.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.saslKerberosTicketRenewWindowFactor(double saslKerberosTicketRenewWindowFactor) |
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 VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.saslLoginCallbackHandlerClass(String saslLoginCallbackHandlerClass) |
The fully qualified name of a SASL login callback handler class that
implements the AuthenticateCallbackHandler interface.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.saslLoginClass(String saslLoginClass) |
The fully qualified name of a class that implements the Login
interface.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.saslLoginRefreshBufferSeconds(short saslLoginRefreshBufferSeconds) |
The amount of buffer time before credential expiration to maintain
when refreshing a credential, in seconds.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.saslLoginRefreshMinPeriodSeconds(short saslLoginRefreshMinPeriodSeconds) |
The desired minimum time for the login refresh thread to wait before
refreshing a credential, in seconds.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.saslLoginRefreshWindowFactor(double saslLoginRefreshWindowFactor) |
Login refresh thread will sleep until the specified window factor
relative to the credential's lifetime has been reached, at which time
it will try to refresh the credential.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.saslLoginRefreshWindowJitter(double saslLoginRefreshWindowJitter) |
The maximum amount of random jitter relative to the credential's
lifetime that is added to the login refresh thread's sleep time.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.saslMechanism(String saslMechanism) |
SASL mechanism used for client connections.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.securityProtocol(String securityProtocol) |
Protocol used to communicate with brokers.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.securityProviders(String securityProviders) |
A list of configurable creator classes each returning a provider
implementing security algorithms.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.seekToOffset(Long seekToOffset) |
Set if KafkaConsumer will read from a particular offset on startup.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.seekToPosition(String seekToPosition) |
Set if KafkaConsumer will read from beginning or end on startup:
beginning : read from beginning end : read from end.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.sendBufferBytes(int sendBufferBytes) |
The size of the TCP send buffer (SO_SNDBUF) to use when sending data.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.sessionTimeoutMs(int sessionTimeoutMs) |
The timeout used to detect client failures when using Kafka's group
management facility.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.sslCipherSuites(String sslCipherSuites) |
A list of cipher suites.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.sslEnabledProtocols(String sslEnabledProtocols) |
The list of protocols enabled for SSL connections.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.sslEndpointIdentificationAlgorithm(String sslEndpointIdentificationAlgorithm) |
The endpoint identification algorithm to validate server hostname
using server certificate.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.sslEngineFactoryClass(String sslEngineFactoryClass) |
The class of type
org.apache.kafka.common.security.auth.SslEngineFactory to provide
SSLEngine objects.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.sslKeymanagerAlgorithm(String sslKeymanagerAlgorithm) |
The algorithm used by key manager factory for SSL connections.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.sslKeyPassword(String sslKeyPassword) |
The password of the private key in the key store file.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.sslKeystoreLocation(String sslKeystoreLocation) |
The location of the key store file.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.sslKeystorePassword(String sslKeystorePassword) |
The store password for the key store file.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.sslKeystoreType(String sslKeystoreType) |
The file format of the key store file.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.sslProtocol(String sslProtocol) |
The SSL protocol used to generate the SSLContext.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.sslProvider(String sslProvider) |
The name of the security provider used for SSL connections.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.sslSecureRandomImplementation(String sslSecureRandomImplementation) |
The SecureRandom PRNG implementation to use for SSL cryptography
operations.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.sslTrustmanagerAlgorithm(String sslTrustmanagerAlgorithm) |
The algorithm used by trust manager factory for SSL connections.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.sslTruststoreLocation(String sslTruststoreLocation) |
The location of the trust store file.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.sslTruststorePassword(String sslTruststorePassword) |
The password for the trust store file.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.sslTruststoreType(String sslTruststoreType) |
The file format of the trust store file.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.transactionalId(String transactionalId) |
The TransactionalId to use for transactional delivery.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.transactionTimeoutMs(int transactionTimeoutMs) |
The maximum amount of time in ms that the transaction coordinator
will wait for a transaction status update from the producer before
proactively aborting the ongoing transaction.If this value is larger
than the transaction.max.timeout.ms setting in the broker, the
request will fail with a InvalidTransactionTimeout error.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.valueDeserializer(String valueDeserializer) |
Deserializer class for value that implements the
org.apache.kafka.common.serialization.Deserializer interface.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.valueSerializer(String valueSerializer) |
Serializer class for value that implements the
org.apache.kafka.common.serialization.Serializer interface.
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.vertx(io.vertx.core.Vertx vertx) |
To use an existing vertx instead of creating a new instance.
|
static VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.vertxKafka() |
Vert.x Kafka (camel-vertx-kafka)
Sent and receive messages to/from an Apache Kafka broker using vert.x
Kafka client
Category: messaging
Since: 3.7
Maven coordinates: org.apache.camel:camel-vertx-kafka
|
default VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder |
VertxKafkaComponentBuilderFactory.VertxKafkaComponentBuilder.vertxOptions(io.vertx.core.VertxOptions vertxOptions) |
To provide a custom set of vertx options for configuring vertx.
|