Class PulsarProperties.Listener
java.lang.Object
org.springframework.pulsar.autoconfigure.PulsarProperties.Listener
- Enclosing class:
- PulsarProperties
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionorg.apache.pulsar.common.schema.SchemaTypevoidsetAckMode(AckMode ackMode) voidsetBatchTimeout(Duration batchTimeout) voidsetMaxNumBytes(DataSize maxNumBytes) voidsetMaxNumMessages(Integer maxNumMessages) voidsetObservationsEnabled(Boolean observationsEnabled) voidsetSchemaType(org.apache.pulsar.common.schema.SchemaType schemaType)
-
Constructor Details
-
Listener
public Listener()
-
-
Method Details
-
getAckMode
-
setAckMode
-
getSchemaType
public org.apache.pulsar.common.schema.SchemaType getSchemaType() -
setSchemaType
public void setSchemaType(org.apache.pulsar.common.schema.SchemaType schemaType) -
getMaxNumMessages
-
setMaxNumMessages
-
getMaxNumBytes
-
setMaxNumBytes
-
getBatchTimeout
-
setBatchTimeout
-
isObservationsEnabled
-
setObservationsEnabled
-