default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.acks(String acks) |
The number of acknowledgments the producer requires the leader to
have received before considering a request complete.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.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.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.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.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.AdvancedVertxKafkaEndpointProducerBuilder.basic() |
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.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 VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.batchSize(String batchSize) |
The producer will attempt to batch records together into fewer
requests whenever multiple records are being sent to the same
partition.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.bootstrapServers(String bootstrapServers) |
A list of host/port pairs to use for establishing the initial
connection to the Kafka cluster.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.bufferMemory(long bufferMemory) |
The total bytes of memory the producer can use to buffer records
waiting to be sent to the server.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.bufferMemory(String bufferMemory) |
The total bytes of memory the producer can use to buffer records
waiting to be sent to the server.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.clientDnsLookup(String clientDnsLookup) |
Controls how the client uses DNS lookups.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.clientId(String clientId) |
An id string to pass to the server when making requests.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.compressionType(String compressionType) |
The compression type for all data generated by the producer.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.connectionsMaxIdleMs(long connectionsMaxIdleMs) |
Close idle connections after the number of milliseconds specified by
this config.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.connectionsMaxIdleMs(String connectionsMaxIdleMs) |
Close idle connections after the number of milliseconds specified by
this config.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.deliveryTimeoutMs(int deliveryTimeoutMs) |
An upper bound on the time to report success or failure after a call
to send() returns.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.deliveryTimeoutMs(String deliveryTimeoutMs) |
An upper bound on the time to report success or failure after a call
to send() returns.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.enableIdempotence(boolean enableIdempotence) |
When set to 'true', the producer will ensure that exactly one copy of
each message is written in the stream.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.enableIdempotence(String enableIdempotence) |
When set to 'true', the producer will ensure that exactly one copy of
each message is written in the stream.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.headerFilterStrategy(String headerFilterStrategy) |
To use a custom HeaderFilterStrategy to filter header to and from
Camel message.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.headerFilterStrategy(org.apache.camel.spi.HeaderFilterStrategy headerFilterStrategy) |
To use a custom HeaderFilterStrategy to filter header to and from
Camel message.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.interceptorClasses(String interceptorClasses) |
A list of classes to use as interceptors.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.keySerializer(String keySerializer) |
Serializer class for key that implements the
org.apache.kafka.common.serialization.Serializer interface.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.lazyStartProducer(boolean lazyStartProducer) |
Whether the producer should be started lazy (on the first message).
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.lazyStartProducer(String lazyStartProducer) |
Whether the producer should be started lazy (on the first message).
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.lingerMs(long lingerMs) |
The producer groups together any records that arrive in between
request transmissions into a single batched request.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.lingerMs(String lingerMs) |
The producer groups together any records that arrive in between
request transmissions into a single batched request.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.maxBlockMs(long maxBlockMs) |
The configuration controls how long the KafkaProducer's send(),
partitionsFor(), initTransactions(), sendOffsetsToTransaction(),
commitTransaction() and abortTransaction() methods will block.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.maxBlockMs(String maxBlockMs) |
The configuration controls how long the KafkaProducer's send(),
partitionsFor(), initTransactions(), sendOffsetsToTransaction(),
commitTransaction() and abortTransaction() methods will block.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.maxInFlightRequestsPerConnection(int maxInFlightRequestsPerConnection) |
The maximum number of unacknowledged requests the client will send on
a single connection before blocking.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.maxInFlightRequestsPerConnection(String maxInFlightRequestsPerConnection) |
The maximum number of unacknowledged requests the client will send on
a single connection before blocking.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.maxRequestSize(int maxRequestSize) |
The maximum size of a request in bytes.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.maxRequestSize(String maxRequestSize) |
The maximum size of a request in bytes.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.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.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.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.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.metadataMaxIdleMs(long metadataMaxIdleMs) |
Controls how long the producer will cache metadata for a topic that's
idle.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.metadataMaxIdleMs(String metadataMaxIdleMs) |
Controls how long the producer will cache metadata for a topic that's
idle.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.metricReporters(String metricReporters) |
A list of classes to use as metrics reporters.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.metricsNumSamples(int metricsNumSamples) |
The number of samples maintained to compute metrics.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.metricsNumSamples(String metricsNumSamples) |
The number of samples maintained to compute metrics.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.metricsRecordingLevel(String metricsRecordingLevel) |
The highest recording level for metrics.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.metricsSampleWindowMs(long metricsSampleWindowMs) |
The window of time a metrics sample is computed over.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.metricsSampleWindowMs(String metricsSampleWindowMs) |
The window of time a metrics sample is computed over.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.partitionerClass(String partitionerClass) |
Partitioner class that implements the
org.apache.kafka.clients.producer.Partitioner interface.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.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.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.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.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.receiveBufferBytes(int receiveBufferBytes) |
The size of the TCP receive buffer (SO_RCVBUF) to use when reading
data.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.receiveBufferBytes(String receiveBufferBytes) |
The size of the TCP receive buffer (SO_RCVBUF) to use when reading
data.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.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.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.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.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.reconnectBackoffMs(long reconnectBackoffMs) |
The base amount of time to wait before attempting to reconnect to a
given host.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.reconnectBackoffMs(String reconnectBackoffMs) |
The base amount of time to wait before attempting to reconnect to a
given host.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.requestTimeoutMs(int requestTimeoutMs) |
The configuration controls the maximum amount of time the client will
wait for the response of a request.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.requestTimeoutMs(String requestTimeoutMs) |
The configuration controls the maximum amount of time the client will
wait for the response of a request.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.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 VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.retries(String retries) |
Setting a value greater than zero will cause the client to resend any
record whose send fails with a potentially transient error.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.retryBackoffMs(long retryBackoffMs) |
The amount of time to wait before attempting to retry a failed
request to a given topic partition.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.retryBackoffMs(String retryBackoffMs) |
The amount of time to wait before attempting to retry a failed
request to a given topic partition.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.saslClientCallbackHandlerClass(String saslClientCallbackHandlerClass) |
The fully qualified name of a SASL client callback handler class that
implements the AuthenticateCallbackHandler interface.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.saslJaasConfig(String saslJaasConfig) |
JAAS login context parameters for SASL connections in the format used
by JAAS configuration files.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.saslKerberosKinitCmd(String saslKerberosKinitCmd) |
Kerberos kinit command path.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.saslKerberosMinTimeBeforeRelogin(long saslKerberosMinTimeBeforeRelogin) |
Login thread sleep time between refresh attempts.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.saslKerberosMinTimeBeforeRelogin(String saslKerberosMinTimeBeforeRelogin) |
Login thread sleep time between refresh attempts.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.saslKerberosServiceName(String saslKerberosServiceName) |
The Kerberos principal name that Kafka runs as.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.saslKerberosTicketRenewJitter(double saslKerberosTicketRenewJitter) |
Percentage of random jitter added to the renewal time.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.saslKerberosTicketRenewJitter(String saslKerberosTicketRenewJitter) |
Percentage of random jitter added to the renewal time.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.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.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.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.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.saslLoginCallbackHandlerClass(String saslLoginCallbackHandlerClass) |
The fully qualified name of a SASL login callback handler class that
implements the AuthenticateCallbackHandler interface.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.saslLoginClass(String saslLoginClass) |
The fully qualified name of a class that implements the Login
interface.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.saslLoginRefreshBufferSeconds(short saslLoginRefreshBufferSeconds) |
The amount of buffer time before credential expiration to maintain
when refreshing a credential, in seconds.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.saslLoginRefreshBufferSeconds(String saslLoginRefreshBufferSeconds) |
The amount of buffer time before credential expiration to maintain
when refreshing a credential, in seconds.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.saslLoginRefreshMinPeriodSeconds(short saslLoginRefreshMinPeriodSeconds) |
The desired minimum time for the login refresh thread to wait before
refreshing a credential, in seconds.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.saslLoginRefreshMinPeriodSeconds(String saslLoginRefreshMinPeriodSeconds) |
The desired minimum time for the login refresh thread to wait before
refreshing a credential, in seconds.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.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.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.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.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.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.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.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.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.saslMechanism(String saslMechanism) |
SASL mechanism used for client connections.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.securityProtocol(String securityProtocol) |
Protocol used to communicate with brokers.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.securityProviders(String securityProviders) |
A list of configurable creator classes each returning a provider
implementing security algorithms.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.sendBufferBytes(int sendBufferBytes) |
The size of the TCP send buffer (SO_SNDBUF) to use when sending data.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.sendBufferBytes(String sendBufferBytes) |
The size of the TCP send buffer (SO_SNDBUF) to use when sending data.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.socketConnectionSetupTimeoutMaxMs(long socketConnectionSetupTimeoutMaxMs) |
The maximum amount of time the client will wait for the socket
connection to be established.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.socketConnectionSetupTimeoutMaxMs(String socketConnectionSetupTimeoutMaxMs) |
The maximum amount of time the client will wait for the socket
connection to be established.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.socketConnectionSetupTimeoutMs(long socketConnectionSetupTimeoutMs) |
The amount of time the client will wait for the socket connection to
be established.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.socketConnectionSetupTimeoutMs(String socketConnectionSetupTimeoutMs) |
The amount of time the client will wait for the socket connection to
be established.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.sslCipherSuites(String sslCipherSuites) |
A list of cipher suites.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.sslEnabledProtocols(String sslEnabledProtocols) |
The list of protocols enabled for SSL connections.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.sslEndpointIdentificationAlgorithm(String sslEndpointIdentificationAlgorithm) |
The endpoint identification algorithm to validate server hostname
using server certificate.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.sslEngineFactoryClass(String sslEngineFactoryClass) |
The class of type
org.apache.kafka.common.security.auth.SslEngineFactory to provide
SSLEngine objects.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.sslKeymanagerAlgorithm(String sslKeymanagerAlgorithm) |
The algorithm used by key manager factory for SSL connections.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.sslKeyPassword(String sslKeyPassword) |
The password of the private key in the key store file orthe PEM key
specified in ssl.keystore.key'.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.sslKeystoreCertificateChain(String sslKeystoreCertificateChain) |
Certificate chain in the format specified by 'ssl.keystore.type'.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.sslKeystoreKey(String sslKeystoreKey) |
Private key in the format specified by 'ssl.keystore.type'.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.sslKeystoreLocation(String sslKeystoreLocation) |
The location of the key store file.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.sslKeystorePassword(String sslKeystorePassword) |
The store password for the key store file.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.sslKeystoreType(String sslKeystoreType) |
The file format of the key store file.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.sslProtocol(String sslProtocol) |
The SSL protocol used to generate the SSLContext.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.sslProvider(String sslProvider) |
The name of the security provider used for SSL connections.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.sslSecureRandomImplementation(String sslSecureRandomImplementation) |
The SecureRandom PRNG implementation to use for SSL cryptography
operations.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.sslTrustmanagerAlgorithm(String sslTrustmanagerAlgorithm) |
The algorithm used by trust manager factory for SSL connections.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.sslTruststoreCertificates(String sslTruststoreCertificates) |
Trusted certificates in the format specified by
'ssl.truststore.type'.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.sslTruststoreLocation(String sslTruststoreLocation) |
The location of the trust store file.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.sslTruststorePassword(String sslTruststorePassword) |
The password for the trust store file.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.sslTruststoreType(String sslTruststoreType) |
The file format of the trust store file.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.transactionalId(String transactionalId) |
The TransactionalId to use for transactional delivery.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.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 InvalidTxnTimeoutException error.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.transactionTimeoutMs(String 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 InvalidTxnTimeoutException error.
|
default VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder |
VertxKafkaEndpointBuilderFactory.VertxKafkaEndpointProducerBuilder.valueSerializer(String valueSerializer) |
Serializer class for value that implements the
org.apache.kafka.common.serialization.Serializer interface.
|