class LiteKafkaSourceImpl[K, V] extends LiteKafkaSource with SourceTestSupport[ConsumerRecord[Array[Byte], Array[Byte]]] with RecordFormatterBaseTestDataGenerator
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- LiteKafkaSourceImpl
- RecordFormatterBaseTestDataGenerator
- TestDataGenerator
- SourceTestSupport
- LiteKafkaSource
- BaseLiteSource
- Lifecycle
- AutoCloseable
- LiteSource
- Source
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- All
Instance Constructors
- new LiteKafkaSourceImpl(contextInitializer: ContextInitializer[ConsumerRecord[K, V]], deserializationSchema: KafkaDeserializationSchema[ConsumerRecord[K, V]], nodeId: NodeId, preparedTopics: List[PreparedKafkaTopic], kafkaConfig: KafkaConfig, formatter: RecordFormatter)
Value Members
-
def
close(): Unit
- Definition Classes
- Lifecycle → AutoCloseable
-
def
createTransformation[F[_]](componentContext: CustomComponentContext[F])(implicit arg0: Monad[F]): (ConsumerRecord[Array[Byte], Array[Byte]]) ⇒ ValidatedNel[ErrorType, Context]
- Definition Classes
- BaseLiteSource → LiteSource
-
val
formatter: RecordFormatter
- Definition Classes
- LiteKafkaSourceImpl → RecordFormatterBaseTestDataGenerator
-
def
generateTestData(size: Int): Array[Byte]
- Definition Classes
- RecordFormatterBaseTestDataGenerator → TestDataGenerator
-
val
kafkaConfig: KafkaConfig
- Definition Classes
- LiteKafkaSourceImpl → RecordFormatterBaseTestDataGenerator
-
val
nodeId: NodeId
- Definition Classes
- LiteKafkaSourceImpl → BaseLiteSource
-
def
open(context: EngineRuntimeContext): Unit
- Definition Classes
- LiteKafkaSourceImpl → BaseLiteSource → Lifecycle
-
def
testDataParser: TestDataParser[ConsumerRecord[Array[Byte], Array[Byte]]]
- Definition Classes
- LiteKafkaSourceImpl → SourceTestSupport
-
val
topics: List[String]
- Definition Classes
- LiteKafkaSourceImpl → RecordFormatterBaseTestDataGenerator → LiteKafkaSource
-
def
transform(record: ConsumerRecord[Array[Byte], Array[Byte]]): Context
- Definition Classes
- LiteKafkaSourceImpl → BaseLiteSource