From 105975d04d313a70f94d7656936a4a256a88e687 Mon Sep 17 00:00:00 2001 From: Oleg Mitsura Date: Wed, 1 Jun 2022 10:00:56 -0400 Subject: Kafka producer parameters updated to be consistent with frankfurt Issue-ID: CCSDK-3737 Signed-off-by: kuldipr Change-Id: I00cba2f644abf85778abf17ee3fb9e102ac5f42f --- .../cds/blueprintsprocessor/message/BluePrintMessageLibData.kt | 4 ++-- .../message/service/BlueprintMessageProducerServiceTest.kt | 8 ++++---- 2 files changed, 6 insertions(+), 6 deletions(-) (limited to 'ms') 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 e0e073d49..9316fdf89 100644 --- 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 { 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 bb35b6614..f5f41f136 100644 --- 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() ) -- cgit 1.2.3-korg