Merge pull request #3 from tusharkhatriofficial/dev

Complete ComprehensiveMetricsService code | create MetricsController …

Author: tusharkhatriofficial

src/main/java/com/eventara/analytics/.DS_Store

@@ -1,30 +1,53 @@
-package com.eventara.analytics.kafka;
+package com.eventara.analytics.config;
 import org.apache.kafka.common.serialization.Serdes;
+import org.apache.kafka.streams.StreamsBuilder;
 import org.apache.kafka.streams.StreamsConfig;
+import org.apache.kafka.streams.kstream.KStream;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 import org.springframework.kafka.annotation.EnableKafkaStreams;
 import org.springframework.kafka.annotation.KafkaStreamsDefaultConfiguration;
 import org.springframework.kafka.config.KafkaStreamsConfiguration;
+
 import java.util.HashMap;
 import java.util.Map;
 
 @Configuration
-@EnableKafkaStreams
+//@EnableKafkaStreams
 public class KafkaStreamsConfig {
 
     @Value("${spring.kafka.bootstrap-servers}")
     private String bootstrapServers;
 
     @Bean(name = KafkaStreamsDefaultConfiguration.DEFAULT_STREAMS_CONFIG_BEAN_NAME)
-    public KafkaStreamsConfiguration kStreamsConfig(){
+    public KafkaStreamsConfiguration kStreamsConfig() {
         Map<String, Object> props = new HashMap<>();
-        props.put(StreamsConfig.APPLICATION_ID_CONFIG, "eventara-streams");
+
+        // Basic configuration
+        props.put(StreamsConfig.APPLICATION_ID_CONFIG, "eventara-analytics");
         props.put(StreamsConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapServers);
+
+        // Serialization
         props.put(StreamsConfig.DEFAULT_KEY_SERDE_CLASS_CONFIG, Serdes.String().getClass());
         props.put(StreamsConfig.DEFAULT_VALUE_SERDE_CLASS_CONFIG, Serdes.String().getClass());
 
+        // Performance tuning
+        props.put(StreamsConfig.NUM_STREAM_THREADS_CONFIG, 2);
+        props.put(StreamsConfig.COMMIT_INTERVAL_MS_CONFIG, 1000);
+
         return new KafkaStreamsConfiguration(props);
     }
+
+
+
+//    @Bean
+//    public KStream<String, String> analyticsStream(StreamsBuilder builder) {
+//        KStream<String, String> stream = builder.stream("eventara.events.raw");
+//        stream.peek((key, value) -> System.out.println("Received raw event: " + value));
+////        stream.peek((key, value) -> System.out.println("Received: " + value))
+////                .to("analytics-output");
+//
+//        return stream;
+//    }
 }

…/analytics/kafka/KafkaStreamsConfig.java …analytics/config/KafkaStreamsConfig.javasrc/main/java/com/eventara/analytics/kafka/KafkaStreamsConfig.java renamed to src/main/java/com/eventara/analytics/config/KafkaStreamsConfig.java src/main/java/com/eventara/analytics/kafka/KafkaStreamsConfig.java renamed to src/main/java/com/eventara/analytics/config/KafkaStreamsConfig.java

@@ -0,0 +1,31 @@
+package com.eventara.analytics.controller;
+
+import com.eventara.analytics.service.ComprehensiveMetricsService;
+import com.eventara.common.dto.ComprehensiveMetricsDto;
+import io.swagger.v3.oas.annotations.Operation;
+import io.swagger.v3.oas.annotations.tags.Tag;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.*;
+
+@RestController
+@RequestMapping("/api/v1/metrics")
+@Tag(name = "Analytics", description = "Comprehensive real-time event analytics")
+public class MetricsController {
+
+    @Autowired
+    private ComprehensiveMetricsService metricsService;
+
+    @GetMapping
+    @Operation(summary = "Get comprehensive metrics")
+    public ResponseEntity<ComprehensiveMetricsDto> getMetrics() {
+        return ResponseEntity.ok(metricsService.getComprehensiveMetrics());
+    }
+
+    @PostMapping("/reset")
+    @Operation(summary = "Reset all metrics")
+    public ResponseEntity<String> resetMetrics() {
+        metricsService.resetMetrics();
+        return ResponseEntity.ok("Metrics reset successfully");
+    }
+}