Package io.deephaven.kafka

Interface CdcTools.CdcSpec

Enclosing class:
CdcTools
public static interface CdcTools.CdcSpec
Users specify CDC streams via objects satisfying this interface; the objects are created with static factory methods, the classes implementing this interface are opaque from a user perspective.

  • Method Details

    • topic

      String topic()
      Returns:
      CDC stream kafka topic

    • keySchemaName

      String keySchemaName()
      return Avro Schema name in Schema Service for the Key Kafka field.

    • keySchemaVersion

      String keySchemaVersion()
      Returns:
      Version to use from Schema Service for the Avro Schema for the Key kafka field.

    • valueSchemaName

      String valueSchemaName()
      return Avro Schema name in Schema Service for the Value Kafka field.

    • valueSchemaVersion

      String valueSchemaVersion()
      Returns:
      Version to use from Schema Service for the Avro Schema for the Value kafka field.