CODEWITHSUNDEEP
apache-storm
ab11
ab11

Reputation: 20100

Is tuple timeout configuration per spout?

Topologies have a tuple timeout setting. If I set this as 30s and have the below topology:

If a tuple emitted by spoutA takes 20s to be emitted to Kafka topicA, and then spoutB takes 20s to emit and ack - will spoutA consider this 40s and timeout and retry? or will nothing be retried because each spout only took 20s?

enter image description here

Upvotes: 0

Views: 202

Answers (1)

f1sherox
f1sherox

Reputation: 349

When spout B read message from topic A storm will consider it as completly new message. So averege complete latency will be 20 seconds not 40.

Upvotes: 1

Related Questions