java.lang.Object
org.springframework.pulsar.autoconfigure.ProducerConfigProperties
org.springframework.pulsar.spring.cloud.stream.binder.properties.PulsarProducerProperties

public class PulsarProducerProperties extends ProducerConfigProperties
Pulsar producer properties used by the binder.
Author:
Soby Chacko, Chris Bono
  • Constructor Details

    • PulsarProducerProperties

      public PulsarProducerProperties()
  • Method Details

    • getSchemaType

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

      public void setSchemaType(@Nullable org.apache.pulsar.common.schema.SchemaType schemaType)
    • getMessageType

      @Nullable public Class<?> getMessageType()
    • setMessageType

      public void setMessageType(@Nullable Class<?> messageType)
    • getMessageKeyType

      @Nullable public Class<?> getMessageKeyType()
    • setMessageKeyType

      public void setMessageKeyType(@Nullable Class<?> messageKeyType)
    • getPartitionCount

      @Nullable public Integer getPartitionCount()
    • setPartitionCount

      public void setPartitionCount(Integer partitionCount)