Description
When we have StandbyTasks in a Kafka Streams app and we have > 1 threads per instance we can run into:
Caused by: java.io.IOException: task [1_0] Failed to lock the state directory: /private/tmp/kafka-streams-smoketest/2/SmokeTest/1_0
This is because the same StandbyTask has been assigned to each thread in the same KafkaStreams instance
Attachments
Issue Links
- links to