[QUESTION] Is possible to publish and consume messages in Aws MSK with SASL enabled? about laravel-kafka HOT 7 CLOSED

@daavelar fixed on v1.7.5. Please let me know if it solves your issue

from laravel-kafka.

@daavelar Publishing (and) to MSK with SASL/SCRAM works fine.
Not sure if directly related, but as far as I know MSK uses SCRAM-SHA-512. The error message would be confusing if this is the problem you're facing, though.

from laravel-kafka.

@daavelar, don't know if i can help you much on this one, since i've never used MSK before. However, this exception is thrown when the flush method returns with error, as you can see here:

from laravel-kafka.

Solved! Thanks a lot!

from laravel-kafka.

I changed the code to this:

        $sasl = new Sasl(
            username: 'myuser',
            password: 'mypass',
            mechanisms: 'SCRAM-SHA-512',
            securityProtocol: 'SASL_SSL'
        );

and managed to publish messages, the problem now is consuming:
Disconnected while requesting ApiVersion: might be caused by incorrect security.protocol configuration (connecting to a SSL listener?) or broker version is < 0.10 (see api.version.request) (after 159ms in state APIVERSION_QUERY)

from laravel-kafka.

I found out here what the problem was, even with the flag --securityProtocol=SASL_SSL, the consumer was using the default SASL_PLAINTEXT value because the parameter was missing in the getSasl() method of the Options class, i change the method to this and worked fine:

    public function getSasl(): ?Sasl
    {
        if (is_null($this->saslMechanisms) || is_null($this->saslPassword) || is_null($this->saslUsername)) {
            return null;
        }

        return new Sasl(
            username: $this->saslUsername,
            password: $this->saslPassword,
            mechanisms: $this->saslMechanisms,
            securityProtocol: $this->securityProtocol
        );
    }

from laravel-kafka.

@daavelar can you send it as a PR?

from laravel-kafka.