Package org.springframework.pulsar.core

Interface ReaderBuilderCustomizer<T>

Type Parameters:
T - The message payload type
Functional Interface:
This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.
@FunctionalInterface public interface ReaderBuilderCustomizer<T>
Callback interface that can be implemented to customize the ReaderBuilder that is used by the PulsarReaderFactory to create readers.

When using Spring Boot autoconfiguration, any beans implementing this interface will be used as default configuration by the DefaultPulsarReaderFactory and as such will apply to all created readers.

The reader factory also supports passing in a specific instance of this callback when creating a reader and as such the passed in customizer only applies to the single created reader.

Author:
Soby Chacko

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    customize(org.apache.pulsar.client.api.ReaderBuilder<T> readerBuilder)
    Customizes a ReaderBuilder.

  • Method Details

    • customize

      void customize(org.apache.pulsar.client.api.ReaderBuilder<T> readerBuilder)
      Customizes a ReaderBuilder.
      Parameters:
      readerBuilder - the builder to customize