【kafka】kafka 2.8 版本的kafka topic 分区扩容、创建topic

作者：繁依Fanyi0 | 2024-05-29 16:43:41

踩

kafka 2.8

在这里插入图片描述

1.概述

今天要升级kafka客户端版本，我们的服务端版本是1.1.0，然后客户端版本要升级到kafka 2.8.2，有点不明白公司为啥死都不升级服务端版本，使劲升级客户端版本。

在上一次就升级过客户端版本：【kafka】kafka 2.3 版本的kafka topic 分区扩容今天升级后发现这里面的代码不能使用了，然后需要升级。

2.createTopic

在创建topic的时候调用了如下代码

/***
     * todo: 162_5Lmd5biI5YWE5ZSv5LiA5Y6f5Yib5paH56ug77yM56aB5q2i6L2s6L29_162  2023/2/17 16:41 162 九师兄
     *  运行的时候报错 UnsupportedVersionException: The broker does not support CREATE_PARTITIONS     
     */
    public void createKafaTopicEx(1
2
3
4

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/繁依Fanyi0/article/detail/643184