Class PulsarProperties.Listener

java.lang.Object
org.springframework.pulsar.autoconfigure.PulsarProperties.Listener
Enclosing class:
PulsarProperties

public static class PulsarProperties.Listener extends Object
  • Constructor Details

    • Listener

      public Listener()
  • Method Details

    • getAckMode

      public AckMode getAckMode()
    • setAckMode

      public void setAckMode(AckMode ackMode)
    • getSchemaType

      public org.apache.pulsar.common.schema.SchemaType getSchemaType()
    • setSchemaType

      public void setSchemaType(org.apache.pulsar.common.schema.SchemaType schemaType)
    • getMaxNumMessages

      public Integer getMaxNumMessages()
    • setMaxNumMessages

      public void setMaxNumMessages(Integer maxNumMessages)
    • getMaxNumBytes

      public DataSize getMaxNumBytes()
    • setMaxNumBytes

      public void setMaxNumBytes(DataSize maxNumBytes)
    • getBatchTimeout

      public Duration getBatchTimeout()
    • setBatchTimeout

      public void setBatchTimeout(Duration batchTimeout)
    • isObservationsEnabled

      public Boolean isObservationsEnabled()
    • setObservationsEnabled

      public void setObservationsEnabled(Boolean observationsEnabled)