SuperstreamManager (Superstream Kafka Client Optimizer 1.0.1-beta API)

java.lang.Object

ai.superstream.core.SuperstreamManager

public class SuperstreamManager extends Object

Main manager class for the Superstream library.

Method Summary

Modifier and Type

Method

Description

static Map<String,Object>

convertPropertiesToMap(Properties properties)

static SuperstreamManager

getInstance()

Get the singleton instance of the SuperstreamManager.

static boolean

isOptimizationInProgress()

Check if optimization is already in progress for the current thread.

boolean

optimizeProducer(String bootstrapServers, String clientId, Properties properties)

Optimize the producer properties for a given Kafka cluster.

static void

setOptimizationInProgress(boolean inProgress)

Set the optimization in progress flag for the current thread.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details
- isOptimizationInProgress
  
  public static boolean isOptimizationInProgress()
  
  Check if optimization is already in progress for the current thread.
  
  Returns:
  
  true if optimization is in progress, false otherwise
- setOptimizationInProgress
  
  public static void setOptimizationInProgress(boolean inProgress)
  
  Set the optimization in progress flag for the current thread.
  
  Parameters:
  
  inProgress - true if optimization is in progress, false otherwise
- getInstance
  
  public static SuperstreamManager getInstance()
  
  Get the singleton instance of the SuperstreamManager.
  
  Returns:
  
  The SuperstreamManager instance
- convertPropertiesToMap
  
  public static Map<String,Object> convertPropertiesToMap(Properties properties)
- optimizeProducer
  
  public boolean optimizeProducer(String bootstrapServers, String clientId, Properties properties)
  
  Optimize the producer properties for a given Kafka cluster.
  
  Parameters:
  
  bootstrapServers - The Kafka bootstrap servers
  
  clientId - The client ID
  
  properties - The producer properties to optimize
  
  Returns:
  
  True if the optimization was successful, false otherwise