From 672a218fe76c7d1f77b3d3d87c8c810b370c38a1 Mon Sep 17 00:00:00 2001 From: Long Nguyen Date: Tue, 19 Sep 2023 05:26:12 +0000 Subject: [PATCH] FE: Add topic params to support MSK Tiered Storage --- .../kafka/ui/pages/topics/enums/CustomParameterType.java | 5 ++++- kafka-ui-react-app/src/lib/constants.ts | 3 +++ 2 files changed, 7 insertions(+), 1 deletion(-) diff --git a/kafka-ui-e2e-checks/src/main/java/com/provectus/kafka/ui/pages/topics/enums/CustomParameterType.java b/kafka-ui-e2e-checks/src/main/java/com/provectus/kafka/ui/pages/topics/enums/CustomParameterType.java index 4ed3e899666..e6555d37c06 100644 --- a/kafka-ui-e2e-checks/src/main/java/com/provectus/kafka/ui/pages/topics/enums/CustomParameterType.java +++ b/kafka-ui-e2e-checks/src/main/java/com/provectus/kafka/ui/pages/topics/enums/CustomParameterType.java @@ -23,7 +23,10 @@ public enum CustomParameterType { SEGMENT_INDEX_BYTES("segment.index.bytes"), SEGMENT_JITTER_MS("segment.jitter.ms"), SEGMENT_MS("segment.ms"), - UNCLEAN_LEADER_ELECTION_ENABLE("unclean.leader.election.enable"); + UNCLEAN_LEADER_ELECTION_ENABLE("unclean.leader.election.enable"), + REMOTE_STORAGE_ENABLE("remote.storage.enable"), + LOCAL_RETENTION_MS("local.retention.ms"), + LOCAL_RETENTION_BYTES("local.retention.bytes"); private final String optionValue; diff --git a/kafka-ui-react-app/src/lib/constants.ts b/kafka-ui-react-app/src/lib/constants.ts index a3e622550b8..6681cfb77de 100644 --- a/kafka-ui-react-app/src/lib/constants.ts +++ b/kafka-ui-react-app/src/lib/constants.ts @@ -42,6 +42,9 @@ export const TOPIC_CUSTOM_PARAMS: Record = { 'segment.ms': '604800000', 'message.timestamp.difference.max.ms': '9223372036854775807', 'segment.index.bytes': '10485760', + 'remote.storage.enable': 'true', + 'local.retention.ms': '', + 'local.retention.bytes': '', }; export const MILLISECONDS_IN_WEEK = 604_800_000;