Package com.here.platform.data.client.service.stream.kafka

Class ProducerCache

java.lang.Object

com.here.platform.data.client.service.stream.kafka.ProducerCache

public final class ProducerCache
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	ProducerCache.ProducerState
class	ProducerCache.ProducerState$

Constructor Summary

Constructors

Constructor	Description
ProducerCache(ClientExecutionContext clientExecutionContext, ProducerFactory producerFactory, scala.concurrent.duration.FiniteDuration producerExpirationTime)

Method Summary

Modifier and Type	Method	Description
scala.concurrent.Future<Producer>	get(HRN hrn, String layer, InternalSettings internalSettings, scala.Option<MetricReporter> metricReporter)

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ProducerCache

public ProducerCache(ClientExecutionContext clientExecutionContext,
 ProducerFactory producerFactory,
 scala.concurrent.duration.FiniteDuration producerExpirationTime)

Method Details

get

public scala.concurrent.Future<Producer> get(HRN hrn,
 String layer,
 InternalSettings internalSettings,
 scala.Option<MetricReporter> metricReporter)