Subscription to topics, partitions and pattern are mutually exclusive java
订阅主题、分区和模式是相互排斥的Subscription to topics, partitions and pattern are mutually exclusive
原因
assign是手动分配分区
而subscribe是自动分配分区
两者API调用不能同时使用
Kafka手动分区分配assign(Collection)不能和自动分区分配subscribe(Collection, ConsumerRebalanceListener)一起使用
解决方案
两者使用一者即可
if (StringUtils.isNotBlank(partition)) {TopicPartition partition0 = new TopicPartition(topic, Integer.valueOf(partition));consumer.assign(Arrays.asList(partition0));} else {consumer.subscribe(Arrays.asList(topic));}
Subscription to topics, partitions and pattern are mutually exclusive java相关推荐
- Kafka使用报错Subscription to topics, partitions and pattern are mutually exclusive
报错内容 Exception in thread "main" java.lang.IllegalStateException: Subscription to topics, p ...
- 如何为一个kafka集群选择topics/partitions的数量
2019独角兽企业重金招聘Python工程师标准>>> How to choose the number oftopics/partitions in a Kafka cluster ...
- [Pytorch] ValueError: sampler option is mutually exclusive with shuffle
踩坑记录: pytoroch利用DDP(DistributedDataParallel)进行单机多卡的训练时, 提示: ValueError: sampler option is mutually e ...
- Pytorch使用DistributedDataParallel单机多卡训练时遇到ValueError: sampler option is mutually exclusive with shuff
Pytorch使用DistributedDataParallel单机多卡训练时遇到 ValueError: sampler option is mutually exclusive with shuf ...
- Pattern And Matcher（java）
Pattern And Matcher(java) 1.什么是Pattern pattern为正则表达式的编译表示形式,指定为字符串的正则表达式必须首先被编译为此类的实例.构造Pattern的方法是私 ...
- MECE分析法(Mutually Exclusive Collectively Exhaustive)
什么是MECE分析法? MECE,是Mutually Exclusive Collectively Exhaustive,中文意思是"相互独立,完全穷尽". 也就是对于一个重大的议 ...
- lstm 文本分类_带有lstm和单词嵌入的灾难推文上的文本分类
lstm 文本分类 This was my first Kaggle notebook and I thought why not write it on Medium too? Ť他是我第一次Kag ...
- kafka踩坑、实践篇
kafka踩坑.实践篇 1.从kafka读取数据后 数据会自动删除吗 不会,kafka中数据的删除跟有没有消费者消费完全无关. 数据的删除,只跟kafka broker上面上面的这两个配置有关: # ...
- Kafka的assign和subscribe订阅模式
一.前言: 使用Apache Kafka消费者组时,有一个为消费者分配对应分区partition的过程,我们可以使用"自动"subscribe和"手动"assi ...
最新文章
- 8个无敌好用国产APP推荐：（办公类、学习类、生活类）
- HDU-4277USACO ORZ深搜+set去重
- linux基础分支,Linux基础--/etc/shadow中字段的分支和操作
- JDK/Java 17 可能带来什么新特性？
- 【视频教程】捷微开发视频系统讲课-陆续更新
- I.MX6 隐藏电池图标
- 机器学习算法实践：决策树 (Decision Tree)（转载）
- 包邮送72本R语言和Python的书籍
- SanDisk U盘加密软件 在其他u盘使用
- 纳米盘资源搜索经验分享
- 78行Python代码教你找回微信撤回的消息
- 双十一|又快又稳！闲鱼实时事件规则计算驱动平台
- 【杂谈】万字长文回顾深度学习的崛起背景，近10年在各行各业中的典型应用
- 常见问题 | Influx 产品常见问题及使用技巧（1）
- 在苏州软件园培训的那俩月，我找到了生的希望
- 从贝壳到电子货币:人类未来的支付会怎样？
- 洛谷 p1010 幂次方
- mysql端口号543_系统里的那些端口在哪里？
- 分享给大家一些UG模具设计常识，值得收藏
- android 列表 风格,安卓列表的item样式