public class ConfigmapUtil extends Object
Modifier and Type | Field and Description |
---|---|
static String |
CLEANUP_POLICY |
static String |
COMPACT |
static String |
RETENTION_MS |
Constructor and Description |
---|
ConfigmapUtil() |
Modifier and Type | Method and Description |
---|---|
static RestoreTopicListConfig |
buildRestorePartitionConfig(org.apache.kafka.clients.admin.AdminClient adminClient,
long fromTimestamp,
long revertCompactionSinceTimestamp,
Set<String> topics) |
static Map<org.apache.kafka.common.config.ConfigResource,org.apache.kafka.clients.admin.Config> |
describeConfigs(org.apache.kafka.clients.admin.AdminClient adminClient,
Set<String> topics) |
public static final String CLEANUP_POLICY
public static final String RETENTION_MS
public static final String COMPACT
public static Map<org.apache.kafka.common.config.ConfigResource,org.apache.kafka.clients.admin.Config> describeConfigs(org.apache.kafka.clients.admin.AdminClient adminClient, Set<String> topics) throws ExecutionException, InterruptedException
public static RestoreTopicListConfig buildRestorePartitionConfig(org.apache.kafka.clients.admin.AdminClient adminClient, long fromTimestamp, long revertCompactionSinceTimestamp, Set<String> topics) throws ExecutionException, InterruptedException