storm kafka

我运行一个Topology,spout用的是kafka,运行一段时间后把这个Topology kill掉,重新运行这个Topology的时候,kafka的offset是重新开始了还是接着之前kill掉时的offset

Dong - Hulu

赞同来自: mopishv0 hello_world

如果你连接了zookeeper,offset会保存在zookeeper上,重新跑时,会重新读取上次的offer,接着读取

hello_world - 大数据工程师@人民网

赞同来自:

kafka不记录生产者和消费者的状态信息,状态信息保存在zookeeper上,不同组的消费者消费kafka的消息是互相独立的,同一组成员不会重复消费kafka中的消息

要回复问题请先登录注册