老师，我使用的storm是1.1.1，kafka是1.0.0。重启worker时，数据丢失，也就是说spout没有重发数据。请问老师，这该怎么配置？非常感谢

来源：9-3 -Storm的ack和fail机制

慕哥8850026

2018-08-30

我的kafkaspout配置为：

KafkaSpoutConfig<String,String> build = KafkaSpoutConfig.builder("192.168.0.99:9092",topic) .setFirstPollOffsetStrategy(KafkaSpoutConfig.FirstPollOffsetStrategy.LATEST) .setGroupId("testGroup")

.build();

我在重启执行worker时，数据是丢失的。在bolt里添加ack与否都是数据丢失。

写回答

1回答

Michael_PK

2018-08-30

首先你是如何确认丢失了？在生产是肯定是要ack的，不然真丢了，

Michael_PK

慕哥8850026

https://kiswo.com/article/1010

2018-09-11

共11条回复

Java大数据实战，巧用Storm快速切入实时流处理领域

深入Storm内部机制，logstash+kafka，快速切入大数据实时流处理

518 学习 · 143 问题

查看课程

相似问题

storm读取数据问题

回答 1

关于storm里面的对象生存周期问题

回答 1

storm的worker自动重启

回答 1

storm数据刷新

回答 2

一个很重要业务上的问题？

回答 1

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