Kafka使用报错Subscription to topics, partitions and pattern are mutually exclusive
报错内容
Exception in thread "main" java.lang.IllegalStateException: Subscription to topics, partitions and pattern are mutually exclusiveat org.apache.kafka.clients.consumer.internals.SubscriptionState.setSubscriptionType(SubscriptionState.java:111)at org.apache.kafka.clients.consumer.internals.SubscriptionState.assignFromUser(SubscriptionState.java:164)at org.apache.kafka.clients.consumer.KafkaConsumer.assign(KafkaConsumer.java:1060)at com.wufabao.kafka.demo.MyOffsetManager.main(MyOffsetManager.java:49)
原因
Kafka手动分区分配assign(Collection)不能和自动分区分配subscribe(Collection, ConsumerRebalanceListener)一起使用
解决方案
如果使用自动分区分配，那就不要使用手动分区分配，反之亦然，两者不可同时使用，使用一种方法，就注释掉另一种方法。
如使用手动分区分配，那么注释掉自动分区分配。
// consumer.subscribe(Collections.singleton("tp_demo_01"));
final Set<TopicPartition> assignment1 = consumer.assignment();
for (TopicPartition partition : assignment1) {System.out.println(partition);
}
Kafka使用报错Subscription to topics, partitions and pattern are mutually exclusive相关推荐
- Subscription to topics, partitions and pattern are mutually exclusive java
订阅主题.分区和模式是相互排斥的Subscription to topics, partitions and pattern are mutually exclusive 原因 assign是手动分配 ...
- git使用报错:fatal: Couldn't find remote ref master的解决方法
git使用报错:fatal: Couldn't find remote ref master的解决方法 fatal: Couldn't find remote ref master 翻译过来就是:致命 ...
- 记录webpack使用问题，使用报错“UnhandledPromiseRejectionWarning，file-loader图片过大，无法加载图片，打包html文件报错TypeError
记录webpack使用报错 版本号问题 运行npm run build,报错 "UnhandledPromiseRejectionWarning: TypeError: this.getRe ...
- Assets.car 解压工具 cartool 使用报错 segmentation fault cartool 解决方案
Assets.car 解压工具 cartool 使用报错 segmentation fault cartool 解决方案 参考文章: (1)Assets.car 解压工具 cartool 使用报错 s ...
- “this”不能在常量表达式中使用报错的解决方法
"this"不能在常量表达式中使用报错的解决方法 问题描述与思考 在用C++书写下面一段代码时,编译器报错"'this'不能在常量表达式中使用".在这里,我最开 ...
- CentOS系统yum源使用报错：Error: Cannot retrieve repository metadata
服务器上的yum突然不好使用,使用yum的时候报错如下: [root@bastion-IDC src]# yum list ...... Could not retrieve mirrorlist h ...
- Python安装xlrd和xlwt的步骤以及使用报错的解决方法
Python安装xlrd和xlwt的步骤以及使用报错的解决方法 参考文章: (1)Python安装xlrd和xlwt的步骤以及使用报错的解决方法 (2)https://www.cnblogs.com/ ...
- git使用报错: fatal: Couldn‘t find remote ref master的解决方法
git使用报错: fatal: Couldn't find remote ref master的解决方法 参考文章: (1)git使用报错: fatal: Couldn't find remote r ...
- cnpm使用报错-最佳方案
问题:cnpm使用报错throw err;^Error: Cannot find module 'fs/promises 现象: 解决方案: 查看你的cnpm的版本是不是高于8.2.0 cnpm 8. ...
最新文章
- 【C++】多线程与异步编程【四】
- 如何使用基于组件的设计方法
- python正则匹配ip地址_Python正则表达式匹配ip地址实例
- Android-一张图理解MVP的用法
- centos mysql 升级 5.7_CentOS 7下升级MySQL5.7.23的一个坑
- 使用shadow dom封装web组件
- SpringCloud的Hystrix(五) Hystrix机制
- 【空间分析-文章学习笔记】2 北京各行业的空间分布分析
- linux通过数字权限设置密码,linux--权限管理和用户管理
- html页面整体换算单位,通过媒体查询meta和JS转换REM单位实现100%自适应
- Redis笔记（五）Redis的事务
- JAVA实现PDF合并、拆分代码工具类
- 求解Ax=b的克莱默法则
- C语言并集编程,c语言求并集和交集的关键代码，谢谢
- 港科百创|【未磁科技】勇夺百万大奖,2021年度总决赛圆满收官!香港科大-越秀集团百万奖金国际创业大赛年度总决赛成功举办!...
- 【视觉高级篇】23 # 如何模拟光照让3D场景更逼真？（上）
- 如何绘制业务架构图 — 4.流程图
- 分布式内存数据技术为查询提速
- 汇编语言实现七段数码管显示控制实验
- FTP 文件传输协议