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