Package org.springframework.pulsar.annotation

Annotation Interface PulsarReader

@Target({TYPE,METHOD,ANNOTATION_TYPE}) @Retention(RUNTIME) @MessageMapping @Documented public @interface PulsarReader

  • Element Details

    • id

      String id
      The unique identifier of the container for this listener.

      If none is specified an auto-generated id is used.

      SpEL #{...} and property placeholders ${...} are supported.

      Returns:
      the id for the container managing for this endpoint.
      See Also:
      Default:
      ""

    • subscriptionName

      String subscriptionName
      Pulsar subscription name associated with this listener.
      Returns:
      the subscriptionName for this Pulsar listener endpoint.
      Default:
      ""

    • schemaType

      org.apache.pulsar.common.schema.SchemaType schemaType
      Pulsar schema type for this listener.
      Returns:
      the schemaType for this listener
      Default:
      NONE

    • startMessageId

      String startMessageId
      MessageId for this reader to start from.
      Returns:
      starting message id - earliest or latest.
      Default:
      ""

    • topics

      String[] topics
      Topics to listen to.
      Returns:
      a comma separated list of topics to listen from.
      Default:
      {}

    • beanRef

      String beanRef
      Default:
      "__listener"

    • containerFactory

      String containerFactory
      Default:
      ""

    • autoStartup

      String autoStartup
      Default:
      ""

    • readerCustomizer

      String readerCustomizer
      The bean name or a 'SpEL' expression that resolves to a ReaderBuilderCustomizer to use to configure the reader.
      Returns:
      the bean name or empty string to not configure the reader.
      Default:
      ""