FDP-94: Make Kafka group id configurable

Signed-off-by: Jasper Kamerling <[email protected]>
OSGP · Nov 22, 2023 · 5654742 · 5654742
1 parent 17efe22
commit 5654742
Show file tree

Hide file tree

Showing 4 changed files with 12 additions and 3 deletions.
diff --git a/application/src/integrationTest/resources/application.yaml b/application/src/integrationTest/resources/application.yaml
@@ -1,6 +1,8 @@
 spring:
   kafka:
     bootstrap-servers: ${spring.embedded.kafka.brokers}
+    consumer:
+      group-id: gxf-soap-bridge
 server:
   ssl:
     enabled: true

diff --git a/application/src/main/kotlin/org/gxf/soapbridge/kafka/listeners/ProxyRequestKafkaListener.kt b/application/src/main/kotlin/org/gxf/soapbridge/kafka/listeners/ProxyRequestKafkaListener.kt
@@ -18,7 +18,8 @@ class ProxyRequestKafkaListener(private val platformCommunicationService: Platfo
     @KafkaListener(
         id = "gxf-request-consumer",
         topics = ["\${kafka.incoming.requests.topic}"],
-        concurrency = "\${kafka.incoming.requests.concurrency}"
+        concurrency = "\${kafka.incoming.requests.concurrency}",
+        idIsGroup = false
     )
     fun consume(record: ConsumerRecord<String, String>) {
         logger.debug { "Received request: ${record.key()}, ${record.value()}" }

diff --git a/application/src/main/kotlin/org/gxf/soapbridge/kafka/listeners/ProxyResponseKafkaListener.kt b/application/src/main/kotlin/org/gxf/soapbridge/kafka/listeners/ProxyResponseKafkaListener.kt
@@ -18,7 +18,8 @@ class ProxyResponseKafkaListener(private val clientCommunicationService: ClientC
     @KafkaListener(
         id = "gxf-response-consumer",
         topics = ["\${kafka.incoming.responses.topic}"],
-        concurrency = "\${kafka.incoming.responses.concurrency}"
+        concurrency = "\${kafka.incoming.responses.concurrency}",
+        idIsGroup = false
     )
     fun consume(record: ConsumerRecord<String, String>) {
         logger.debug { "Received response: ${record.key()}, ${record.value()}" }

diff --git a/application/src/main/resources/application.yaml b/application/src/main/resources/application.yaml
@@ -4,6 +4,11 @@ management:
       exposure:
         include: prometheus
 
+spring:
+  kafka:
+    consumer:
+      group-id: gxf-soap-bridge
+
 soap:
   hostname-verification-strategy: BROWSER_COMPATIBLE_HOSTNAMES
 
@@ -12,4 +17,4 @@ kafka:
     requests:
       concurrency: 1
     responses:
-      concurrency: 1
+      concurrency: 1