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

Interface AsyncConsumer

All Known Implementing Classes:
AsyncConsumerImpl
public interface AsyncConsumer

  • Method Summary

    Modifier and Type
    Method
    Description
    scala.concurrent.Future<org.apache.pekko.Done>
    close()
     
    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()
     

  • Method Details

    • request

      void request()

    • close

      scala.concurrent.Future<org.apache.pekko.Done> close()

    • stop

      scala.concurrent.Future<org.apache.pekko.Done> stop()

    • commitOffset

      scala.concurrent.Future<org.apache.pekko.Done> commitOffset(scala.collection.immutable.Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndMetadata> state)

    • retrieveMetrics

      scala.concurrent.Future<scala.collection.immutable.Map<String,String>> retrieveMetrics(scala.collection.immutable.List<String> metricNames)