Class PulsarReaderContainerProperties

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

  • Constructor Details

    • PulsarReaderContainerProperties

      public PulsarReaderContainerProperties()

  • Method Details

    • getReaderListener

      public @Nullable Object getReaderListener()

    • setReaderListener

      public void setReaderListener(Object readerListener)

    • getReaderTaskExecutor

      public @Nullable 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 @Nullable List<String> getTopics()

    • setTopics

      public void setTopics(List<String> topics)

    • getStartMessageId

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

    • setStartMessageId

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

    • getSchema

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

    • setSchema

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

    • getSchemaType

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

    • setSchemaType

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

    • getSchemaResolver

      public SchemaResolver getSchemaResolver()

    • setSchemaResolver

      public void setSchemaResolver(SchemaResolver schemaResolver)

    • getStartupFailureRetryTemplate

      public @Nullable RetryTemplate getStartupFailureRetryTemplate()

    • getDefaultStartupFailureRetryTemplate

      public 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(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