From cc9b77a82bbbe4dff9a933ff9710c29f74035937 Mon Sep 17 00:00:00 2001 From: Samar Abbas Date: Wed, 29 Jul 2020 07:41:53 -0700 Subject: [PATCH] clean up unused feature flags --- common/service/dynamicconfig/constants.go | 3 --- service/worker/service.go | 2 +- 2 files changed, 1 insertion(+), 4 deletions(-) diff --git a/common/service/dynamicconfig/constants.go b/common/service/dynamicconfig/constants.go index d58f457867d..0a1b958e71e 100644 --- a/common/service/dynamicconfig/constants.go +++ b/common/service/dynamicconfig/constants.go @@ -61,7 +61,6 @@ var keys = map[Key]string{ // system settings EnableGlobalNamespace: "system.enableGlobalNamespace", EnableNDC: "system.enableNDC", - EnableNewKafkaClient: "system.enableNewKafkaClient", EnableVisibilitySampling: "system.enableVisibilitySampling", AdvancedVisibilityWritingMode: "system.advancedVisibilityWritingMode", EnableReadVisibilityFromES: "system.enableReadVisibilityFromES", @@ -314,8 +313,6 @@ const ( EnableGlobalNamespace // EnableNDC is key for enable N data center events replication EnableNDC - // EnableNewKafkaClient is key for using New Kafka client - EnableNewKafkaClient // EnableVisibilitySampling is key for enable visibility sampling EnableVisibilitySampling // AdvancedVisibilityWritingMode is key for how to write to advanced visibility diff --git a/service/worker/service.go b/service/worker/service.go index 21d5dec30b8..1b08c511868 100644 --- a/service/worker/service.go +++ b/service/worker/service.go @@ -153,7 +153,7 @@ func NewConfig(params *resource.BootstrapParams) *Config { ) if advancedVisWritingMode() != common.AdvancedVisibilityWritingModeOff { config.IndexerCfg = &indexer.Config{ - IndexerConcurrency: dc.GetIntProperty(dynamicconfig.WorkerIndexerConcurrency, 1000), + IndexerConcurrency: dc.GetIntProperty(dynamicconfig.WorkerIndexerConcurrency, 100), ESProcessorNumOfWorkers: dc.GetIntProperty(dynamicconfig.WorkerESProcessorNumOfWorkers, 1), ESProcessorBulkActions: dc.GetIntProperty(dynamicconfig.WorkerESProcessorBulkActions, 1000), ESProcessorBulkSize: dc.GetIntProperty(dynamicconfig.WorkerESProcessorBulkSize, 2<<24), // 16MB