返回到文章

采纳

编辑于

The broker does not support CREATE_PARTITIONS

kafka

AdminClient clientAdminClient = AdminClientClient.create(props);
List<ConfigEntry> entities = new ArrayList<>();
for (String key : topicParament = AdminClientAdminClient client = AdminClient.create(props);
List<ConfigEntry> entities = new ArrayList<>();
for (String key : topicParam.getConfig().keySet()) {
    ConfigEntryt clientlient.createAdminClient client = AdminClient.create(props);
List<ConfigEntry> entities = new ArrayList<>();
for (String key : topicParam.getConfig().keySet()) {
    ConfigEntry entity = new ConfigEntry(key, topicParamclientAdminClient client = AdminClient.create(props);
List<ConfigEntry> entities = new ArrayList<>();
for (String key : topicParam.getConfig().keySet()) {
    ConfigEntry entity = newAdminClient client = AdminClientent.create(props);
List<ConfigEntry> entities = new ArrayList<>();
for (String key : topicParam.getConfig().keySet()) {
    ConfigEntry entity = new ConfigEntry(key, topicParam.getConfig().get(key));
    entities.add(entity);
}
MapAdminClient client = AdminClientnClient.creatent.createe(props);
ListAdminClient client = AdminClient.create(props);
List<ConfigEntry> entities = new ArrayList<>();
for (String key : topicParam.getConfig().keySet()) {
    ConfigEntry entity = new ConfigEntryAdminClient client = AdminClient.create(props);
List<ConfigEntry> entities = new ArrayList<>();
for (String key : topicParam.getConfig().keySet()) {
    ConfigEntry entity = new ConfigEntry(key, topicParam client = AdminClient.create(props);
List<ConfigEntry> entities = new ArrayList<>();
for (String key : topicParam.getConfig().keySet()) {
    ConfigEntry entity = new ConfigEntry(key, topicParam.getConfig().get(key));
    entities.add(entity);
}
Map<ConfigResource, Config> configs = new HashMapAdminClient clientient.createeate(props);
Listist<ConfigEntrytities = newAdminClient client = AdminClient.create(props);
List<ConfigEntry> entities = new ArrayList<>();
for (String key : topicParam.getConfig().keySet()) {
    ConfigEntry entity = new ConfigEntry(key, topicParam.getConfig().get(key));
    entities.add(entityAdminClient clientClient.create<ConfigEntryAdminClient client = AdminClient.create(props);
List<ConfigEntry> entities = new ArrayList<>();
for (String key : topicParam.getConfig().keySet()) {
    ConfigEntry entity = newnt client = AdminClient.create(props);
List<ConfigEntry> entities = new ArrayList<>();
for (String key : topicParam.getConfig().keySet()) {
    ConfigEntry entity = new ConfigEntry(key, topicParam.getConfig().get(key));
    entities.add(entity);
}
Map<ConfigResource, Config> configs = new HashMapent clientClient.createist<ConfigEntryAdminClient client = AdminClient.create(props);
List<ConfigEntry> entities = new ArrayList<>();
for (String key : topicParam.getConfig().keySet()) {
    ConfigEntry entity = new ConfigEntry(key, topicParam.getConfig().get(key));
    entities.add(entity);
}
Map<ConfigResource, Config> configs = new HashMap<>();
configs.put(new ConfigResource(ConfigResource.Type.TOPIC,"topic", newnfig(entitiesentitieslterConfigsResult rsConfigs(configs();

adminclient在增加分区的时候爆出来的 ,请问 我调脚本就可以操作这是什么情况