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

Class ProducerImpl

java.lang.Object

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

All Implemented Interfaces:

Producer

public final class ProducerImpl
extends Object
implements Producer

Constructor Summary

Constructors

Constructor	Description
ProducerImpl(String topic, String loggingKey, org.apache.kafka.clients.producer.Producer<String,byte[]> producer, RetryPolicyType retryPolicyType, ClientExecutionContext clientExecutionContext)

Method Summary

Modifier and Type	Method	Description
ClientExecutionContext	clientExecutionContext()
scala.concurrent.Future<org.apache.pekko.Done>	close()
final scala.concurrent.duration.FiniteDuration	CloseKafkaTimeout()	Time to block a close operation for kafka producer/consumer, including time to send all pending data.
scala.concurrent.Future<org.apache.pekko.Done>	send(PublishPartition partition, boolean isCompressed)

Methods inherited from class java.lang.Object

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

Constructor Details

ProducerImpl

public ProducerImpl(String topic,
 String loggingKey,
 org.apache.kafka.clients.producer.Producer<String,byte[]> producer,
 RetryPolicyType retryPolicyType,
 ClientExecutionContext clientExecutionContext)

Method Details

CloseKafkaTimeout

public final scala.concurrent.duration.FiniteDuration CloseKafkaTimeout()

Time to block a close operation for kafka producer/consumer, including time to send all pending data. Default message send timeout is 60 seconds, so everything that is left there should be already timed out.

clientExecutionContext

public ClientExecutionContext clientExecutionContext()

close

public scala.concurrent.Future<org.apache.pekko.Done> close()

Specified by:

close in interface Producer

send

public scala.concurrent.Future<org.apache.pekko.Done> send(PublishPartition partition,
 boolean isCompressed)

Specified by:

send in interface Producer