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

Class AsyncConsumerImpl

java.lang.Object
com.here.platform.data.client.service.stream.kafka.AsyncConsumerImpl
All Implemented Interfaces:
AsyncConsumer
public class AsyncConsumerImpl extends Object implements AsyncConsumer
Wrap java kafka consumer that must run in a single thread

  • Constructor Summary

    Constructors
    Constructor
    Description
    AsyncConsumerImpl(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 Summary

    Modifier and Type
    Method
    Description
    scala.concurrent.Future<org.apache.pekko.Done>
    close()
     
    final scala.concurrent.duration.FiniteDuration
    CloseKafkaTimeout()
     
    scala.concurrent.Future<org.apache.pekko.Done>
    commitOffset(scala.collection.immutable.Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndMetadata> state)
     
    void
    request()
     
    scala.concurrent.Future<scala.collection.immutable.Map<String,String>>
    retrieveMetrics(scala.collection.immutable.List<String> metricNames)
     
    scala.concurrent.Future<org.apache.pekko.Done>
    stop()
     

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • AsyncConsumerImpl

      public AsyncConsumerImpl(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

    • CloseKafkaTimeout

      public final scala.concurrent.duration.FiniteDuration CloseKafkaTimeout()

    • close

      public scala.concurrent.Future<org.apache.pekko.Done> close()
      Specified by:
      close in interface AsyncConsumer

    • commitOffset

      public scala.concurrent.Future<org.apache.pekko.Done> commitOffset(scala.collection.immutable.Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndMetadata> state)
      Specified by:
      commitOffset in interface AsyncConsumer

    • request

      public void request()
      Specified by:
      request in interface AsyncConsumer

    • retrieveMetrics

      public scala.concurrent.Future<scala.collection.immutable.Map<String,String>> retrieveMetrics(scala.collection.immutable.List<String> metricNames)
      Specified by:
      retrieveMetrics in interface AsyncConsumer

    • stop

      public scala.concurrent.Future<org.apache.pekko.Done> stop()
      Specified by:
      stop in interface AsyncConsumer