From ed1cc994ea142604b6f5a7741ea5960d218c55c6 Mon Sep 17 00:00:00 2001 From: Sander van der Heijden Date: Thu, 10 Nov 2022 12:26:21 +0100 Subject: [PATCH] FDP-852 ~ Attempts to fix failing cucumber test Signed-off-by: Sander van der Heijden --- .../distributionautomation/ProcessStringMessage.feature | 3 +-- .../osgp-adapter-kafka-distributionautomation.properties | 1 + 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/integration-tests/cucumber-tests-platform-distributionautomation/src/test/resources/features/distributionautomation/ProcessStringMessage.feature b/integration-tests/cucumber-tests-platform-distributionautomation/src/test/resources/features/distributionautomation/ProcessStringMessage.feature index 6736b3549e1..47205098bfd 100644 --- a/integration-tests/cucumber-tests-platform-distributionautomation/src/test/resources/features/distributionautomation/ProcessStringMessage.feature +++ b/integration-tests/cucumber-tests-platform-distributionautomation/src/test/resources/features/distributionautomation/ProcessStringMessage.feature @@ -1,5 +1,4 @@ -# Skipped due to NotLeaderForPartitionException issues with kafka -@Skip @DistributionAutomation @Platform @StringMessage +@DistributionAutomation @Platform @StringMessage Feature: DistributionAutomation String message processing Scenario: Process a String message from MQTT device diff --git a/osgp/platform/osgp-adapter-kafka-distributionautomation/src/main/resources/osgp-adapter-kafka-distributionautomation.properties b/osgp/platform/osgp-adapter-kafka-distributionautomation/src/main/resources/osgp-adapter-kafka-distributionautomation.properties index 47aeb87b5b0..3c5f52d097d 100644 --- a/osgp/platform/osgp-adapter-kafka-distributionautomation/src/main/resources/osgp-adapter-kafka-distributionautomation.properties +++ b/osgp/platform/osgp-adapter-kafka-distributionautomation/src/main/resources/osgp-adapter-kafka-distributionautomation.properties @@ -10,6 +10,7 @@ distributionautomation.kafka.bootstrap.servers=localhost:9092 distributionautomation.kafka.topic.message=distributionautomation_message_from_mqtt_broker distributionautomation.kafka.producer.key.serializer=org.apache.kafka.common.serialization.StringSerializer distributionautomation.kafka.producer.value.serializer=org.apache.kafka.common.serialization.StringSerializer +distributionautomation.kafka.producer.retry.backoff.ms=3000 # Example Kafka SSL configuration for use in acceptance or production environments #distributionautomation.kafka.security.protocol=SSL