Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

Div
classconfluenceTableSmall

Property

Default

Description

consumerId

 

 
socketTimeoutMs  
socketReceiveBufferBytes  
fetchMessageMaxBytes  
autoCommitEnable  
autoCommitIntervalMs  
queuedMaxMessages  
rebalanceMaxRetries  
fetchMinBytes  
fetchWaitMaxMs  
rebalanceBackoffMs  
refreshLeaderBackoffMs  
autoOffsetReset  
consumerTimeoutMs  

Options (Camel 2.17 or newer)

PropertyDefaultDescription

topic

 Topic to use

groupId

  

consumerStreams

10 

clientId

  

consumersCount

1

The number of consumers that connect to kafka server

batchSize

100

Commit Size if auto commit is false

bridgeEndpoint

falseCamel 2.16.0: If the bridgeEndpoint is true, the producer will ignore the topic header setting of the message.

 

Samples

Camel 2.16 or older

...