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