Kafka consumer KafkaConsumer ¶ Bases: Consumer Implementation of a consumer for Kafka disconnect() async ¶ Closes the connection to the server. RETURNS DESCRIPTION None get_message() ¶ Get the published messages of the subscription. RETURNS DESCRIPTION iterator An async iterator for the messages. TYPE: AsyncIterator