diff --git a/application/src/integrationTest/resources/application.yaml b/application/src/integrationTest/resources/application.yaml index c46fea9..a4a404c 100644 --- 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 index a5aafa7..04777ce 100644 --- 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) { 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 index fe2d3e7..b087b02 100644 --- 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) { logger.debug { "Received response: ${record.key()}, ${record.value()}" } diff --git a/application/src/main/resources/application.yaml b/application/src/main/resources/application.yaml index ba729f1..1b0dd64 100644 --- 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 \ No newline at end of file + concurrency: 1