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

Class DirectKafkaConsumerImpl

java.lang.Object

org.apache.pekko.stream.stage.GraphStageWithMaterializedValue<org.apache.pekko.stream.SourceShape<scala.collection.immutable.Vector<org.apache.kafka.clients.consumer.ConsumerRecord<String,byte[]>>>,com.here.platform.data.client.scaladsl.SubscriptionControl>

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

All Implemented Interfaces:

org.apache.pekko.stream.Graph<org.apache.pekko.stream.SourceShape<scala.collection.immutable.Vector<org.apache.kafka.clients.consumer.ConsumerRecord<String,byte[]>>>,com.here.platform.data.client.scaladsl.SubscriptionControl>

public class DirectKafkaConsumerImpl
extends org.apache.pekko.stream.stage.GraphStageWithMaterializedValue<org.apache.pekko.stream.SourceShape<scala.collection.immutable.Vector<org.apache.kafka.clients.consumer.ConsumerRecord<String,byte[]>>>,com.here.platform.data.client.scaladsl.SubscriptionControl>

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.pekko.stream.Graph

org.apache.pekko.stream.Graph.GraphMapMatVal<S extends org.apache.pekko.stream.Shape,M extends Object>

Constructor Summary

Constructors

Constructor	Description
DirectKafkaConsumerImpl(scala.collection.immutable.Map<String,String> userProperties, ConsumerSettings consumerSettings, KafkaStreamSettings streamSettings, HereTokenProvider tokenProvider, String endpoint, AsyncConsumerFactory asyncConsumerFactory, KafkaConsumerFactory kafkaConsumerFactory, ClientExecutionContext clientExecutionContext)

Method Summary

Modifier and Type	Method	Description
ClientExecutionContext	clientExecutionContext()
scala.Tuple2<org.apache.pekko.stream.stage.GraphStageLogic,com.here.platform.data.client.scaladsl.SubscriptionControl>	createLogicAndMaterializedValue(org.apache.pekko.stream.Attributes inheritedAttributes)
org.apache.pekko.stream.SourceShape<scala.collection.immutable.Vector<org.apache.kafka.clients.consumer.ConsumerRecord<String,byte[]>>>	shape()

Methods inherited from class org.apache.pekko.stream.stage.GraphStageWithMaterializedValue

addAttributes, async, async, async, createLogicAndMaterializedValue, getAttributes, initialAttributes, named, traversalBuilder, withAttributes

Methods inherited from class java.lang.Object

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

Constructor Details

DirectKafkaConsumerImpl

public DirectKafkaConsumerImpl(scala.collection.immutable.Map<String,String> userProperties,
 ConsumerSettings consumerSettings,
 KafkaStreamSettings streamSettings,
 HereTokenProvider tokenProvider,
 String endpoint,
 AsyncConsumerFactory asyncConsumerFactory,
 KafkaConsumerFactory kafkaConsumerFactory,
 ClientExecutionContext clientExecutionContext)

Method Details

clientExecutionContext

public ClientExecutionContext clientExecutionContext()

shape

public org.apache.pekko.stream.SourceShape<scala.collection.immutable.Vector<org.apache.kafka.clients.consumer.ConsumerRecord<String,byte[]>>> shape()

createLogicAndMaterializedValue

public scala.Tuple2<org.apache.pekko.stream.stage.GraphStageLogic,com.here.platform.data.client.scaladsl.SubscriptionControl> createLogicAndMaterializedValue(org.apache.pekko.stream.Attributes inheritedAttributes)

Specified by:

createLogicAndMaterializedValue in class org.apache.pekko.stream.stage.GraphStageWithMaterializedValue<org.apache.pekko.stream.SourceShape<scala.collection.immutable.Vector<org.apache.kafka.clients.consumer.ConsumerRecord<String,byte[]>>>,com.here.platform.data.client.scaladsl.SubscriptionControl>