Hello, I am utilizing "org.apache.kafka.streams.integration.utils.EmbeddedKafkaCluster" to write integration tests for my application. In general, things are functioning properly. However, when I modify the default server configurations to use a SASL_PLAINTEXT listener with the PLAIN mechanism, issues arise. Although the cluster is running, the response from the METADATA request suggests that there are no brokers in the cluster.
Here is the server log for reference: [image: image.png] Did anybody see something similar or maybe is there someone who could successfully use EmbeddedKafkaCluster with SASL? Thanks,