default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.additionalProperties(String key,
Object value) |
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 VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.additionalProperties(Map values) |
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 VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.allowAutoCreateTopics(boolean allowAutoCreateTopics) |
Allow automatic topic creation on the broker when subscribing to or
assigning a topic.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.allowAutoCreateTopics(String allowAutoCreateTopics) |
Allow automatic topic creation on the broker when subscribing to or
assigning a topic.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.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 VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.autoCommitIntervalMs(String autoCommitIntervalMs) |
The frequency in milliseconds that the consumer offsets are
auto-committed to Kafka if enable.auto.commit is set to true.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.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 VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.AdvancedVertxKafkaEndpointConsumerBuilder.basic() |
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.bootstrapServers(String bootstrapServers) |
A list of host/port pairs to use for establishing the initial
connection to the Kafka cluster.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.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 VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.bridgeErrorHandler(String 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 VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.checkCrcs(boolean checkCrcs) |
Automatically check the CRC32 of the records consumed.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.checkCrcs(String checkCrcs) |
Automatically check the CRC32 of the records consumed.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.clientDnsLookup(String clientDnsLookup) |
Controls how the client uses DNS lookups.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.clientId(String clientId) |
An id string to pass to the server when making requests.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.clientRack(String clientRack) |
A rack identifier for this client.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.connectionsMaxIdleMs(long connectionsMaxIdleMs) |
Close idle connections after the number of milliseconds specified by
this config.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.connectionsMaxIdleMs(String connectionsMaxIdleMs) |
Close idle connections after the number of milliseconds specified by
this config.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.defaultApiTimeoutMs(int defaultApiTimeoutMs) |
Specifies the timeout (in milliseconds) for client APIs.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.defaultApiTimeoutMs(String defaultApiTimeoutMs) |
Specifies the timeout (in milliseconds) for client APIs.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.enableAutoCommit(boolean enableAutoCommit) |
If true the consumer's offset will be periodically committed in the
background.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.enableAutoCommit(String enableAutoCommit) |
If true the consumer's offset will be periodically committed in the
background.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.excludeInternalTopics(boolean excludeInternalTopics) |
Whether internal topics matching a subscribed pattern should be
excluded from the subscription.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.excludeInternalTopics(String excludeInternalTopics) |
Whether internal topics matching a subscribed pattern should be
excluded from the subscription.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.fetchMaxBytes(int fetchMaxBytes) |
The maximum amount of data the server should return for a fetch
request.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.fetchMaxBytes(String fetchMaxBytes) |
The maximum amount of data the server should return for a fetch
request.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.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 VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.fetchMaxWaitMs(String 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 VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.fetchMinBytes(int fetchMinBytes) |
The minimum amount of data the server should return for a fetch
request.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.fetchMinBytes(String fetchMinBytes) |
The minimum amount of data the server should return for a fetch
request.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.groupId(String groupId) |
A unique string that identifies the consumer group this consumer
belongs to.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.groupInstanceId(String groupInstanceId) |
A unique identifier of the consumer instance provided by the end
user.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.headerFilterStrategy(String headerFilterStrategy) |
To use a custom HeaderFilterStrategy to filter header to and from
Camel message.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.headerFilterStrategy(org.apache.camel.spi.HeaderFilterStrategy headerFilterStrategy) |
To use a custom HeaderFilterStrategy to filter header to and from
Camel message.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.heartbeatIntervalMs(int heartbeatIntervalMs) |
The expected time between heartbeats to the consumer coordinator when
using Kafka's group management facilities.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.heartbeatIntervalMs(String heartbeatIntervalMs) |
The expected time between heartbeats to the consumer coordinator when
using Kafka's group management facilities.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.interceptorClasses(String interceptorClasses) |
A list of classes to use as interceptors.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.isolationLevel(String isolationLevel) |
Controls how to read messages written transactionally.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.keyDeserializer(String keyDeserializer) |
Deserializer class for key that implements the
org.apache.kafka.common.serialization.Deserializer interface.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.maxPartitionFetchBytes(int maxPartitionFetchBytes) |
The maximum amount of data per-partition the server will return.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.maxPartitionFetchBytes(String maxPartitionFetchBytes) |
The maximum amount of data per-partition the server will return.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.maxPollIntervalMs(int maxPollIntervalMs) |
The maximum delay between invocations of poll() when using consumer
group management.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.maxPollIntervalMs(String maxPollIntervalMs) |
The maximum delay between invocations of poll() when using consumer
group management.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.maxPollRecords(int maxPollRecords) |
The maximum number of records returned in a single call to poll().
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.maxPollRecords(String maxPollRecords) |
The maximum number of records returned in a single call to poll().
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.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 VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.metadataMaxAgeMs(String 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 VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.metricReporters(String metricReporters) |
A list of classes to use as metrics reporters.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.metricsNumSamples(int metricsNumSamples) |
The number of samples maintained to compute metrics.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.metricsNumSamples(String metricsNumSamples) |
The number of samples maintained to compute metrics.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.metricsRecordingLevel(String metricsRecordingLevel) |
The highest recording level for metrics.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.metricsSampleWindowMs(long metricsSampleWindowMs) |
The window of time a metrics sample is computed over.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.metricsSampleWindowMs(String metricsSampleWindowMs) |
The window of time a metrics sample is computed over.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.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 VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.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 VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.partitionId(String 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 VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.receiveBufferBytes(int receiveBufferBytes) |
The size of the TCP receive buffer (SO_RCVBUF) to use when reading
data.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.receiveBufferBytes(String receiveBufferBytes) |
The size of the TCP receive buffer (SO_RCVBUF) to use when reading
data.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.reconnectBackoffMaxMs(long reconnectBackoffMaxMs) |
The maximum amount of time in milliseconds to wait when reconnecting
to a broker that has repeatedly failed to connect.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.reconnectBackoffMaxMs(String reconnectBackoffMaxMs) |
The maximum amount of time in milliseconds to wait when reconnecting
to a broker that has repeatedly failed to connect.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.reconnectBackoffMs(long reconnectBackoffMs) |
The base amount of time to wait before attempting to reconnect to a
given host.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.reconnectBackoffMs(String reconnectBackoffMs) |
The base amount of time to wait before attempting to reconnect to a
given host.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.requestTimeoutMs(int requestTimeoutMs) |
The configuration controls the maximum amount of time the client will
wait for the response of a request.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.requestTimeoutMs(String requestTimeoutMs) |
The configuration controls the maximum amount of time the client will
wait for the response of a request.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.retryBackoffMs(long retryBackoffMs) |
The amount of time to wait before attempting to retry a failed
request to a given topic partition.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.retryBackoffMs(String retryBackoffMs) |
The amount of time to wait before attempting to retry a failed
request to a given topic partition.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.saslClientCallbackHandlerClass(String saslClientCallbackHandlerClass) |
The fully qualified name of a SASL client callback handler class that
implements the AuthenticateCallbackHandler interface.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.saslJaasConfig(String saslJaasConfig) |
JAAS login context parameters for SASL connections in the format used
by JAAS configuration files.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.saslKerberosKinitCmd(String saslKerberosKinitCmd) |
Kerberos kinit command path.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.saslKerberosMinTimeBeforeRelogin(long saslKerberosMinTimeBeforeRelogin) |
Login thread sleep time between refresh attempts.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.saslKerberosMinTimeBeforeRelogin(String saslKerberosMinTimeBeforeRelogin) |
Login thread sleep time between refresh attempts.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.saslKerberosServiceName(String saslKerberosServiceName) |
The Kerberos principal name that Kafka runs as.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.saslKerberosTicketRenewJitter(double saslKerberosTicketRenewJitter) |
Percentage of random jitter added to the renewal time.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.saslKerberosTicketRenewJitter(String saslKerberosTicketRenewJitter) |
Percentage of random jitter added to the renewal time.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.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 VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.saslKerberosTicketRenewWindowFactor(String 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 VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.saslLoginCallbackHandlerClass(String saslLoginCallbackHandlerClass) |
The fully qualified name of a SASL login callback handler class that
implements the AuthenticateCallbackHandler interface.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.saslLoginClass(String saslLoginClass) |
The fully qualified name of a class that implements the Login
interface.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.saslLoginRefreshBufferSeconds(short saslLoginRefreshBufferSeconds) |
The amount of buffer time before credential expiration to maintain
when refreshing a credential, in seconds.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.saslLoginRefreshBufferSeconds(String saslLoginRefreshBufferSeconds) |
The amount of buffer time before credential expiration to maintain
when refreshing a credential, in seconds.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.saslLoginRefreshMinPeriodSeconds(short saslLoginRefreshMinPeriodSeconds) |
The desired minimum time for the login refresh thread to wait before
refreshing a credential, in seconds.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.saslLoginRefreshMinPeriodSeconds(String saslLoginRefreshMinPeriodSeconds) |
The desired minimum time for the login refresh thread to wait before
refreshing a credential, in seconds.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.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 VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.saslLoginRefreshWindowFactor(String 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 VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.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 VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.saslLoginRefreshWindowJitter(String 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 VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.saslMechanism(String saslMechanism) |
SASL mechanism used for client connections.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.securityProtocol(String securityProtocol) |
Protocol used to communicate with brokers.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.securityProviders(String securityProviders) |
A list of configurable creator classes each returning a provider
implementing security algorithms.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.seekToOffset(Long seekToOffset) |
Set if KafkaConsumer will read from a particular offset on startup.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.seekToOffset(String seekToOffset) |
Set if KafkaConsumer will read from a particular offset on startup.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.seekToPosition(String seekToPosition) |
Set if KafkaConsumer will read from beginning or end on startup:
beginning : read from beginning end : read from end.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.sendBufferBytes(int sendBufferBytes) |
The size of the TCP send buffer (SO_SNDBUF) to use when sending data.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.sendBufferBytes(String sendBufferBytes) |
The size of the TCP send buffer (SO_SNDBUF) to use when sending data.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.sessionTimeoutMs(int sessionTimeoutMs) |
The timeout used to detect client failures when using Kafka's group
management facility.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.sessionTimeoutMs(String sessionTimeoutMs) |
The timeout used to detect client failures when using Kafka's group
management facility.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.sslCipherSuites(String sslCipherSuites) |
A list of cipher suites.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.sslEnabledProtocols(String sslEnabledProtocols) |
The list of protocols enabled for SSL connections.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.sslEndpointIdentificationAlgorithm(String sslEndpointIdentificationAlgorithm) |
The endpoint identification algorithm to validate server hostname
using server certificate.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.sslEngineFactoryClass(String sslEngineFactoryClass) |
The class of type
org.apache.kafka.common.security.auth.SslEngineFactory to provide
SSLEngine objects.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.sslKeymanagerAlgorithm(String sslKeymanagerAlgorithm) |
The algorithm used by key manager factory for SSL connections.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.sslKeyPassword(String sslKeyPassword) |
The password of the private key in the key store file.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.sslKeystoreLocation(String sslKeystoreLocation) |
The location of the key store file.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.sslKeystorePassword(String sslKeystorePassword) |
The store password for the key store file.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.sslKeystoreType(String sslKeystoreType) |
The file format of the key store file.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.sslProtocol(String sslProtocol) |
The SSL protocol used to generate the SSLContext.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.sslProvider(String sslProvider) |
The name of the security provider used for SSL connections.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.sslSecureRandomImplementation(String sslSecureRandomImplementation) |
The SecureRandom PRNG implementation to use for SSL cryptography
operations.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.sslTrustmanagerAlgorithm(String sslTrustmanagerAlgorithm) |
The algorithm used by trust manager factory for SSL connections.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.sslTruststoreLocation(String sslTruststoreLocation) |
The location of the trust store file.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.sslTruststorePassword(String sslTruststorePassword) |
The password for the trust store file.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.sslTruststoreType(String sslTruststoreType) |
The file format of the trust store file.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointConsumerBuilder.valueDeserializer(String valueDeserializer) |
Deserializer class for value that implements the
org.apache.kafka.common.serialization.Deserializer interface.
|