From dff4fd46a5f7642767ef64e9f803dc69e8a775fd Mon Sep 17 00:00:00 2001
From: Rassyan <yjkhngds@gmail.com>
Date: Thu, 21 Mar 2024 21:50:14 +0800
Subject: [PATCH] Log AffixSetting update when using addAffixMapUpdateConsumer
 (#97072)

---
 docs/changelog/97072.yaml                     |  5 ++++
 .../common/settings/Setting.java              | 24 ++++++++++++++++++-
 2 files changed, 28 insertions(+), 1 deletion(-)
 create mode 100644 docs/changelog/97072.yaml

diff --git a/docs/changelog/97072.yaml b/docs/changelog/97072.yaml
new file mode 100644
index 0000000000000..686b30952b646
--- /dev/null
+++ b/docs/changelog/97072.yaml
@@ -0,0 +1,5 @@
+pr: 97072
+summary: Log when update AffixSetting using addAffixMapUpdateConsumer
+area: Infra/Logging
+type: bug
+issues: []
diff --git a/server/src/main/java/org/elasticsearch/common/settings/Setting.java b/server/src/main/java/org/elasticsearch/common/settings/Setting.java
index aa1c25a3f1952..aaedf0f8d8874 100644
--- a/server/src/main/java/org/elasticsearch/common/settings/Setting.java
+++ b/server/src/main/java/org/elasticsearch/common/settings/Setting.java
@@ -626,6 +626,13 @@ String innerGetRaw(final Settings settings) {
         return defaultValue.apply(settings);
     }
 
+    /**
+     * Returns the raw (string) settings value, which is for logging use
+     */
+    String getLogString(final Settings settings) {
+        return getRaw(settings);
+    }
+
     /** Logs a deprecation warning if the setting is deprecated and used. */
     void checkDeprecation(Settings settings) {
         // They're using the setting, so we need to tell them to stop
@@ -989,6 +996,7 @@ public Map<String, T> getValue(Settings current, Settings previous) {
 
                 @Override
                 public void apply(Map<String, T> value, Settings current, Settings previous) {
+                    Setting.logSettingUpdate(AffixSetting.this, current, previous, logger);
                     consumer.accept(value);
                 }
             };
@@ -1008,6 +1016,20 @@ public String innerGetRaw(final Settings settings) {
             );
         }
 
+        @Override
+        String getLogString(final Settings settings) {
+            Settings filteredAffixSetting = settings.filter(this::match);
+            try {
+                XContentBuilder builder = XContentFactory.jsonBuilder();
+                builder.startObject();
+                filteredAffixSetting.toXContent(builder, new MapParams(Collections.singletonMap("flat_settings", "true")));
+                builder.endObject();
+                return Strings.toString(builder);
+            } catch (IOException e) {
+                throw new RuntimeException(e);
+            }
+        }
+
         @Override
         public Setting<T> getConcreteSetting(String key) {
             if (match(key)) {
@@ -1811,7 +1833,7 @@ static void logSettingUpdate(Setting<?> setting, Settings current, Settings prev
             if (setting.isFiltered()) {
                 logger.info("updating [{}]", setting.key);
             } else {
-                logger.info("updating [{}] from [{}] to [{}]", setting.key, setting.getRaw(previous), setting.getRaw(current));
+                logger.info("updating [{}] from [{}] to [{}]", setting.key, setting.getLogString(previous), setting.getLogString(current));
             }
         }
     }