spring boot整合kafka中自定义分区怎么加入到配置中?

CielSwift 发布于 2019/12/08 12:10
阅读 157
收藏 0

我发现KafkaTemplate  和 KafkaProperties 都没有关于设置Partitioner的地方? 也搜不到;

难道只能用Properties.put ()这样原始的方式吗?

加载中
0
f
freezingsky

我是直接使用Stream来操作kafka的, 虽然实际使用上也是基于KafkaTemplate. 但配置是可以完全隔离的

返回顶部
顶部