java无法使用kafka管理客户端API创建具有所需分区的kafka主题
我正在使用Kafka管理客户端API创建主题。正在创建主题,但是默认情况下,主题是使用1个分区创建的。API不遵守提供的可配置值。不确定我是否正确使用了它
注意:主题创建是在代理级别启用的。主题也正在创建中,但它是使用分区1创建的
NewTopic newTopic = new NewTopic(TOPIC_NAME, 10, (short) 1);
CreateTopicsResult createTopicsResult = null;
try {
createTopicsResult = KafkaAdminClient.create(getAdminProperties()).createTopics(Collections.singletonList(newTopic));
} catch (ClassNotFoundException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
但是,我能够使用Kafka管理客户端API增加先前创建的主题的分区
# 1 楼答案
我试图用以下代码重现这一点,但没有成功:
A
kafka-topics describe
显示如下:我想,好吧,如果这个话题可能在创作之前就存在,那该怎么办,但我又得到了一个
java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.TopicExistsException: Topic 'demoTopic' already exists.
,所以这也不可能是你的情况我知道这不是“真正的”答案,它解决了任何问题,对此我很抱歉。但我希望它能有所帮助。也许其他人可以用它在他的环境中重现,并“看到”问题