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

Interface KafkaConsumerFactory

public interface KafkaConsumerFactory

Method Summary

Modifier and Type	Method	Description
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)

Method Details

apply

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)