Embedded Scalatest: параллельно запуская два пакета, он пытается подключиться бесконечно
Я запускаю два отдельных FunSuites (параллельно SBT), с разными портами Kafka и ZK каждый, они работают по отдельности, но не работают при запуске обоих.
[2018-05-12 00:57:59,106] WARN [Producer clientId=test-processor-stream-application-2fe823e5-72dc-4465-b8b8-a265b7b46f72-StreamThread-5-producer] Connection to node -1 could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)
[2018-05-12 00:57:59,655] WARN [Consumer clientId=test-processor-stream-application-2fe823e5-72dc-4465-b8b8-a265b7b46f72-StreamThread-5-consumer, groupId=test-processor-stream-application] Connection to node 0 could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)
Они оба продолжают появляться бесконечно.
Внутри каждого набора я поднимаю и опускаю каждую пару ZK-Kafka один раз за каждый тест (для заполнения с нуля каждый раз).
На самом деле, если я пытаюсь Ctrl+C, это показывает, [warn] Canceling execution... но продолжает пытаться соединиться, и это не останавливает тесты или программу.
Что может происходить?