`TestUtils.tempDirectory(applicationId).getPath()` - creates the temp directory. The `collect` variable includes the application directory. So, the assert fail always.
Is it allowed to create `application` directory for stateless topology ? [ Full content available at: https://github.com/apache/kafka/pull/5647 ] This message was relayed via gitbox.apache.org for [email protected]
