Interface ProcessorDefinition.ProcessorDefinitionConfigurationStep<T extends EventProcessorConfiguration>

Type Parameters:
T - The type of EventProcessorConfiguration for this processor.
Enclosing interface:
ProcessorDefinition

public static interface ProcessorDefinition.ProcessorDefinitionConfigurationStep<T extends EventProcessorConfiguration>
Final step in the processor definition fluent API for configuring the processor settings.
  • Method Details

    • withConfiguration

      @Nonnull ProcessorDefinition withConfiguration(@Nonnull Function<T,T> configurer)
      Applies custom configuration to the processor using the provided configuration function.

      The function receives the default configuration for the processor type and should return a modified configuration. This allows for customizing aspects such as thread pool size, batch size, error handling, and other processor-specific settings.

      Example:

      
       withConfiguration(config -> config
           .maxClaimedSegments(4)
           .batchSize(100))
       
      Parameters:
      configurer - A function that modifies the processor configuration.
      Returns:
      The completed processor definition.
    • withDefaultSettings

      @Nonnull ProcessorDefinition withDefaultSettings()
      Completes the processor definition using default settings for this processor type.

      No custom configuration will be applied; the processor will use the default configuration values appropriate for its type.

      Returns:
      The completed processor definition.