Record - kafka : ProducerConfiguration

Represents the Kafka Producer configuration.

Fields

  • bootstrapServers string
  • List of remote server endpoints of Kafka brokers

  • acks ProducerAcks (default ACKS_SINGLE)
  • Number of acknowledgments

  • 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 the 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 implement the kafka:Serializer object

  • keySerializer Serializer
  • Custom serializer object to serialize Kafka keys. This should implement the kafka:Serializer object

  • schemaRegistryUrl string
  • Avro schema registry URL. Use this field to specify the schema registry URL if the 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 during which the sending is blocked when the buffer is full

  • requestTimeoutInMillis int
  • Wait time for the response of a request

  • metadataMaxAgeInMillis int
  • Maximum time to force a refresh of metadata

  • metricsSampleWindowInMillis int
  • Time window for a metrics sample to compute over

  • metricsNumSamples int
  • Number of samples maintained to compute the metrics

  • maxInFlightRequestsPerConnection int
  • Maximum number of unacknowledged requests on a single connection

  • connectionsMaxIdleTimeInMillis int
  • Close the idle connections after this 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