Skip to content

Commit

Permalink
add support for kafka3.7.x, because kafka3.7 changed the pull message…
Browse files Browse the repository at this point in the history 
… method's name from pollForFetches to poll
  • Loading branch information
@darkness-2nd
darkness-2nd committed Jul 23, 2024
1 parent 1e2b82a commit d875bd3
Showing 1 changed file with 4 additions and 12 deletions.
16 changes: 4 additions & 12 deletions ...ugin/src/main/java/org/apache/skywalking/apm/plugin/kafka/Kafka37ConsumerInterceptor.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -21,19 +21,11 @@
import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.apache.kafka.clients.consumer.ConsumerRecords;
import org.apache.kafka.common.TopicPartition;
import org.apache.kafka.common.header.Header;
import org.apache.skywalking.apm.agent.core.context.CarrierItem;
import org.apache.skywalking.apm.agent.core.context.ContextCarrier;
import org.apache.skywalking.apm.agent.core.context.ContextManager;
import org.apache.skywalking.apm.agent.core.context.tag.Tags;
import org.apache.skywalking.apm.agent.core.context.trace.AbstractSpan;
import org.apache.skywalking.apm.agent.core.context.trace.SpanLayer;
import org.apache.skywalking.apm.agent.core.plugin.interceptor.enhance.EnhancedInstance;
import org.apache.skywalking.apm.network.trace.component.ComponentsDefine;

import java.lang.reflect.Method;
import java.nio.charset.StandardCharsets;
import java.util.*;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

/**
* kafak3.7 removed the method named pollForFetches with return type Fetch.
Expand Down

0 comments on commit d875bd3

Please sign in to comment.