Versions Compared

Key

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

...

PropertyDefault & Description Reference

serializerClass

http://kafka.apache.org/documentation.html#producerconfigs

serializerClass : org.apache.kafka.common.serialization.StringSerializer

keySerializerClass : org.apache.kafka.common.serialization.StringSerializer

partitioner : org.apache.kafka.clients.producer.internals.DefaultPartitioner 

 

 


keySerializerClass

requestRequiredAcks 

bufferMemorySize 

compressionCodec 

retries 

sslKeyPassword

sslKeystoreLocation

sslKeystorePassword

sslTruststoreLocation

sslTruststorePassword

producerBatchSize 

clientId

connectionMaxIdleMs 

lingerMs 

maxBlockMs 

maxRequestSize 

partitioner 

receiveBufferBytes 

requestTimeoutMs 

saslKerberosServiceName

saslMechanism (from Camel 2.18)

securityProtocol

sendBufferBytes 

sslEnabledProtocols 

sslKeystoreType 

sslProtocol 

sslProvider

sslTruststoreType

maxInFlightRequest 

metadataMaxAgeMs 

metricReporters

noOfMetricsSample 

metricsSampleWindowMs 

reconnectBackoffMs 

retryBackoffMs 

kerberosInitCmd 

kerberosBeforeReloginMinTime 

kerberosRenewJitter 

kerberosRenewWindowFactor 

sslCipherSuites

sslEndpointAlgorithm

sslKeymanagerAlgorithm 

sslTrustmanagerAlgorithm 

...

PropertyDefault & Description Reference

 

http://kafka.apache.org/documentation.html#newconsumerconfigs

keyDeserializer : org.apache.kafka.common.serialization.StringDeserializer

valueDeserializer : org.apache.kafka.common.serialization.StringDeserializer

partitionAssignor : org.apache.kafka.clients.consumer.RangeAssignor

 



keyDeserializer

valueDeserializer

fetchMinBytes 

groupId

heartbeatIntervalMs 

maxPartitionFetchBytes 

sessionTimeoutMs 

sslKeyPassword

sslKeystoreLocation

sslKeystorePassword

sslTruststoreLocation

sslTruststorePassword

autoOffsetReset 

connectionMaxIdleMs 

autoCommitEnable 

partitionAssignor 

receiveBufferBytes 

consumerRequestTimeoutMs 

saslKerberosServiceName

saslMechanism (from Camel 2.18)

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 

...