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

Class DirectKafkaImpl

java.lang.Object

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

All Implemented Interfaces:

DirectKafka

public class DirectKafkaImpl
extends Object
implements DirectKafka

param: streamConfig configuration with root at here.platform.data-client.stream

Constructor Summary

Constructors

Constructor	Description
DirectKafkaImpl(com.typesafe.config.Config streamConfig, StreamConfigProvider streamService, RetryPolicyType retryPolicyType, ClientExecutionContext clientExecutionContext)

Method Summary

Modifier and Type	Method	Description
static scala.concurrent.Future<KafkaEndpoints>	chooseEndpoints(String connectorKey, scala.collection.immutable.Seq<KafkaEndpoint> bootstrapServers, scala.collection.immutable.Seq<KafkaEndpoint> bootstrapServersInternal, ClientExecutionContext clientExecutionContext, org.apache.pekko.event.LoggingAdapter log)
ClientExecutionContext	ex()
static scala.collection.immutable.Map<String,String>	parseConnectorProperties(com.typesafe.config.Config config)
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)
scala.collection.mutable.Buffer<String>	supportedProtocolVersions()

Methods inherited from class java.lang.Object

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

Constructor Details

DirectKafkaImpl

public DirectKafkaImpl(com.typesafe.config.Config streamConfig,
 StreamConfigProvider streamService,
 RetryPolicyType retryPolicyType,
 ClientExecutionContext clientExecutionContext)

Method Details

parseConnectorProperties

public static scala.collection.immutable.Map<String,String> parseConnectorProperties(com.typesafe.config.Config config)

chooseEndpoints

public static scala.concurrent.Future<KafkaEndpoints> chooseEndpoints(String connectorKey,
 scala.collection.immutable.Seq<KafkaEndpoint> bootstrapServers,
 scala.collection.immutable.Seq<KafkaEndpoint> bootstrapServersInternal,
 ClientExecutionContext clientExecutionContext,
 org.apache.pekko.event.LoggingAdapter log)

ex

public ClientExecutionContext ex()

supportedProtocolVersions

public scala.collection.mutable.Buffer<String> supportedProtocolVersions()

publish

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

Specified by:

publish in interface DirectKafka

subscribe

public 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)

Specified by:

subscribe in interface DirectKafka

subscribeToNotifications

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

Specified by:

subscribeToNotifications in interface DirectKafka