2
回答
spring 集成Kafka的时候 topic 分区问题
【寻找人气王】邀新用户免费体验华为云服务,百元话费等你拿!   

求教,spring集成使用kafka的时候.

topic的创建和创建分区只能在命令行下进行吗。我可以在spring 的kafka - producer配置中创建指定topic的分区数吗。

<无标签>
举报
Jeremy0215
发帖于6个月前 2回/577阅

可以自动创建,也可以在代码里创建。我都是自动的,没有这个topic,你发一个就有了,但是这个topic是按kafka上的配置文件默认的设置来的,比如partition数

--- 共有 2 条评论 ---
一只小桃子 回复 @Jeremy0215 : 如果你想用代码创建,也是有一个类可以用的The 0.11.0.0 client library provides an AdminClient which can be used to create topics. The KafkaAdmin uses this client to automatically add topics defined as 6个月前 回复
Jeremy0215的确是这样的,我现在自己实现了一个启动的时候根据我配置文件使用客户端Kafka创建的方法。只能先这样了,谢谢解答。 6个月前 回复

需要你给 kafka server 做 自动创建 topic 的配置启用.

 

默认创建的分区和副本数,均为配置文件中配置,否则是默认!

--- 共有 1 条评论 ---
Jeremy0215试了试,的确是这样的。 为了方便我现在spring 集成kafka以后,我自己实现了一个客户端去根据我的配置文件去创建对应topic分区数。现在只能先这样了。 6个月前 回复
顶部