diff options
| author |   Oleg Mitsura <oleg.mitsura@bell.ca> | 2022-06-01 10:00:56 -0400 |
|---|---|---|
| committer |   kuldipr <kuldip.rai@amdocs.com> | 2022-08-04 10:33:11 -0400 |
| commit | 105975d04d313a70f94d7656936a4a256a88e687 (patch) | |
| tree | 4b5f416501e9caa544a40efabbfd34487ed45b59 /ms/blueprintsprocessor/modules/commons/message-lib/src/main | |
| parent | fa536ca8bd901dc51833cfe906f7b22846674d2f (diff) | |
Kafka producer parameters updated to be consistent with frankfurt
Issue-ID: CCSDK-3737
Signed-off-by: kuldipr <kuldip.rai@amdocs.com>
Change-Id: I00cba2f644abf85778abf17ee3fb9e102ac5f42f
Diffstat (limited to 'ms/blueprintsprocessor/modules/commons/message-lib/src/main')
| -rw-r--r-- | ms/blueprintsprocessor/modules/commons/message-lib/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/message/BluePrintMessageLibData.kt | 4 |
1 files changed, 2 insertions, 2 deletions
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<String, Any> { |