Packages

o

akka.projection.kafka.javadsl

KafkaSourceProvider

object KafkaSourceProvider

Source
KafkaSourceProvider.scala
Linear Supertypes
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. KafkaSourceProvider
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Value Members

  1. def create[K, V](system: ActorSystem[_], settings: ConsumerSettings[K, V], topics: Set[String]): SourceProvider[MergeableOffset[Long], ConsumerRecord[K, V]]

    Create a SourceProvider that resumes from externally managed offsets