Class ProducerCache
java.lang.Object
com.here.platform.data.client.service.stream.kafka.ProducerCache
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionclassclass -
Constructor Summary
ConstructorsConstructorDescriptionProducerCache(ClientExecutionContext clientExecutionContext, ProducerFactory producerFactory, scala.concurrent.duration.FiniteDuration producerExpirationTime) -
Method Summary
Modifier and TypeMethodDescriptionscala.concurrent.Future<Producer>get(HRN hrn, String layer, InternalSettings internalSettings, scala.Option<MetricReporter> metricReporter)
-
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)
-