Kafka

Kafka

Scheme: kafka
Name Kind Type Required Deprecated Default Value Enum Values Description
brokers path java.lang.String true false
zookeeperConnect parameter java.lang.String false
zookeeperHost parameter java.lang.String false
zookeeperPort parameter int false 2181
topic parameter java.lang.String false
groupId parameter java.lang.String false
partitioner parameter java.lang.String false DefaultPartitioner
consumerStreams parameter int false 10
consumersCount parameter int false 1
batchSize parameter int false 100
barrierAwaitTimeoutMs parameter int false 10000
clientId parameter java.lang.String false
consumerId parameter java.lang.String false
socketTimeoutMs parameter java.lang.Integer false
socketReceiveBufferBytes parameter java.lang.Integer false
fetchMessageMaxBytes parameter java.lang.Integer false
autoCommitEnable parameter java.lang.Boolean false
autoCommitIntervalMs parameter java.lang.Integer false
queuedMaxMessages parameter java.lang.Integer false
rebalanceMaxRetries parameter java.lang.Integer false
fetchMinBytes parameter java.lang.Integer false
fetchWaitMaxMs parameter java.lang.Integer false
rebalanceBackoffMs parameter java.lang.Integer false
refreshLeaderBackoffMs parameter java.lang.Integer false
autoOffsetReset parameter java.lang.String false
consumerTimeoutMs parameter java.lang.Integer false
zookeeperSessionTimeoutMs parameter java.lang.Integer false
zookeeperConnectionTimeoutMs parameter java.lang.Integer false
zookeeperSyncTimeMs parameter java.lang.Integer false
producerType parameter java.lang.String false
compressionCodec parameter java.lang.String false
compressedTopics parameter java.lang.String false
messageSendMaxRetries parameter java.lang.Integer false
retryBackoffMs parameter java.lang.Integer false
topicMetadataRefreshIntervalMs parameter java.lang.Integer false
sendBufferBytes parameter java.lang.Integer false
requestRequiredAcks parameter short false
requestTimeoutMs parameter java.lang.Integer false
queueBufferingMaxMs parameter java.lang.Integer false
queueBufferingMaxMessages parameter java.lang.Integer false
queueEnqueueTimeoutMs parameter java.lang.Integer false
batchNumMessages parameter java.lang.Integer false
serializerClass parameter java.lang.String false
keySerializerClass parameter java.lang.String false
exchangePattern parameter org.apache.camel.ExchangePattern false InOnly InOnly
RobustInOnly
InOut
InOptionalOut
OutOnly
RobustOutOnly
OutIn
OutOptionalIn
Sets the default exchange pattern when creating an exchange
synchronous parameter boolean false false Sets whether synchronous processing should be strictly used, or Camel is allowed to use asynchronous processing (if supported).

kafka consumer