...
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.
|
|
You can append query options to the URI in the following format, ?option=value&option=value&...
...