Class DirectKafkaImpl
java.lang.Object
com.here.platform.data.client.service.stream.kafka.DirectKafkaImpl
- All Implemented Interfaces:
DirectKafka
param: streamConfig configuration with root at here.platform.data-client.stream
-
Constructor Summary
ConstructorsConstructorDescriptionDirectKafkaImpl(com.typesafe.config.Config streamConfig, StreamConfigProvider streamService, RetryPolicyType retryPolicyType, ClientExecutionContext clientExecutionContext) -
Method Summary
Modifier and TypeMethodDescriptionstatic 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()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>
-
Constructor Details
-
DirectKafkaImpl
public DirectKafkaImpl(com.typesafe.config.Config streamConfig, StreamConfigProvider streamService, RetryPolicyType retryPolicyType, ClientExecutionContext clientExecutionContext)
-
-
Method Details
-
parseConnectorProperties
-
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
-
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:
publishin interfaceDirectKafka
-
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:
subscribein interfaceDirectKafka
-
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:
subscribeToNotificationsin interfaceDirectKafka
-