Package org.springframework.pulsar.reader

Class PulsarReaderContainerProperties

java.lang.Object
org.springframework.pulsar.reader.PulsarReaderContainerProperties
public class PulsarReaderContainerProperties extends Object
Container properties for Pulsar Reader.
Author:
Soby Chacko

  • Constructor Details

    • PulsarReaderContainerProperties

      public PulsarReaderContainerProperties()

  • Method Details

    • getReaderListener

      public Object getReaderListener()

    • setReaderListener

      public void setReaderListener(Object readerListener)

    • getReaderTaskExecutor

      public AsyncTaskExecutor getReaderTaskExecutor()

    • setReaderTaskExecutor

      public void setReaderTaskExecutor(AsyncTaskExecutor readerExecutor)

    • getReaderStartTimeout

      public Duration getReaderStartTimeout()

    • setReaderStartTimeout

      public void setReaderStartTimeout(Duration readerStartTimeout)
      Set the timeout to wait for a reader thread to start before logging an error. Default 30 seconds.
      Parameters:
      readerStartTimeout - the reader start timeout.

    • getTopics

      public List<String> getTopics()

    • setTopics

      public void setTopics(List<String> topics)

    • getStartMessageId

      public org.apache.pulsar.client.api.MessageId getStartMessageId()

    • setStartMessageId

      public void setStartMessageId(org.apache.pulsar.client.api.MessageId startMessageId)

    • getSchema

      public org.apache.pulsar.client.api.Schema<?> getSchema()

    • setSchema

      public void setSchema(org.apache.pulsar.client.api.Schema<?> schema)

    • getSubscriptionName

      public String getSubscriptionName()

    • setSubscriptionName

      public void setSubscriptionName(String subscriptionName)

    • getSchemaType

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

    • setSchemaType

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

    • getSchemaResolver

      public SchemaResolver getSchemaResolver()

    • setSchemaResolver

      public void setSchemaResolver(SchemaResolver schemaResolver)