Skip to content

Commit a50c699

Browse files
compiling error fix
1 parent b6e48d4 commit a50c699

File tree

1 file changed

+5
-2
lines changed

1 file changed

+5
-2
lines changed

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

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -5,6 +5,7 @@
55
import ai.superstream.model.MetadataMessage;
66
import ai.superstream.util.SuperstreamLogger;
77
import net.bytebuddy.asm.Advice;
8+
import java.util.AbstractMap;
89

910
import java.lang.reflect.Field;
1011
import java.lang.reflect.Method;
@@ -173,7 +174,8 @@ public static void onEnter(@Advice.AllArguments Object[] args) {
173174
// Report the error to the client
174175
try {
175176
// Get metadata message before reporting
176-
MetadataMessage metadataMessage = SuperstreamManager.getInstance().getOrFetchMetadataMessage(bootstrapServers, properties);
177+
AbstractMap.SimpleEntry<MetadataMessage, String> metadataResult = SuperstreamManager.getInstance().getOrFetchMetadataMessage(bootstrapServers, properties);
178+
MetadataMessage metadataMessage = metadataResult.getKey();
177179
SuperstreamManager.getInstance().reportClientInformation(
178180
bootstrapServers,
179181
properties,
@@ -302,7 +304,8 @@ public static void onExit(@Advice.This Object producer) {
302304
if (producerProps != null) {
303305
String bootstrapServersProp = producerProps.getProperty("bootstrap.servers");
304306
if (bootstrapServersProp != null) {
305-
metadataMessage = SuperstreamManager.getInstance().getOrFetchMetadataMessage(bootstrapServersProp, producerProps);
307+
AbstractMap.SimpleEntry<MetadataMessage, String> metadataResult = SuperstreamManager.getInstance().getOrFetchMetadataMessage(bootstrapServersProp, producerProps);
308+
metadataMessage = metadataResult.getKey();
306309
}
307310
String topicsEnv = System.getenv("SUPERSTREAM_TOPICS_LIST");
308311
if (topicsEnv != null && !topicsEnv.trim().isEmpty()) {

0 commit comments

Comments
 (0)