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