Skip to content

Commit f8e8ebc

Browse files
remove debug logs
1 parent c30c2b7 commit f8e8ebc

File tree

1 file changed

+0
-4
lines changed

1 file changed

+0
-4
lines changed

superstream-clients/src/main/java/ai/superstream/agent/KafkaProducerInterceptor.java

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -98,7 +98,6 @@ public static void onEnter(@Advice.AllArguments Object[] args) {
9898
// Check if this is a direct call from application code or an internal
9999
// delegation
100100
if (!isInitialProducerCreation()) {
101-
logger.debug("Skipping internal constructor delegation");
102101
return;
103102
}
104103

@@ -146,7 +145,6 @@ public static void onEnter(@Advice.AllArguments Object[] args) {
146145
try {
147146
// Skip if we're already in the process of optimizing
148147
if (SuperstreamManager.isOptimizationInProgress()) {
149-
logger.debug("Skipping interception as optimization is already in progress");
150148
return;
151149
}
152150

@@ -227,7 +225,6 @@ public static void onExit(@Advice.This Object producer) {
227225
try {
228226
// Process only for the outer-most constructor call
229227
if (!isInitialProducerCreation()) {
230-
logger.debug("Skipping internal constructor delegation");
231228
return;
232229
}
233230

@@ -264,7 +261,6 @@ public static void onExit(@Advice.This Object producer) {
264261

265262
// Skip internal library producers (identified by client.id prefix)
266263
if (rawClientId != null && rawClientId.startsWith(SUPERSTREAM_LIBRARY_PREFIX)) {
267-
logger.debug("Skipping Superstream internal producer: {}", rawClientId);
268264
return;
269265
}
270266

0 commit comments

Comments
 (0)