Skip to content

Commit a3668e9

Browse files
committed
[#12452] Changed kafka_streams serviceType desc
1 parent 7a3f3b2 commit a3668e9

File tree

3 files changed

+1
-1
lines changed

3 files changed

+1
-1
lines changed

agent-module/plugins/kafka/src/main/java/com/navercorp/pinpoint/plugin/kafka/KafkaConstants.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -33,7 +33,7 @@ public class KafkaConstants {
3333
public static final String SCOPE = "KAFKA_SCOPE";
3434

3535
public static final ServiceType KAFKA_CLIENT = ServiceTypeFactory.of(8660, "KAFKA_CLIENT", "KAFKA_CLIENT", QUEUE, RECORD_STATISTICS);
36-
public static final ServiceType KAFKA_STREAMS = ServiceTypeFactory.of(8662, "KAFKA_STREAMS", "KAFKA_CLIENT", QUEUE, RECORD_STATISTICS);
36+
public static final ServiceType KAFKA_STREAMS = ServiceTypeFactory.of(8662, "KAFKA_STREAMS", "KAFKA_STREAMS", QUEUE, RECORD_STATISTICS);
3737
public static final ServiceType KAFKA_CLIENT_INTERNAL = ServiceTypeFactory.of(8661, "KAFKA_CLIENT_INTERNAL", "KAFKA_CLIENT");
3838

3939
public static final AnnotationKey KAFKA_TOPIC_ANNOTATION_KEY = AnnotationKeyFactory.of(140, "kafka.topic", VIEW_IN_RECORD_SET);
1.74 KB
Loading
8.32 KB
Loading

0 commit comments

Comments
 (0)