- setAutoCommitEnable(Boolean) - Method in class org.apache.camel.component.kafka.KafkaConfiguration
-
If true, periodically commit to ZooKeeper the offset of messages already fetched by the consumer.
- setAutoCommitIntervalMs(Integer) - Method in class org.apache.camel.component.kafka.KafkaConfiguration
-
The frequency in ms that the consumer offsets are committed to zookeeper.
- setAutoOffsetReset(String) - Method in class org.apache.camel.component.kafka.KafkaConfiguration
-
What to do when there is no initial offset in ZooKeeper or if an offset is out of range:
smallest : automatically reset the offset to the smallest offset
largest : automatically reset the offset to the largest offset
fail: throw exception to the consumer
- setBridgeEndpoint(boolean) - Method in class org.apache.camel.component.kafka.KafkaEndpoint
-
If the option is true, then KafkaProducer will ignore the KafkaConstants.TOPIC header setting of the inbound message.
- setBrokers(String) - Method in class org.apache.camel.component.kafka.KafkaConfiguration
-
This is for bootstrapping and the producer will only use it for getting metadata (topics, partitions and replicas).
- setBufferMemorySize(Integer) - Method in class org.apache.camel.component.kafka.KafkaConfiguration
-
The total bytes of memory the producer can use to buffer records waiting to be sent to the server.
- setCheckCrcs(Boolean) - Method in class org.apache.camel.component.kafka.KafkaConfiguration
-
Automatically check the CRC32 of the records consumed.
- setClientId(String) - Method in class org.apache.camel.component.kafka.KafkaConfiguration
-
The client id is a user-specified string sent in each request to help trace calls.
- setCompressionCodec(String) - Method in class org.apache.camel.component.kafka.KafkaConfiguration
-
This parameter allows you to specify the compression codec for all data generated by this producer.
- setConfiguration(KafkaConfiguration) - Method in class org.apache.camel.component.kafka.KafkaEndpoint
-
- setConnectionMaxIdleMs(Integer) - Method in class org.apache.camel.component.kafka.KafkaConfiguration
-
Close idle connections after the number of milliseconds specified by this config.
- setConsumerId(String) - Method in class org.apache.camel.component.kafka.KafkaConfiguration
-
Generated automatically if not set.
- setConsumerRequestTimeoutMs(Integer) - Method in class org.apache.camel.component.kafka.KafkaConfiguration
-
The configuration controls the maximum amount of time the client will wait for the response
of a request.
- setConsumersCount(int) - Method in class org.apache.camel.component.kafka.KafkaConfiguration
-
The number of consumers that connect to kafka server
- setConsumerStreams(int) - Method in class org.apache.camel.component.kafka.KafkaConfiguration
-
Number of concurrent consumers on the consumer
- setFetchMinBytes(Integer) - Method in class org.apache.camel.component.kafka.KafkaConfiguration
-
The minimum amount of data the server should return for a fetch request.
- setFetchWaitMaxMs(Integer) - Method in class org.apache.camel.component.kafka.KafkaConfiguration
-
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
- setGroupId(String) - Method in class org.apache.camel.component.kafka.KafkaConfiguration
-
A string that uniquely identifies the group of consumer processes to which this consumer belongs.
- setHeartbeatIntervalMs(Integer) - Method in class org.apache.camel.component.kafka.KafkaConfiguration
-
The expected time between heartbeats to the consumer coordinator when using Kafka's group management facilities.
- setKafkaProducer(KafkaProducer) - Method in class org.apache.camel.component.kafka.KafkaProducer
-
To use a custom KafkaProducer instance.
- setKerberosBeforeReloginMinTime(Integer) - Method in class org.apache.camel.component.kafka.KafkaConfiguration
-
Login thread sleep time between refresh attempts.
- setKerberosInitCmd(String) - Method in class org.apache.camel.component.kafka.KafkaConfiguration
-
Kerberos kinit command path.
- setKerberosPrincipalToLocalRules(String) - Method in class org.apache.camel.component.kafka.KafkaConfiguration
-
A list of rules for mapping from principal names to short names (typically operating system usernames).
- setKerberosRenewJitter(Double) - Method in class org.apache.camel.component.kafka.KafkaConfiguration
-
Percentage of random jitter added to the renewal time.
- setKerberosRenewWindowFactor(Double) - Method in class org.apache.camel.component.kafka.KafkaConfiguration
-
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.
- setKeyDeserializer(String) - Method in class org.apache.camel.component.kafka.KafkaConfiguration
-
Deserializer class for key that implements the Deserializer interface.
- setKeySerializerClass(String) - Method in class org.apache.camel.component.kafka.KafkaConfiguration
-
The serializer class for keys (defaults to the same as for messages if nothing is given).
- setLingerMs(Integer) - Method in class org.apache.camel.component.kafka.KafkaConfiguration
-
The producer groups together any records that arrive in between request transmissions into a single batched request.
- setMaxBlockMs(Integer) - Method in class org.apache.camel.component.kafka.KafkaConfiguration
-
The configuration controls how long sending to kafka will block.
- setMaxInFlightRequest(Integer) - Method in class org.apache.camel.component.kafka.KafkaConfiguration
-
The maximum number of unacknowledged requests the client will send on a single connection before blocking.
- setMaxPartitionFetchBytes(Integer) - Method in class org.apache.camel.component.kafka.KafkaConfiguration
-
The maximum amount of data per-partition the server will return.
- setMaxPollRecords(Integer) - Method in class org.apache.camel.component.kafka.KafkaConfiguration
-
A unique string that identifies the consumer group this consumer belongs to.
- setMaxRequestSize(Integer) - Method in class org.apache.camel.component.kafka.KafkaConfiguration
-
The maximum size of a request.
- setMetadataMaxAgeMs(Integer) - Method in class org.apache.camel.component.kafka.KafkaConfiguration
-
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.
- setMetricReporters(String) - Method in class org.apache.camel.component.kafka.KafkaConfiguration
-
A list of classes to use as metrics reporters.
- setMetricsSampleWindowMs(Integer) - Method in class org.apache.camel.component.kafka.KafkaConfiguration
-
The number of samples maintained to compute metrics.
- setNoOfMetricsSample(Integer) - Method in class org.apache.camel.component.kafka.KafkaConfiguration
-
The number of samples maintained to compute metrics.
- setPartitionAssignor(String) - Method in class org.apache.camel.component.kafka.KafkaConfiguration
-
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
- setPartitioner(String) - Method in class org.apache.camel.component.kafka.KafkaConfiguration
-
The partitioner class for partitioning messages amongst sub-topics.
- setPollTimeoutMs(Long) - Method in class org.apache.camel.component.kafka.KafkaConfiguration
-
The timeout used when polling the KafkaConsumer.
- setProducerBatchSize(Integer) - Method in class org.apache.camel.component.kafka.KafkaConfiguration
-
The producer will attempt to batch records together into fewer requests whenever multiple records are being sent to the same partition.
- setQueueBufferingMaxMessages(Integer) - Method in class org.apache.camel.component.kafka.KafkaConfiguration
-
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.
- setReceiveBufferBytes(Integer) - Method in class org.apache.camel.component.kafka.KafkaConfiguration
-
The size of the TCP receive buffer (SO_RCVBUF) to use when reading data.
- setReconnectBackoffMs(Integer) - Method in class org.apache.camel.component.kafka.KafkaConfiguration
-
The amount of time to wait before attempting to reconnect to a given host.
- setRecordMetadata(boolean) - Method in class org.apache.camel.component.kafka.KafkaConfiguration
-
Whether the producer should store the RecordMetadata results from sending to Kafka.
- setRequestRequiredAcks(String) - Method in class org.apache.camel.component.kafka.KafkaConfiguration
-
The number of acknowledgments the producer requires the leader to have received before considering a request complete.
- setRequestTimeoutMs(Integer) - Method in class org.apache.camel.component.kafka.KafkaConfiguration
-
The amount of time the broker will wait trying to meet the request.required.acks requirement before sending back an error to the client.
- setRetries(Integer) - Method in class org.apache.camel.component.kafka.KafkaConfiguration
-
Setting a value greater than zero will cause the client to resend any record whose send fails with a potentially transient error.
- setRetryBackoffMs(Integer) - Method in class org.apache.camel.component.kafka.KafkaConfiguration
-
Before each retry, the producer refreshes the metadata of relevant topics to see if a new leader has been elected.
- setSaslKerberosServiceName(String) - Method in class org.apache.camel.component.kafka.KafkaConfiguration
-
The Kerberos principal name that Kafka runs as.
- setSaslMechanism(String) - Method in class org.apache.camel.component.kafka.KafkaConfiguration
-
The Simple Authentication and Security Layer (SASL) Mechanism used.
- setSecurityProtocol(String) - Method in class org.apache.camel.component.kafka.KafkaConfiguration
-
Protocol used to communicate with brokers.
- setSeekToBeginning(boolean) - Method in class org.apache.camel.component.kafka.KafkaConfiguration
-
If the option is true, then KafkaConsumer will read from beginning on startup.
- setSendBufferBytes(Integer) - Method in class org.apache.camel.component.kafka.KafkaConfiguration
-
Socket write buffer size
- setSerializerClass(String) - Method in class org.apache.camel.component.kafka.KafkaConfiguration
-
The serializer class for messages.
- setSessionTimeoutMs(Integer) - Method in class org.apache.camel.component.kafka.KafkaConfiguration
-
The timeout used to detect failures when using Kafka's group management facilities.
- setSslCipherSuites(String) - Method in class org.apache.camel.component.kafka.KafkaConfiguration
-
A list of cipher suites.
- setSslEnabledProtocols(String) - Method in class org.apache.camel.component.kafka.KafkaConfiguration
-
The list of protocols enabled for SSL connections.
- setSslEndpointAlgorithm(String) - Method in class org.apache.camel.component.kafka.KafkaConfiguration
-
The endpoint identification algorithm to validate server hostname using server certificate.
- setSslKeymanagerAlgorithm(String) - Method in class org.apache.camel.component.kafka.KafkaConfiguration
-
The algorithm used by key manager factory for SSL connections.
- setSslKeyPassword(String) - Method in class org.apache.camel.component.kafka.KafkaConfiguration
-
The password of the private key in the key store file.
- setSslKeystoreLocation(String) - Method in class org.apache.camel.component.kafka.KafkaConfiguration
-
The location of the key store file.
- setSslKeystorePassword(String) - Method in class org.apache.camel.component.kafka.KafkaConfiguration
-
The store password for the key store file.This is optional for client and only needed
if ssl.keystore.location is configured.
- setSslKeystoreType(String) - Method in class org.apache.camel.component.kafka.KafkaConfiguration
-
The file format of the key store file.
- setSslProtocol(String) - Method in class org.apache.camel.component.kafka.KafkaConfiguration
-
The SSL protocol used to generate the SSLContext.
- setSslProvider(String) - Method in class org.apache.camel.component.kafka.KafkaConfiguration
-
The name of the security provider used for SSL connections.
- setSslTrustmanagerAlgorithm(String) - Method in class org.apache.camel.component.kafka.KafkaConfiguration
-
The algorithm used by trust manager factory for SSL connections.
- setSslTruststoreLocation(String) - Method in class org.apache.camel.component.kafka.KafkaConfiguration
-
The location of the trust store file.
- setSslTruststorePassword(String) - Method in class org.apache.camel.component.kafka.KafkaConfiguration
-
The password for the trust store file.
- setSslTruststoreType(String) - Method in class org.apache.camel.component.kafka.KafkaConfiguration
-
The file format of the trust store file.
- setTopic(String) - Method in class org.apache.camel.component.kafka.KafkaConfiguration
-
Name of the topic to use.
- setValueDeserializer(String) - Method in class org.apache.camel.component.kafka.KafkaConfiguration
-
Deserializer class for value that implements the Deserializer interface.
- setWorkerPool(ExecutorService) - Method in class org.apache.camel.component.kafka.KafkaComponent
-
To use a shared custom worker pool for continue routing
Exchange after kafka server has acknowledge
the message that was sent to it from
KafkaProducer using asynchronous non-blocking processing.
- setWorkerPool(ExecutorService) - Method in class org.apache.camel.component.kafka.KafkaConfiguration
-
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.
- setWorkerPool(ExecutorService) - Method in class org.apache.camel.component.kafka.KafkaProducer
-
- setWorkerPoolCoreSize(Integer) - Method in class org.apache.camel.component.kafka.KafkaConfiguration
-
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.
- setWorkerPoolMaxSize(Integer) - Method in class org.apache.camel.component.kafka.KafkaConfiguration
-
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.