Package ai.superstream.agent

Class KafkaProducerInterceptor

java.lang.Object

ai.superstream.agent.KafkaProducerInterceptor

public class KafkaProducerInterceptor
extends Object

Intercepts KafkaProducer constructor calls to optimize configurations.

Field Summary

Fields

Modifier and Type	Field	Description
static final SuperstreamLogger	logger

Constructor Summary

Constructors

Constructor	Description
KafkaProducerInterceptor()

Method Summary

Modifier and Type	Method	Description
static Properties	extractProperties(Object[] args)	Extract Properties object from constructor arguments.
static boolean	isInitialProducerCreation()	Determines if this constructor call is the initial creation from application code rather than an internal delegation between constructors.
static void	onEnter(Object[] args)	Called before the KafkaProducer constructor.

Methods inherited from class java.lang.Object

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

Field Details

logger

public static final SuperstreamLogger logger

Constructor Details

KafkaProducerInterceptor

public KafkaProducerInterceptor()

Method Details

onEnter

@OnMethodEnter
public static void onEnter(@AllArguments
 Object[] args)

Called before the KafkaProducer constructor.

Parameters:

args - The producer properties

extractProperties

public static Properties extractProperties(Object[] args)

Extract Properties object from constructor arguments.

isInitialProducerCreation

public static boolean isInitialProducerCreation()

Determines if this constructor call is the initial creation from application code rather than an internal delegation between constructors.