Record -
kafka
: ProducerConfig
Struct which represents Kafka Producer configuration.
Fields
- bootstrapServers string ()
-
List of remote server endpoints of Kafka brokers.
- acks Producer_Acks ACKS_SINGLE
-
Number of acknowledgments. This can be either
kafka:ACKS_ALL
,kafka:ACKS_SINGLE
orkafka:ACKS_NONE
.
- compressionType string ()
-
Compression type to be used for messages.
- clientId string ()
-
Identifier to be used for server side logging.
- metricsRecordingLevel string ()
-
Metrics recording level.
- metricReporterClasses string ()
-
Metrics reporter classes.
- partitionerClass string ()
-
Partitioner class to be used to select partition to which the message is sent.
- interceptorClasses string ()
-
Interceptor classes to be used before sending records.
- transactionalId string ()
-
Transactional ID to be used in transactional delivery.
- bufferMemory int -1
-
Total bytes of memory the producer can use to buffer records.
- retryCount int -1
-
Number of retries to resend a record.
- batchSize int -1
-
Number of records to be batched for a single request. Use 0 for no batching.
- linger int -1
-
Delay to allow other records to be batched.
- sendBuffer int -1
-
Size of the TCP send buffer (SO_SNDBUF).
- receiveBuffer int -1
-
Size of the TCP receive buffer (SO_RCVBUF).
- maxRequestSize int -1
-
The maximum size of a request in bytes.
- reconnectBackoffTimeInMillis int -1
-
Time to wait before attempting to reconnect.
- reconnectBackoffMaxTimeInMillis int -1
-
Maximum amount of time in milliseconds to wait when reconnecting.
- retryBackoffTimeInMillis int -1
-
Time to wait before attempting to retry a failed request.
- maxBlock int -1
-
Maximum block time which the send is blocked, when the buffer is full.
- requestTimeoutInMillis int -1
-
Wait time for response of a request.
- metadataMaxAgeInMillis int -1
-
Maximum time to force a refresh of metadata.
- metricsSampleWindowInMillis int -1
-
Time window for a metrics sample to computed over.
- metricsNumSamples int -1
-
Number of samples maintained to compute metrics.
- maxInFlightRequestsPerConnection int -1
-
Maximum number of unacknowledged requests on a single connection.
- connectionsMaxIdleTimeInMillis int -1
-
Close idle connections after the number of milliseconds.
- transactionTimeoutInMillis int -1
-
Timeout for transaction status update from the producer.
- enableIdempotence boolean false
-
Exactly one copy of each message is written in the stream when enabled.
- secureSocket SecureSocket
-
Configurations related to SSL/TLS.