Packages

package kafka

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. All

Type Members

  1. case class BasicRecordFormatter(testDataSplit: TestDataSplit) extends RecordFormatter with Product with Serializable
  2. trait RecordFormatter extends Serializable

    It is interface for bi-directional conversion between Kafka record and bytes.

    It is interface for bi-directional conversion between Kafka record and bytes. It is used when data stored on topic aren't in human readable format and you need to add extra step in generation of test data and in reading of these data.

  3. trait RecordFormatterBaseTestDataGenerator extends TestDataGenerator
  4. trait RecordFormatterFactory extends Serializable

Value Members

  1. object BasicRecordFormatter extends Serializable
  2. object KafkaComponentsUtils extends KafkaUtils
  3. object KafkaFactory
  4. object RecordFormatterFactory extends Serializable

Ungrouped