public class ConfigmapUtil extends Object
Modifier and Type | Field and Description |
---|---|
static String |
CLEANUP_POLICY |
static String |
COMPACT |
static String |
RETENTION_TIME |
Constructor and Description |
---|
ConfigmapUtil() |
Modifier and Type | Method and Description |
---|---|
static RestoreTopicListConfig |
buildRestorePartitionConfig(org.apache.kafka.clients.admin.AdminClient adminClient,
long fromTimestamp) |
static long |
convertStringToTimestamp(String input)
convert input string to a timestamp (long)
|
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_TIME
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) throws ExecutionException, InterruptedException
public static long convertStringToTimestamp(String input) throws ParseException
input
- can either be a timestamp string as "1631222876", or a date string as "2021-09-08 07:06:22"ParseException