test

Author: varkey98

kafka-streams-framework/src/main/java/org/hypertrace/core/kafkastreams/framework/interceptors/metrics/MetricsInterceptor.java

@@ -16,6 +16,7 @@ public class MetricsInterceptor implements Processor {
 
   @Override
   public void process(Record record) {
+    System.out.println("Inside custom processor");
     timeLagCounter.increment(System.currentTimeMillis() - record.timestamp());
     numRecordsCounter.increment();
   }