Record -
kafka
: ProducerConfiguration
Struct which represents Kafka Producer configuration.
Fields
- bootstrapServers string
-
List of remote server endpoints of Kafka brokers.
- acks ProducerAcks (default ACKS_SINGLE)
-
Number of acknowledgments. This can be either
kafka:ACKS_ALL
,kafka:ACKS_SINGLE
orkafka:ACKS_NONE
.
- compressionType CompressionType (default COMPRESSION_NONE)
-
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.
- valueSerializerType SerializerType (default SER_BYTE_ARRAY)
-
Serializer used for the Kafka record value. This can be either
kafka:SerializerType
or a user-defined serializer.
- keySerializerType SerializerType (default SER_BYTE_ARRAY)
-
Serializer used for the Kafka record key. This can be either
kafka:SerializerType
or a user-defined serializer.
- valueSerializer Serializer
-
Custom serializer object to serialize kafka values. This should be implement the
kafka:Serializer
object.
- keySerializer Serializer
-
Custom serializer object to serialize kafka keys. This should be implement the
kafka:Serializer
object.
- schemaRegistryUrl string
-
Avro schema registry url. Use this field to specify schema registry url, if Avro serializer is used.
- bufferMemory int
-
Total bytes of memory the producer can use to buffer records.
- retryCount int
-
Number of retries to resend a record.
- batchSize int
-
Number of records to be batched for a single request. Use 0 for no batching.
- linger int
-
Delay to allow other records to be batched.
- sendBuffer int
-
Size of the TCP send buffer (SO_SNDBUF).
- receiveBuffer int
-
Size of the TCP receive buffer (SO_RCVBUF).
- maxRequestSize int
-
The maximum size of a request in bytes.
- reconnectBackoffTimeInMillis int
-
Time to wait before attempting to reconnect.
- reconnectBackoffMaxTimeInMillis int
-
Maximum amount of time in milliseconds to wait when reconnecting.
- retryBackoffTimeInMillis int
-
Time to wait before attempting to retry a failed request.
- maxBlock int
-
Maximum block time which the send is blocked, when the buffer is full.
- requestTimeoutInMillis int
-
Wait time for response of a request.
- metadataMaxAgeInMillis int
-
Maximum time to force a refresh of metadata.
- metricsSampleWindowInMillis int
-
Time window for a metrics sample to computed over.
- metricsNumSamples int
-
Number of samples maintained to compute metrics.
- maxInFlightRequestsPerConnection int
-
Maximum number of unacknowledged requests on a single connection.
- connectionsMaxIdleTimeInMillis int
-
Close idle connections after the number of milliseconds.
- transactionTimeoutInMillis int
-
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.