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

Class KafkaConsumerFactoryImpl

java.lang.Object

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

public class KafkaConsumerFactoryImpl
extends Object

Constructor Summary

Constructors

Constructor	Description
KafkaConsumerFactoryImpl()

Method Summary

Modifier and Type	Method	Description
static void	addConsumerSettings(Properties kafkaProperties, String consumerGroupPrefix, ConsumerSettings consumerSettings)
static org.apache.kafka.clients.consumer.Consumer<String,byte[]>	apply(KafkaEndpoints endpoints, scala.collection.immutable.Map<String,String> userProperties, KafkaStreamSettings streamSettings, ConsumerSettings consumerSettings, String token, org.apache.pekko.stream.stage.AsyncCallback<org.apache.kafka.clients.consumer.Consumer<String,byte[]>> regionChangeListener, String endpoint)

Methods inherited from class java.lang.Object

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

Constructor Details

KafkaConsumerFactoryImpl

public KafkaConsumerFactoryImpl()

Method Details

addConsumerSettings

public static void addConsumerSettings(Properties kafkaProperties,
 String consumerGroupPrefix,
 ConsumerSettings consumerSettings)

apply

public static org.apache.kafka.clients.consumer.Consumer<String,byte[]> apply(KafkaEndpoints endpoints,
 scala.collection.immutable.Map<String,String> userProperties,
 KafkaStreamSettings streamSettings,
 ConsumerSettings consumerSettings,
 String token,
 org.apache.pekko.stream.stage.AsyncCallback<org.apache.kafka.clients.consumer.Consumer<String,byte[]>> regionChangeListener,
 String endpoint)