Interface EventProcessorDefinition.ConfigurationStep<T extends EventProcessorConfiguration>

Type Parameters:
T - The type of EventProcessorConfiguration for this processor.
All Superinterfaces:
EventProcessorDefinition
Enclosing interface:
EventProcessorDefinition

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

    • customized

      EventProcessorDefinition customized(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:

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

      EventProcessorDefinition notCustomized()
      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.