消费者的关闭问题

来源：10-1 Kafka集群篇介绍

乃好

2020-04-23

老师您好，消费者的关闭可以通过consumer.close();方法来关闭，但是在消费者一直运行的情况下，怎么从外部再获取到该consumer对象执行其close方法将其关闭呢？或者是用别的什么关闭方法？

写回答

1回答

Allen

2020-04-24

最简单的肯定是提供个接口了，不过这个问题的目标是什么呢

乃好

Allen

老师您好，我现在遇到问题，消费者拿到数据后，向数据库插入数据，如果插入途中发生异常，我希望在catch块中将消费者关闭，可我实验后发现执行了close方法其会将该次拉取到的所有数据都提交，不管遍历到第几条，不管是否手动提交，总是会提交最末尾数据的offset，这样的话发生了异常就没法接着发生异常的地方重新开始消费了。。。

2020-04-24

共4条回复

Kafka多维度系统精讲，从入门到实战开发

系统讲解Kafka，实战结合，让你成为使用Kafka的高手

896 学习 · 237 问题

查看课程

相似问题

一个partition不能被同一个组中的多个cusumer同时消费

回答 3

消费者和消费者组之间的关系，是不是能理解成，topic和partiotion的关系？

回答 1

假如一个消费者组里有3个消费者，那一个分区内的某一条消息，是只能被一个消费者poll到还是所有的消费者都能拉取到但是只有一个能成功提交？

回答 1

拿到消息消费处理的这个线程卡住

回答 1

多线程下多个消费者不会冲突吗？

回答 1

打开慕课网App查看更多内容