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

Interface DirectKafka

All Known Implementing Classes:

DirectKafkaImpl

public interface DirectKafka

Method Summary

Modifier and Type	Method	Description
scala.concurrent.Future<org.apache.pekko.Done>	publish(HRN hrn, PublishPartition partition, InternalSettings internalSettings, scala.Option<MetricReporter> metricReporter, boolean isCompressed)
scala.concurrent.Future<org.apache.pekko.stream.scaladsl.Source<com.here.platform.data.client.scaladsl.Partition,com.here.platform.data.client.scaladsl.SubscriptionControl>>	subscribe(HRN hrn, String layerId, ConsumerSettings consumerSettings, InternalSettings internalSettings, boolean isCompressed)
scala.concurrent.Future<org.apache.pekko.stream.scaladsl.Source<BatchPublicationNotification,com.here.platform.data.client.scaladsl.SubscriptionControl>>	subscribeToNotifications(HRN hrn, ConsumerSettings consumerSettings, InternalSettings internalSettings)

Method Details

publish

scala.concurrent.Future<org.apache.pekko.Done> publish(HRN hrn,
 PublishPartition partition,
 InternalSettings internalSettings,
 scala.Option<MetricReporter> metricReporter,
 boolean isCompressed)

subscribe

scala.concurrent.Future<org.apache.pekko.stream.scaladsl.Source<com.here.platform.data.client.scaladsl.Partition,com.here.platform.data.client.scaladsl.SubscriptionControl>> subscribe(HRN hrn,
 String layerId,
 ConsumerSettings consumerSettings,
 InternalSettings internalSettings,
 boolean isCompressed)

subscribeToNotifications

scala.concurrent.Future<org.apache.pekko.stream.scaladsl.Source<BatchPublicationNotification,com.here.platform.data.client.scaladsl.SubscriptionControl>> subscribeToNotifications(HRN hrn,
 ConsumerSettings consumerSettings,
 InternalSettings internalSettings)