Packages

c

pl.touk.nussknacker.engine.lite.components

LiteKafkaSourceImpl

class LiteKafkaSourceImpl[K, V] extends LiteKafkaSource with SourceTestSupport[ConsumerRecord[Array[Byte], Array[Byte]]] with RecordFormatterBaseTestDataGenerator

Linear Supertypes
RecordFormatterBaseTestDataGenerator, TestDataGenerator, SourceTestSupport[ConsumerRecord[Array[Byte], Array[Byte]]], LiteKafkaSource, BaseLiteSource[ConsumerRecord[Array[Byte], Array[Byte]]], Lifecycle, AutoCloseable, LiteSource[ConsumerRecord[Array[Byte], Array[Byte]]], Source, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. LiteKafkaSourceImpl
  2. RecordFormatterBaseTestDataGenerator
  3. TestDataGenerator
  4. SourceTestSupport
  5. LiteKafkaSource
  6. BaseLiteSource
  7. Lifecycle
  8. AutoCloseable
  9. LiteSource
  10. Source
  11. AnyRef
  12. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new LiteKafkaSourceImpl(contextInitializer: ContextInitializer[ConsumerRecord[K, V]], deserializationSchema: KafkaDeserializationSchema[ConsumerRecord[K, V]], nodeId: NodeId, preparedTopics: List[PreparedKafkaTopic], kafkaConfig: KafkaConfig, formatter: RecordFormatter)

Value Members

  1. def close(): Unit
    Definition Classes
    Lifecycle → AutoCloseable
  2. def createTransformation[F[_]](componentContext: CustomComponentContext[F])(implicit arg0: Monad[F]): (ConsumerRecord[Array[Byte], Array[Byte]]) ⇒ ValidatedNel[ErrorType, Context]
    Definition Classes
    BaseLiteSource → LiteSource
  3. val formatter: RecordFormatter
    Definition Classes
    LiteKafkaSourceImpl → RecordFormatterBaseTestDataGenerator
  4. def generateTestData(size: Int): Array[Byte]
    Definition Classes
    RecordFormatterBaseTestDataGenerator → TestDataGenerator
  5. val kafkaConfig: KafkaConfig
    Definition Classes
    LiteKafkaSourceImpl → RecordFormatterBaseTestDataGenerator
  6. val nodeId: NodeId
    Definition Classes
    LiteKafkaSourceImpl → BaseLiteSource
  7. def open(context: EngineRuntimeContext): Unit
    Definition Classes
    LiteKafkaSourceImpl → BaseLiteSource → Lifecycle
  8. def testDataParser: TestDataParser[ConsumerRecord[Array[Byte], Array[Byte]]]
    Definition Classes
    LiteKafkaSourceImpl → SourceTestSupport
  9. val topics: List[String]
    Definition Classes
    LiteKafkaSourceImpl → RecordFormatterBaseTestDataGenerator → LiteKafkaSource
  10. def transform(record: ConsumerRecord[Array[Byte], Array[Byte]]): Context
    Definition Classes
    LiteKafkaSourceImpl → BaseLiteSource