Class PulsarProducerProperties

java.lang.Object
io.numaproj.pulsar.config.producer.PulsarProducerProperties

public class PulsarProducerProperties extends Object
Parsed representation of the pulsar.producer section of application.yml. Call validateConfig() before constructing a producer.
  • Constructor Details

    • PulsarProducerProperties

      public PulsarProducerProperties()
  • Method Details

    • validateConfig

      public void validateConfig()
      Validates the configuration to catch unsupported combinations of fields.
      Throws:
      IllegalArgumentException - if useAutoProduceSchema is false and dropInvalidMessages is true