Kafka Container with SASL_PLAINTEXT

[SerdarNur]

Hey,

already tried a lot possibilities but always getting some exceptions.

Does anybody have a good example for KafkaContainer with SASL_PLAINTEXT?

Thank you!

[SerdarNur]

For those who also search for a solution. I have solved it like following:

`const jaasConfig = 'org.apache.kafka.common.security.plain.PlainLoginModule required ' + 'username="admin" ' + 'password="admin" ' + 'user_admin="admin" ' + 'user_test="secret";';

kafkaContainer = await new KafkaContainer()
  .withNetwork(network)
  .withZooKeeper(zooKeeperHost, zooKeeperPort)
  .withEnvironment({
    KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: 'PLAINTEXT:SASL_PLAINTEXT,BROKER:SASL_PLAINTEXT',
    KAFKA_SASL_MECHANISM_INTER_BROKER_PROTOCOL: 'PLAIN',
    KAFKA_LISTENER_NAME_PLAINTEXT_SASL_ENABLED_MECHANISMS: 'PLAIN',
    KAFKA_LISTENER_NAME_BROKER_SASL_ENABLED_MECHANISMS: 'PLAIN',
    KAFKA_LISTENER_NAME_BROKER_PLAIN_SASL_JAAS_CONFIG: jaasConfig,
    KAFKA_LISTENER_NAME_PLAINTEXT_PLAIN_SASL_JAAS_CONFIG: jaasConfig
  })
  .withExposedPorts(9093)
  .start();`