...
Property | Default & Description Reference |
---|---|
keyDeserializerserializerClass | 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
|
keySerializerClasskeyDeserializer | |
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 |
...
Property | Default & 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 | |
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 |
...