Package com.here.platform.data.client.impl

Class WrappedSubscriptionControl

java.lang.Object
com.here.platform.data.client.impl.WrappedSubscriptionControl
All Implemented Interfaces:
SubscriptionControl
public final class WrappedSubscriptionControl extends Object implements SubscriptionControl

  • Constructor Details

    • WrappedSubscriptionControl

      public WrappedSubscriptionControl(com.here.platform.data.client.scaladsl.SubscriptionControl delegate)

  • Method Details

    • acknowledge

      public void acknowledge(Partition partition)
      Description copied from interface: SubscriptionControl
      Only with manual offsets.

      Notify the subscription that user already process the partition and can be include in next [checkpoint] call.

      Specified by:
      acknowledge in interface SubscriptionControl

    • checkpoint

      public CompletionStage<org.apache.pekko.Done> checkpoint()
      Description copied from interface: SubscriptionControl
      Only with manual offsets.

      Persist in server the offset for all [acknowledge] partitions for current groupName

      Specified by:
      checkpoint in interface SubscriptionControl

    • getKafkaMetrics

      public CompletionStage<scala.collection.immutable.Map<String,String>> getKafkaMetrics(scala.collection.immutable.List<String> metricNames)
      Description copied from interface: SubscriptionControl
      Exposes Kafka consumer metrics.

      A specific list of Kafka metric name Strings can be specified in metricNames. If there is no argument passed (or the list is empty), then all available Kafka consumer metrics will be retrieved. Only the metric name should be specified (without including the group), for example "time-between-poll-avg" or "records-consumed-rate".

      In the Kafka consumer metrics returned, the client-id value will be taken from the consumerId field in ConsumerSettings, which can be set to a specified value (if it is not set, then by default a random UUID will be assigned as client-id).

      Specified by:
      getKafkaMetrics in interface SubscriptionControl

    • shutdown

      public CompletionStage<org.apache.pekko.Done> shutdown()
      Description copied from interface: SubscriptionControl
      Shutdown the stream. It will wait for outstanding processes to finish before shutting down.
      Specified by:
      shutdown in interface SubscriptionControl