Topic edit feature (#1)

* Added topic edit feature and other minor enhancements.

* Updated the Spring Boot to version 3.0.2

* Updated the package and few minor updates

* Minor refactor.

Author: nicholasnet

backend/main/java/com/ideasbucket/tansen/configuration/ApplicationProperties.java

@@ -7,20 +7,18 @@
 package com.ideasbucket.tansen.configuration;
 
 import com.ideasbucket.tansen.entity.Cluster;
+import jakarta.validation.Valid;
+import jakarta.validation.constraints.AssertTrue;
+import jakarta.validation.constraints.NotEmpty;
+import jakarta.validation.constraints.NotNull;
 import java.util.Map;
 import java.util.Set;
 import java.util.function.Function;
 import java.util.stream.Collectors;
-import javax.validation.Valid;
-import javax.validation.constraints.AssertTrue;
-import javax.validation.constraints.NotEmpty;
-import javax.validation.constraints.NotNull;
 import org.springframework.boot.context.properties.ConfigurationProperties;
-import org.springframework.boot.context.properties.ConstructorBinding;
 import org.springframework.validation.annotation.Validated;
 
 @ConfigurationProperties("tansen")
-@ConstructorBinding
 @Validated
 public class ApplicationProperties {
 

backend/main/java/com/ideasbucket/tansen/entity/Cluster.java

@@ -6,11 +6,11 @@
  */
 package com.ideasbucket.tansen.entity;
 
+import jakarta.validation.constraints.NotBlank;
+import jakarta.validation.constraints.NotNull;
+import jakarta.validation.constraints.Pattern;
+import jakarta.validation.constraints.Size;
 import java.util.Map;
-import javax.validation.constraints.NotBlank;
-import javax.validation.constraints.NotNull;
-import javax.validation.constraints.Pattern;
-import javax.validation.constraints.Size;
 
 public class Cluster {
 

backend/main/java/com/ideasbucket/tansen/entity/ClusterInformation.java

@@ -47,6 +47,9 @@ public final class ClusterInformation {
     @JsonProperty("outOfSyncReplicas")
     private final Integer outOfSyncReplicas;
 
+    @JsonProperty("clusterSize")
+    private final Long clusterSize;
+
     @JsonCreator
     public ClusterInformation(
         @JsonProperty("id") String id,
@@ -59,7 +62,8 @@ public ClusterInformation(
         @JsonProperty("totalNumberOfPartitions") Integer totalNumberOfPartitions,
         @JsonProperty("totalReplicas") Integer totalReplicas,
         @JsonProperty("inSyncReplicas") Integer inSyncReplicas,
-        @JsonProperty("outOfSyncReplicas") Integer outOfSyncReplicas
+        @JsonProperty("outOfSyncReplicas") Integer outOfSyncReplicas,
+        @JsonProperty("clusterSize") Long clusterSize
     ) {
         this.id = id;
         this.name = name;
@@ -72,6 +76,7 @@ public ClusterInformation(
         this.inSyncReplicas = inSyncReplicas;
         this.outOfSyncReplicas = outOfSyncReplicas;
         this.configurations = configurations;
+        this.clusterSize = clusterSize;
     }
 
     public ClusterInformation(
@@ -84,7 +89,8 @@ public ClusterInformation(
         @JsonProperty("totalNumberOfTopics") Integer totalNumberOfTopics,
         @JsonProperty("totalNumberOfPartitions") Integer totalNumberOfPartitions,
         @JsonProperty("totalReplicas") Integer totalReplicas,
-        @JsonProperty("inSyncReplicas") Integer inSyncReplicas
+        @JsonProperty("inSyncReplicas") Integer inSyncReplicas,
+        @JsonProperty("clusterSize") Long clusterSize
     ) {
         this.id = id;
         this.name = name;
@@ -97,6 +103,7 @@ public ClusterInformation(
         this.inSyncReplicas = inSyncReplicas;
         this.outOfSyncReplicas = totalReplicas - inSyncReplicas;
         this.configurations = configurations;
+        this.clusterSize = clusterSize;
     }
 
     public String getName() {
@@ -142,4 +149,8 @@ public Integer getOutOfSyncReplicas() {
     public List<ConfigurationWithDefinition> getConfigurations() {
         return configurations;
     }
+
+    public Long getClusterSize() {
+        return clusterSize;
+    }
 }

backend/main/java/com/ideasbucket/tansen/entity/CompatibilityChangeRequest.java

@@ -10,9 +10,9 @@
 import com.fasterxml.jackson.annotation.JsonInclude;
 import com.fasterxml.jackson.annotation.JsonProperty;
 import com.fasterxml.jackson.annotation.JsonPropertyOrder;
-import javax.validation.constraints.NotBlank;
-import javax.validation.constraints.NotNull;
-import javax.validation.constraints.Pattern;
+import jakarta.validation.constraints.NotBlank;
+import jakarta.validation.constraints.NotNull;
+import jakarta.validation.constraints.Pattern;
 
 @JsonInclude(JsonInclude.Include.NON_NULL)
 @JsonPropertyOrder({ "compatibility" })

backend/main/java/com/ideasbucket/tansen/entity/MessageSelectionCriteria.java

@@ -7,8 +7,9 @@
 package com.ideasbucket.tansen.entity;
 
 import com.fasterxml.jackson.annotation.*;
+import jakarta.validation.constraints.AssertFalse;
+
 import java.time.Instant;
-import javax.validation.constraints.AssertFalse;
 
 @JsonInclude(JsonInclude.Include.NON_NULL)
 @JsonPropertyOrder({ "offset", "partition", "timestamp" })
@@ -55,19 +56,16 @@ private boolean hasValidOffset() {
     @AssertFalse(message = "Invalid partition.")
     @JsonIgnore
     private boolean hasValidPartition() {
-        return this.partition != null && this.partition < 0;
+        return this.partition != null && this.partition < -1;
     }
 
     @JsonIgnore
     public String getCase() {
-        if ((this.partition != null) && (this.offset != null)) {
-            return "offset";
-        }
 
-        if (this.timestamp != null) {
-            return "timestamp";
+        if (this.partition == null) {
+            return "";
         }
 
-        return "";
+        return (this.offset != null) ? "offset" : "timestamp";
     }
 }

backend/main/java/com/ideasbucket/tansen/entity/ModeChangeRequest.java

@@ -7,7 +7,7 @@
 package com.ideasbucket.tansen.entity;
 
 import com.fasterxml.jackson.annotation.*;
-import javax.validation.constraints.AssertTrue;
+import jakarta.validation.constraints.AssertTrue;
 
 @JsonInclude(JsonInclude.Include.NON_NULL)
 @JsonPropertyOrder({ "mode" })

backend/main/java/com/ideasbucket/tansen/entity/Reference.java

@@ -10,8 +10,8 @@
 import com.fasterxml.jackson.annotation.JsonInclude;
 import com.fasterxml.jackson.annotation.JsonProperty;
 import com.fasterxml.jackson.annotation.JsonPropertyOrder;
-import javax.validation.constraints.NotBlank;
-import javax.validation.constraints.NotNull;
+import jakarta.validation.constraints.NotBlank;
+import jakarta.validation.constraints.NotNull;
 
 @JsonInclude(JsonInclude.Include.NON_NULL)
 @JsonPropertyOrder({ "name", "subject", "version" })

backend/main/java/com/ideasbucket/tansen/entity/SaveSchemaRequest.java

@@ -7,12 +7,12 @@
 package com.ideasbucket.tansen.entity;
 
 import com.fasterxml.jackson.annotation.*;
+import jakarta.validation.Valid;
+import jakarta.validation.constraints.AssertTrue;
+import jakarta.validation.constraints.NotBlank;
+import jakarta.validation.constraints.NotNull;
 import java.util.Collections;
 import java.util.List;
-import javax.validation.Valid;
-import javax.validation.constraints.AssertTrue;
-import javax.validation.constraints.NotBlank;
-import javax.validation.constraints.NotNull;
 
 @JsonInclude(JsonInclude.Include.NON_NULL)
 @JsonPropertyOrder({ "schema", "schemaType", "references" })

backend/main/java/com/ideasbucket/tansen/entity/NewTopicCreateRequest.java renamed to backend/main/java/com/ideasbucket/tansen/entity/TopicCreateRequest.java

@@ -10,9 +10,9 @@
 import com.fasterxml.jackson.databind.annotation.JsonDeserialize;
 import com.fasterxml.jackson.databind.annotation.JsonSerialize;
 import com.fasterxml.jackson.databind.ser.std.ToStringSerializer;
+import jakarta.validation.constraints.*;
 import java.util.HashMap;
 import java.util.Map;
-import javax.validation.constraints.*;
 import org.apache.kafka.common.config.TopicConfig;
 
 @JsonInclude(JsonInclude.Include.NON_NULL)
@@ -49,7 +49,7 @@
         "preallocate",
     }
 )
-public final class NewTopicCreateRequest {
+public final class TopicCreateRequest {
 
     @JsonProperty("cleanup.policy")
     @NotNull(message = "cleanup.policy must be either delete or compact.")
@@ -214,7 +214,7 @@ public final class NewTopicCreateRequest {
     private final Boolean preallocate;
 
     @JsonCreator
-    public NewTopicCreateRequest(
+    public TopicCreateRequest(
         @JsonProperty("cleanup.policy") String cleanupPolicy,
         @JsonProperty("compression.type") String compressionType,
         @JsonProperty("delete.retention.ms") Long deleteRetentionMs,
@@ -274,6 +274,37 @@ public NewTopicCreateRequest(
         this.preallocate = preallocate;
     }
 
+    public TopicCreateRequest(String name, Integer partition) {
+        this.name = name;
+        this.partition = partition;
+        this.cleanupPolicy = "delete";
+        this.compressionType = "producer";
+        this.deleteRetentionMs = 86400000L;
+        this.fileDeleteDelayMs = 60000L;
+        this.flushMessages = 9223372036854775807L;
+        this.flushMs = 9223372036854775807L;
+        this.followerReplicationThrottledReplicas = "";
+        this.indexIntervalBytes = 4096;
+        this.leaderReplicationThrottledReplicas = "";
+        this.maxCompactionLagMs = 9223372036854775807L;
+        this.maxMessageBytes = 1048588;
+        this.messageDownconversionEnable = true;
+        this.messageTimestampDifferenceMaxMs = 9223372036854775807L;
+        this.messageTimestampType = "CreateTime";
+        this.minCleanableDirtyRatio = 0.5;
+        this.minCompactionLagMs = 0L;
+        this.minInsyncReplicas = 1;
+        this.replicationFactor = 1;
+        this.retentionBytes = -1L;
+        this.retentionMs = 604800000L;
+        this.segmentBytes = 1073741824;
+        this.segmentIndexBytes = 10485760;
+        this.segmentJitterMs = 0L;
+        this.segmentMs = 604800000L;
+        this.uncleanLeaderElectionEnable = false;
+        this.preallocate = false;
+    }
+
     @AssertTrue(message = "Retention bytes cannot be null, must be numeric either exactly -1 or greater than 0.")
     @JsonIgnore
     private boolean hasValidRetentionBytes() {
@@ -284,6 +315,13 @@ private boolean hasValidRetentionBytes() {
         return this.retentionBytes == -1L || this.retentionBytes > 0L;
     }
 
+    @AssertFalse(message = "Minimum in-sync replica must be equal or less than replication factor.")
+    @JsonIgnore
+    private boolean hasMinInsyncReplicas() {
+
+        return (this.replicationFactor < this.minInsyncReplicas);
+    }
+
     @AssertTrue(message = "Retention time cannot be null, must be numeric either exactly -1 or greater than 0.")
     @JsonIgnore
     private boolean hasValidRetentionMs() {