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)
    • 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)
    • getStartupFailureRetryTemplate

      @Nullable public org.springframework.retry.support.RetryTemplate getStartupFailureRetryTemplate()
    • getDefaultStartupFailureRetryTemplate

      public org.springframework.retry.support.RetryTemplate getDefaultStartupFailureRetryTemplate()
      Get the default template to use to retry startup when no custom retry template has been specified.
      Returns:
      the default retry template that will retry 3 times with a fixed delay of 10 seconds between each attempt.
      Since:
      1.2.0
    • setStartupFailureRetryTemplate

      public void setStartupFailureRetryTemplate(org.springframework.retry.support.RetryTemplate startupFailureRetryTemplate)
      Set the template to use to retry startup when an exception occurs during startup.
      Parameters:
      startupFailureRetryTemplate - the retry template to use
      Since:
      1.2.0
    • getStartupFailurePolicy

      public StartupFailurePolicy getStartupFailurePolicy()
    • setStartupFailurePolicy

      public void setStartupFailurePolicy(StartupFailurePolicy startupFailurePolicy)
      The action to take on the container when a failure occurs during startup.
      Parameters:
      startupFailurePolicy - action to take when a failure occurs during startup
      Since:
      1.2.0