您好,欢迎访问代理记账网站
移动应用 微信公众号 联系我们

咨询热线 -

电话 15988168888

联系客服
  • 价格透明
  • 信息保密
  • 进度掌控
  • 售后无忧

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 exclusive
	at 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);
}

分享:

低价透明

统一报价,无隐形消费

金牌服务

一对一专属顾问7*24小时金牌服务

信息保密

个人信息安全有保障

售后无忧

服务出问题客服经理全程跟进