Kafka producer parameters updated to be consistent with frankfurt

Issue-ID: CCSDK-3737
Signed-off-by: kuldipr <kuldip.rai@amdocs.com>
Change-Id: I00cba2f644abf85778abf17ee3fb9e102ac5f42f

diff --git a/ms/blueprintsprocessor/modules/commons/message-lib/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/message/BluePrintMessageLibData.kt b/ms/blueprintsprocessor/modules/commons/message-lib/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/message/BluePrintMessageLibData.kt
index e0e073d..9316fdf 100644 (file)
--- a/ms/blueprintsprocessor/modules/commons/message-lib/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/message/BluePrintMessageLibData.kt
+++ b/ms/blueprintsprocessor/modules/commons/message-lib/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/message/BluePrintMessageLibData.kt
@@ -55,8 +55,8 @@ open class KafkaBasicAuthMessageProducerProperties : MessageProducerProperties()
 
     lateinit var clientId: String
     var acks: String = "all" // strongest producing guarantee
-    var maxBlockMs: Int = 250 // max blocking time in ms to send a message
-    var reconnectBackOffMs: Int = 60 * 60 * 1000 // time in ms before retrying connection (1 hour)
+    var maxBlockMs: Int = 5000 // max blocking time in ms to send a message
+    var reconnectBackOffMs: Int = 5000 // time in ms before retrying connection (5 seconds)
     var enableIdempotence: Boolean = true // ensure we don't push duplicates
 
     override fun getConfig(): HashMap<String, Any> {

diff --git a/ms/blueprintsprocessor/modules/commons/message-lib/src/test/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/message/service/BlueprintMessageProducerServiceTest.kt b/ms/blueprintsprocessor/modules/commons/message-lib/src/test/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/message/service/BlueprintMessageProducerServiceTest.kt
index bb35b66..f5f41f1 100644 (file)
--- a/ms/blueprintsprocessor/modules/commons/message-lib/src/test/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/message/service/BlueprintMessageProducerServiceTest.kt
+++ b/ms/blueprintsprocessor/modules/commons/message-lib/src/test/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/message/service/BlueprintMessageProducerServiceTest.kt
@@ -119,8 +119,8 @@ open class BlueprintMessageProducerServiceTest {
             ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG to StringSerializer::class.java,
             ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG to ByteArraySerializer::class.java,
             ProducerConfig.ACKS_CONFIG to "all",
-            ProducerConfig.MAX_BLOCK_MS_CONFIG to 250,
-            ProducerConfig.RECONNECT_BACKOFF_MS_CONFIG to 60 * 60 * 1000,
+            ProducerConfig.MAX_BLOCK_MS_CONFIG to 5000,
+            ProducerConfig.RECONNECT_BACKOFF_MS_CONFIG to 5000,
             ProducerConfig.ENABLE_IDEMPOTENCE_CONFIG to true,
             CommonClientConfigs.SECURITY_PROTOCOL_CONFIG to SecurityProtocol.SASL_SSL.toString(),
             SslConfigs.SSL_TRUSTSTORE_TYPE_CONFIG to "JKS",
@@ -182,8 +182,8 @@ open class BlueprintMessageProducerServiceTest {
             ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG to StringSerializer::class.java,
             ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG to ByteArraySerializer::class.java,
             ProducerConfig.ACKS_CONFIG to "all",
-            ProducerConfig.MAX_BLOCK_MS_CONFIG to 250,
-            ProducerConfig.RECONNECT_BACKOFF_MS_CONFIG to 60 * 60 * 1000,
+            ProducerConfig.MAX_BLOCK_MS_CONFIG to 5000,
+            ProducerConfig.RECONNECT_BACKOFF_MS_CONFIG to 5000,
             ProducerConfig.ENABLE_IDEMPOTENCE_CONFIG to true,
             CommonClientConfigs.SECURITY_PROTOCOL_CONFIG to SecurityProtocol.SASL_PLAINTEXT.toString()
         )