Skip to content

InternalKafkaProducerPool

spark.kafka.producer.cache.timeout

InternalKafkaProducerPool uses spark.kafka.producer.cache.timeout when requested to acquire a CachedKafkaProducer.

Acquiring CachedKafkaProducer

acquire(
  kafkaParams: ju.Map[String, Object]): CachedKafkaProducer

acquire...FIXME

acquire is used when...FIXME


Last update: 2020-11-09