...
| Code Block |
|---|
kafka:server:port[?options]
|
Options (Camel 2.16 or older)
| Div |
|---|
| class | confluenceTableSmall |
|---|
|
Property | Default | Description |
|---|
zookeeperHost | | The zookeeper host to use | zookeeperPort | 2181 | The zookeeper port to use | | zookeeperConnect | | Camel 2.13.3/2.14.1: If in use, then zookeeperHost/zookeeperPort is not used. | topic | | The topic to use | groupId | | | partitioner | | | consumerStreams | 10 | | clientId | | | zookeeperSessionTimeoutMs | | | zookeeperConnectionTimeoutMs | | | zookeeperSyncTimeMs | | | consumersCount | 1 | Camel 2.15.0: The number of consumers that connect to kafka server | batchSize | 100 | Camel 2.15.0: The batchSize that the BatchingConsumerTask processes once.
| barrierAwaitTimeoutMs | 10000 | Camel 2.15.0: If the BatchingConsumerTask processes exchange exceed the batchSize, it will wait for barrierAwaitTimeoutMs.
| | bridgeEndpoint | false | Camel 2.16.0: If the bridgeEndpoint is true, the producer will ignore the topic header setting of the message. |
|
You can append query options to the URI in the following format, ?option=value&option=value&...
Producer
...
Options (Camel 2.16 or older)
| Div |
|---|
| class | confluenceTableSmall |
|---|
|
Property | Default | Description |
|---|
producerType | sync (Taken from native KafkaProducer class) | sync - send message/batch immediately, and wait until response is received async - queue the message/batch to send. There is a thread per broker (Kafka node) which polls from this queue upon queueBufferingMaxMs or batchNumMessages | | compressionCodec | | | | compressedTopics | | | | messageSendMaxRetries | | | | retryBackoffMs | | | | topicMetadataRefreshIntervalMs | | | | sendBufferBytes | | | | requestRequiredAcks | | | | requestTimeoutMs | | | | queueBufferingMaxMs | | | | queueBufferingMaxMessages | | | | queueEnqueueTimeoutMs | | | | batchNumMessages | | | | serializerClass | | | | keySerializerClass | | |
|
Consumer
...
Options (Camel 2.16 or older)
| Div |
|---|
| class | confluenceTableSmall |
|---|
|
Property | Default | Description |
|---|
consumerId | | | | socketTimeoutMs | | | | socketReceiveBufferBytes | | | | fetchMessageMaxBytes | | | | autoCommitEnable | | | | autoCommitIntervalMs | | | | queuedMaxMessages | | | | rebalanceMaxRetries | | | | fetchMinBytes | | | | fetchWaitMaxMs | | | | rebalanceBackoffMs | | | | refreshLeaderBackoffMs | | | | autoOffsetReset | | | | consumerTimeoutMs | | |
|
...
