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

Interface ProducerFactory

All Known Implementing Classes:

ProducerFactoryImpl

public interface ProducerFactory

Creates a new producer instance from given parameters

Method Summary

Modifier and Type	Method	Description
scala.concurrent.Future<Producer>	create(ProducerKey key, HereToken hereTokenCredentials, scala.Function3<ProducerKey,String,org.apache.kafka.clients.producer.Producer<String,byte[]>,scala.runtime.BoxedUnit> regionChangeListener)
Producer	createReconnected(ProducerKey key, String topic, org.apache.kafka.clients.producer.Producer<String,byte[]> producer)

Method Details

create

scala.concurrent.Future<Producer> create(ProducerKey key,
 HereToken hereTokenCredentials,
 scala.Function3<ProducerKey,String,org.apache.kafka.clients.producer.Producer<String,byte[]>,scala.runtime.BoxedUnit> regionChangeListener)

createReconnected

Producer createReconnected(ProducerKey key,
 String topic,
 org.apache.kafka.clients.producer.Producer<String,byte[]> producer)