Исключение встроенного потока Kafka при параллельной обработке - PullRequest
0 голосов
/ 25 июня 2019

Когда я выполняю свое приложение для обработки данных, используя Embedded Kafka Streams для параллельной работы, я получаю следующую ошибку:

Exception in thread "TopicInGroup-684d9a1a-35fd-40eb-9d76-d869eab30251-StreamThread-1" org.apache.kafka.streams.errors.StreamsException: task [1_0] Fatal error while trying to lock the state directory for task 1_0 

Примечание. Каждый экземпляр потока kafka выполняется только в отдельной JVM.

...