Package ai.superstream.core

Class ClientReporter

java.lang.Object

ai.superstream.core.ClientReporter

public class ClientReporter
extends Object

Reports client information to the superstream.clients topic.

Constructor Summary

Constructors

Constructor	Description
ClientReporter()

Method Summary

Modifier and Type	Method	Description
boolean	reportClient(String bootstrapServers, Properties originalClientProperties, int superstreamClusterId, boolean active, String clientId, Map<String,Object> originalConfiguration, Map<String,Object> optimizedConfiguration)	Report client information to the superstream.clients topic.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ClientReporter

public ClientReporter()

Method Details

reportClient

public boolean reportClient(String bootstrapServers,
 Properties originalClientProperties,
 int superstreamClusterId,
 boolean active,
 String clientId,
 Map<String,Object> originalConfiguration,
 Map<String,Object> optimizedConfiguration)

Report client information to the superstream.clients topic.

Parameters:

bootstrapServers - The Kafka bootstrap servers

superstreamClusterId - The superstream cluster ID

active - Whether the superstream optimization is active

clientId - The client ID

originalConfiguration - The original configuration

optimizedConfiguration - The optimized configuration

Returns:

True if the message was sent successfully, false otherwise