Record -
kafka
: ConsumerConfig
Configuration related to consumer endpoint.
Fields
- bootstrapServers string ()
-
List of remote server endpoints of kafka brokers.
- groupId string ()
-
Unique string that identifies the consumer.
- offsetReset string ()
-
Offset reset strategy if no initial offset.
- partitionAssignmentStrategy string ()
-
Strategy class for handling the partition assignment among consumers.
- metricsRecordingLevel string ()
-
Metrics recording level.
- metricsReporterClasses string ()
-
Metrics reporter classes.
- clientId string ()
-
Identifier to be used for server side logging.
- interceptorClasses string ()
-
Interceptor classes to be used before sending records.
- isolationLevel string ()
-
Transactional message reading method. Use "read_committed" to read committed messages only in transactional mode when poll() is called. Use "read_uncommitted" to read all the messages, even the aborted ones.
- topics string ()
-
Topics to be subscribed by the consumer.
- properties string ()
-
Additional properties if required.
- sessionTimeoutInMillis int -1
-
Timeout used to detect consumer failures when heartbeat threshold is reached.
- heartBeatIntervalInMillis int -1
-
Expected time between heartbeats.
- metadataMaxAgeInMillis int -1
-
Maximum time to force a refresh of metadata.
- autoCommitIntervalInMillis int -1
-
Auto committing interval for commit offset, when auto-commit is enabled.
- maxPartitionFetchBytes int -1
-
The maximum amount of data per-partition the server returns.
- sendBuffer int -1
-
Size of the TCP send buffer (SO_SNDBUF).
- receiveBuffer int -1
-
Size of the TCP receive buffer (SO_RCVBUF).
- fetchMinBytes int -1
-
Minimum amount of data the server should return for a fetch request.
- fetchMaxBytes int -1
-
Maximum amount of data the server should return for a fetch request.
- fetchMaxWaitTimeInMillis int -1
-
Maximum amount of time the server will block before answering the fetch request.
- reconnectBackoffTimeMaxInMillis int -1
-
Maximum amount of time in milliseconds to wait when reconnecting.
- retryBackoffInMillis int -1
-
Time to wait before attempting to retry a failed request.
- metricsSampleWindowInMillis int -1
-
Window of time a metrics sample is computed over.
- metricsNumSamples int -1
-
Number of samples maintained to compute metrics.
- requestTimeoutInMillis int -1
-
Wait time for response of a request.
- connectionMaxIdleTimeInMillis int -1
-
Close idle connections after the number of milliseconds.
- maxPollRecords int -1
-
Maximum number of records returned in a single call to poll.
- maxPollInterval int -1
-
Maximum delay between invocations of poll.
- reconnectBackoffTimeInMillis int -1
-
Time to wait before attempting to reconnect.
- pollingTimeoutInMillis int -1
-
Timeout interval for polling.
- pollingIntervalInMillis int -1
-
Polling interval for the consumer.
- concurrentConsumers int -1
-
Number of concurrent consumers.
- defaultApiTimeoutInMillis int 30000
-
Default API timeout value for APIs with duration.
- autoCommit boolean true
-
Enables auto committing offsets.
- checkCRCS boolean true
-
Check the CRC32 of the records consumed.
- excludeInternalTopics boolean true
-
Whether records from internal topics should be exposed to the consumer.
- decoupleProcessing boolean false
-
Decouples processing
- secureSocket SecureSocket
-
SSL/TLS related options