Class KafkaConsumerFactoryImpl
java.lang.Object
com.here.platform.data.client.service.stream.kafka.KafkaConsumerFactoryImpl
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionstatic voidaddConsumerSettings(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)
-
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)
-