Class KafkaTools.Produce.KeyOrValueSpec

java.lang.Object
io.deephaven.kafka.KafkaTools.Produce.KeyOrValueSpec
Enclosing class:
KafkaTools.Produce

public abstract static class KafkaTools.Produce.KeyOrValueSpec extends Object
Class to specify conversion of table columns to Kafka KEY or VALUE fields.
  • Constructor Details

    • KeyOrValueSpec

      public KeyOrValueSpec()
  • Method Details

    • getSchemaProvider

      Optional<io.confluent.kafka.schemaregistry.SchemaProvider> getSchemaProvider()