THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
| Property | Default | Description |
|---|---|---|
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 | false | Camel 2.16.0: If the bridgeEndpoint is true, the producer will ignore the topic header setting of the message. |
Producer Options (Camel 2.17 or newer)
| Property | Default & Description Reference |
|---|---|
keyDeserializer | http://kafka.apache.org/documentation.html#producerconfigs |
keyDeserializer | |
requestRequiredAcks | |
bufferMemorySize | |
compressionCodec | |
retries | |
sslKeyPassword | |
sslKeystoreLocation | |
sslKeystorePassword | |
sslTruststoreLocation | |
sslTruststorePassword | |
producerBatchSize | |
clientId | |
connectionMaxIdleMs | |
lingerMs | |
maxBlockMs | |
maxRequestSize | |
partitioner | |
receiveBufferBytes | |
requestTimeoutMs | |
saslKerberosServiceName | |
securityProtocol | |
sendBufferBytes | |
sslEnabledProtocols | |
sslKeystoreType | |
sslProtocol | |
sslProvider | |
sslTruststoreType | |
timeoutMs | |
blockOnBufferFull | |
maxInFlightRequest | |
metadataFetchTimeoutMs | |
metadataMaxAgeMs | |
metricReporters | |
noOfMetricsSample | |
metricsSampleWindowMs | |
reconnectBackoffMs | |
retryBackoffMs | |
kerberosInitCmd | |
kerberosBeforeReloginMinTime | |
kerberosRenewJitter | |
kerberosRenewWindowFactor | |
sslCipherSuites | |
sslEndpointAlgorithm | |
sslKeymanagerAlgorithm | |
sslTrustmanagerAlgorithm |
Consumer Options (Camel 2.17 or newer)
| Property | Default & Description Reference |
|---|---|
bootstrapServers | http://kafka.apache.org/documentation.html#newconsumerconfigs |
keyDeserializer | |
valueDeserializer | |
fetchMinBytes | |
groupId | |
heartbeatIntervalMs | |
maxPartitionFetchBytes | |
sessionTimeoutMs | |
sslKeyPassword | |
sslKeystoreLocation | |
sslKeystorePassword | |
sslTruststoreLocation | |
sslTruststorePassword | |
autoOffsetReset | |
connectionMaxIdleMs | |
autoCommitEnable | |
partitionAssignor | |
receiveBufferBytes | |
consumerRequestTimeoutMs | |
saslKerberosServiceName | |
securityProtocol | |
sendBufferBytes | |
sslEnabledProtocols | |
sslKeystoreType | |
sslProtocol | |
sslProvider | |
sslTruststoreType | |
autoCommitIntervalMs | |
checkCrcs | |
clientId | |
fetchWaitMaxMs | |
metadataMaxAgeMs | |
metricReporters | |
noOfMetricsSample | |
metricsSampleWindowMs | |
reconnectBackoffMs | |
retryBackoffMs | |
kerberosInitCmd | |
kerberosBeforeReloginMinTime | |
kerberosRenewJitter | |
kerberosRenewWindowFactor | |
sslCipherSuites | |
sslEndpointAlgorithm | |
sslKeymanagerAlgorithm | |
sslTrustmanagerAlgorithm |
Samples
Camel 2.16 or older
...