moved kafka config from threat detection to utils

akto-api-security · Dec 12, 2024 · a6176d3 · a6176d3
1 parent 2b1808b
commit a6176d3
Show file tree

Hide file tree

Showing 8 changed files with 10 additions and 11 deletions.
diff --git a/apps/threat-detection/src/main/java/com/akto/threat/detection/Main.java b/apps/threat-detection/src/main/java/com/akto/threat/detection/Main.java
@@ -1,9 +1,9 @@
 package com.akto.threat.detection;
 
 import com.akto.DaoInit;
-import com.akto.threat.detection.config.kafka.KafkaConfig;
-import com.akto.threat.detection.config.kafka.KafkaConsumerConfig;
-import com.akto.threat.detection.config.kafka.KafkaProducerConfig;
+import com.akto.kafka.KafkaConfig;
+import com.akto.kafka.KafkaConsumerConfig;
+import com.akto.kafka.KafkaProducerConfig;
 import com.akto.threat.detection.constants.KafkaTopic;
 import com.akto.threat.detection.session_factory.SessionFactoryUtils;
 import com.akto.threat.detection.tasks.CleanupTask;

diff --git a/...at-detection/src/main/java/com/akto/threat/detection/tasks/AbstractKafkaConsumerTask.java b/...at-detection/src/main/java/com/akto/threat/detection/tasks/AbstractKafkaConsumerTask.java
@@ -1,7 +1,7 @@
 package com.akto.threat.detection.tasks;
 
+import com.akto.kafka.KafkaConfig;
 import com.akto.runtime.utils.Utils;
-import com.akto.threat.detection.config.kafka.KafkaConfig;
 import org.apache.kafka.clients.consumer.Consumer;
 import org.apache.kafka.clients.consumer.ConsumerRecords;
 import org.apache.kafka.clients.consumer.KafkaConsumer;

diff --git a/apps/threat-detection/src/main/java/com/akto/threat/detection/tasks/FlushSampleDataTask.java b/apps/threat-detection/src/main/java/com/akto/threat/detection/tasks/FlushSampleDataTask.java
@@ -1,9 +1,8 @@
 package com.akto.threat.detection.tasks;
 
 import com.akto.dto.type.URLMethods;
-import com.akto.proto.threat_protection.message.malicious_event.v1.MaliciousEvent;
+import com.akto.kafka.KafkaConfig;
 import com.akto.proto.threat_protection.message.sample_request.v1.SampleMaliciousRequest;
-import com.akto.threat.detection.config.kafka.KafkaConfig;
 import com.akto.threat.detection.db.entity.MaliciousEventEntity;
 import com.akto.threat.detection.dto.MessageEnvelope;
 import com.google.protobuf.InvalidProtocolBufferException;

diff --git a/...detection/src/main/java/com/akto/threat/detection/tasks/MaliciousTrafficDetectorTask.java b/...detection/src/main/java/com/akto/threat/detection/tasks/MaliciousTrafficDetectorTask.java
@@ -1,11 +1,11 @@
 package com.akto.threat.detection.tasks;
 
 import com.akto.dao.context.Context;
+import com.akto.kafka.KafkaConfig;
 import com.akto.proto.threat_protection.message.malicious_event.v1.MaliciousEvent;
 import com.akto.proto.threat_protection.message.sample_request.v1.SampleMaliciousRequest;
 import com.akto.threat.detection.actor.SourceIPActorGenerator;
 import com.akto.threat.detection.cache.RedisBackedCounterCache;
-import com.akto.threat.detection.config.kafka.KafkaConfig;
 import com.akto.threat.detection.constants.KafkaTopic;
 import com.akto.dao.monitoring.FilterYamlTemplateDao;
 import com.akto.data_actor.DataActor;

diff --git a/...tection/src/main/java/com/akto/threat/detection/tasks/SendMaliciousRequestsToBackend.java b/...tection/src/main/java/com/akto/threat/detection/tasks/SendMaliciousRequestsToBackend.java
@@ -1,11 +1,11 @@
 package com.akto.threat.detection.tasks;
 
+import com.akto.kafka.KafkaConfig;
 import com.akto.proto.threat_protection.message.malicious_event.v1.MaliciousEvent;
 import com.akto.proto.threat_protection.message.sample_request.v1.SampleMaliciousRequest;
 import com.akto.proto.threat_protection.service.malicious_alert_service.v1.MaliciousEventServiceGrpc;
 import com.akto.proto.threat_protection.service.malicious_alert_service.v1.RecordMaliciousEventRequest;
 import com.akto.proto.threat_protection.service.malicious_alert_service.v1.RecordMaliciousEventResponse;
-import com.akto.threat.detection.config.kafka.KafkaConfig;
 import com.akto.threat.detection.db.entity.MaliciousEventEntity;
 import com.akto.threat.detection.dto.MessageEnvelope;
 import com.akto.threat.detection.grpc.AuthToken;

diff --git a/...t/detection/config/kafka/KafkaConfig.java → ...main/java/com/akto/kafka/KafkaConfig.java b/...t/detection/config/kafka/KafkaConfig.java → ...main/java/com/akto/kafka/KafkaConfig.java
@@ -1,4 +1,4 @@
-package com.akto.threat.detection.config.kafka;
+package com.akto.kafka;
 
 public class KafkaConfig {
   private final String bootstrapServers;

diff --git a/...ion/config/kafka/KafkaConsumerConfig.java → ...a/com/akto/kafka/KafkaConsumerConfig.java b/...ion/config/kafka/KafkaConsumerConfig.java → ...a/com/akto/kafka/KafkaConsumerConfig.java
@@ -1,4 +1,4 @@
-package com.akto.threat.detection.config.kafka;
+package com.akto.kafka;
 
 public class KafkaConsumerConfig {
   private final int maxPollRecords;

diff --git a/...ion/config/kafka/KafkaProducerConfig.java → ...a/com/akto/kafka/KafkaProducerConfig.java b/...ion/config/kafka/KafkaProducerConfig.java → ...a/com/akto/kafka/KafkaProducerConfig.java
@@ -1,4 +1,4 @@
-package com.akto.threat.detection.config.kafka;
+package com.akto.kafka;
 
 public class KafkaProducerConfig {
   private final int lingerMs;