decode_body

kafkit.registry.sansio.decode_body(content_type, body)

Decode an HTTP body based on the specified content type.

Parameters:

content_type : str

Content type string, from the response header.

body : bytes

Bytes content of the body.

Returns:

decoded

The decoded message.

• If the content type is recognized as JSON, the result will be an object parsed from the JSON message.
• If the content type isn’t recognized, the body is decoded into a string.
• If the message is empty or content_type is None, the returned value is None.