View Source KlifeProtocol.Messages.SaslAuthenticate (Klife Protocol v0.7.0)

Kafka protocol SaslAuthenticate message

Request versions summary:

  • Version 1 is the same as version 0. Version 2 adds flexible version support

Response versions summary:

  • Version 1 adds the session lifetime. Version 2 adds flexible version support

Link to this section Summary

Functions

Returns the message api key number.

Receive a binary in the kafka wire format and deserialize it into a map.

Returns the current max supported version of this message.

Returns the current min supported version of this message.

Receives a map and serialize it to kafka wire format of the given version.

Link to this section Functions

Returns the message api key number.

Link to this function

deserialize_response(data, version, with_header? \\ true)

View Source

Receive a binary in the kafka wire format and deserialize it into a map.

Response content fields:

  • error_code: The error code, or 0 if there was no error. (int16 | versions 0+)

  • error_message: The error message, or null if there was no error. (string | versions 0+)

  • auth_bytes: The SASL authentication bytes from the server, as defined by the SASL mechanism. (bytes | versions 0+)

  • session_lifetime_ms: Number of milliseconds after which only re-authentication over the existing connection to create a new session can occur. (int64 | versions 1+)

Returns the current max supported version of this message.

Returns the current min supported version of this message.

Link to this function

serialize_request(map, version)

View Source

Receives a map and serialize it to kafka wire format of the given version.

Input content fields:

  • auth_bytes: The SASL authentication bytes from the client, as defined by the SASL mechanism. (bytes | versions 0+)