Package ai.superstream.core

Class ConfigurationOptimizer

java.lang.Object
ai.superstream.core.ConfigurationOptimizer
public class ConfigurationOptimizer extends Object
Optimizes Kafka producer configurations based on metadata.

  • Constructor Details

    • ConfigurationOptimizer

      public ConfigurationOptimizer()

  • Method Details

    • getOptimalConfiguration

      public Map<String,Object> getOptimalConfiguration(MetadataMessage metadataMessage, List<String> applicationTopics)
      Get the optimal configuration for a set of topics.
      Parameters:
      metadataMessage - The metadata message
      applicationTopics - The list of topics that the application might produce to
      Returns:
      The optimal configuration, or an empty map if no optimization is possible

    • applyOptimalConfiguration

      public List<String> applyOptimalConfiguration(Properties properties, Map<String,Object> optimalConfiguration)
      Apply the optimal configuration to the producer properties.
      Parameters:
      properties - The producer properties to modify
      optimalConfiguration - The optimal configuration to apply
      Returns:
      The list of configuration keys that were modified