Improve naming for instrumentation class.
@@ -17,12 +17,11 @@ import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.apache.kafka.common.record.TimestampType;
// This is necessary because SourceNodeRecordDeserializer drops the headers. :-(
-public class KafkaStreamsSourceNodeRecordDeserializerInstrumentation {
-
@AutoService(Instrumenter.class)
- public static class StartInstrumentation extends Instrumenter.Configurable {
+public class KafkaStreamsSourceNodeRecordDeserializerInstrumentation
+ extends Instrumenter.Configurable {
- public StartInstrumentation() {
+ public KafkaStreamsSourceNodeRecordDeserializerInstrumentation() {
super("kafka", "kafka-streams");
}
@@ -69,4 +68,3 @@ public class KafkaStreamsSourceNodeRecordDeserializerInstrumentation {
}
}
}
-}
