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