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 or kafka: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.