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

Interface AsyncConsumerFactory

public interface AsyncConsumerFactory

Method Summary

Modifier and Type	Method	Description
AsyncConsumer	apply(String consumerKey, String dataClientKafkaConsumerId, org.apache.kafka.clients.consumer.Consumer<String,byte[]> consumer, scala.Function1<scala.collection.immutable.Vector<org.apache.kafka.clients.consumer.ConsumerRecord<String,byte[]>>,scala.runtime.BoxedUnit> callback, scala.Function1<Throwable,scala.runtime.BoxedUnit> onFailure, ClientExecutionContext clientExecutionContext)

Method Details

apply

AsyncConsumer apply(String consumerKey,
 String dataClientKafkaConsumerId,
 org.apache.kafka.clients.consumer.Consumer<String,byte[]> consumer,
 scala.Function1<scala.collection.immutable.Vector<org.apache.kafka.clients.consumer.ConsumerRecord<String,byte[]>>,scala.runtime.BoxedUnit> callback,
 scala.Function1<Throwable,scala.runtime.BoxedUnit> onFailure,
 ClientExecutionContext clientExecutionContext)