storm-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Elyahou Ittah <>
Subject KafkaSpout reconsume all kafka messages after kafka rolling restart
Date Mon, 21 Aug 2017 07:44:21 GMT
I noticed that storm kafka spout reconsume all kafka message after a
rolling restart of kafka cluster.

This issue occured only with kafkaSpout consumer and not for my other
consumers (ruby based  using the kafka consumer API like kafkaSpout)

Attached logs of the spout.

Do you know what can cause this kind of behavior ?

View raw message