deprecation

Author: yeikel

api/src/main/java/io/kafbat/ui/service/ReactiveAdminClient.java

@@ -493,13 +493,9 @@ public Mono<Void> createPartitions(Map<String, NewPartitions> newPartitionsMap)
   // NOTE: places whole current topic config with new one. Entries that were present in old config,
   // but missed in new will be set to default
   public Mono<Void> updateTopicConfig(String topicName, Map<String, String> configs) {
-    if (getClusterFeatures().contains(SupportedFeature.INCREMENTAL_ALTER_CONFIGS)) {
       return getTopicsConfigImpl(List.of(topicName), false)
           .map(conf -> conf.getOrDefault(topicName, List.of()))
           .flatMap(currentConfigs -> incrementalAlterConfig(topicName, currentConfigs, configs));
-    } else {
-      return alterConfig(topicName, configs);
-    }
   }
 
   public Mono<List<String>> listConsumerGroupNames() {
@@ -742,16 +738,6 @@ private Mono<Void> incrementalAlterConfig(String topicName,
         )).all());
   }
 
-  @SuppressWarnings("deprecation")
-  private Mono<Void> alterConfig(String topicName, Map<String, String> configs) {
-    List<ConfigEntry> configEntries = configs.entrySet().stream()
-        .flatMap(cfg -> Stream.of(new ConfigEntry(cfg.getKey(), cfg.getValue())))
-        .collect(toList());
-    Config config = new Config(configEntries);
-    var topicResource = new ConfigResource(ConfigResource.Type.TOPIC, topicName);
-    return toMono(client.alterConfigs(Map.of(topicResource, config)).all());
-  }
-
   /**
    * Splits input collection into batches, converts each batch into Mono, sequentially subscribes to them
    * and merges output Monos into one Mono.

api/src/main/java/io/kafbat/ui/service/masking/policies/Replace.java

@@ -53,7 +53,7 @@ private JsonNode replaceWithFieldsCheck(JsonNode node) {
   private JsonNode replaceRecursive(JsonNode node) {
     if (node.isObject()) {
       ObjectNode obj = ((ObjectNode) node).objectNode();
-      node.fields().forEachRemaining(f -> obj.set(f.getKey(), replaceRecursive(f.getValue())));
+      node.properties().forEach(f -> obj.set(f.getKey(), replaceRecursive(f.getValue())));
       return obj;
     } else if (node.isArray()) {
       ArrayNode arr = ((ArrayNode) node).arrayNode(node.size());

api/src/main/java/io/kafbat/ui/util/jsonschema/JsonAvroConversion.java

@@ -17,7 +17,6 @@
 import com.fasterxml.jackson.databind.node.TextNode;
 import com.google.common.collect.Lists;
 import io.confluent.kafka.schemaregistry.avro.AvroSchemaUtils;
-import io.confluent.kafka.serializers.AvroData;
 import io.kafbat.ui.exception.JsonAvroConversionException;
 import java.math.BigDecimal;
 import java.nio.ByteBuffer;

contract/src/main/resources/swagger/kafbat-ui-api.yaml

@@ -3872,6 +3872,7 @@ components:
         - DYNAMIC_CLIENT_METRICS_CONFIG
         - STATIC_BROKER_CONFIG
         - DEFAULT_CONFIG
+        - DYNAMIC_GROUP_CONFIG
         - UNKNOWN
 
     ConfigSynonym: