spring 集成Kafka的时候 topic 分区问题

Jeremy0215 发布于 2018/02/12 09:36
阅读 1K+
收藏 2

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

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

加载中
0
一只小桃子
一只小桃子

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

一只小桃子
一只小桃子
回复 @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
Jeremy0215
Jeremy0215
的确是这样的,我现在自己实现了一个启动的时候根据我配置文件使用客户端Kafka创建的方法。只能先这样了,谢谢解答。
0
Ryan-瑞恩
Ryan-瑞恩

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

 

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

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