Detailed Description

Wrapper for consumed record.

Definition at line 124 of file classes.py.

Public Member Functions
	__init__ (self, aiokafka.ConsumerRecord record)
str	key (self)
str	value (self)
list[Header]	headers (self)

Public Attributes
	topic = record.topic
str	key_raw = record.key
str	value_raw = record.value
	partition = record.partition
	offset = record.offset
list[Header]	headers_raw = record.headers

Constructor & Destructor Documentation

◆ init()

testsuite.databases.kafka.classes.ConsumedMessage.__init__	(		self,
		aiokafka.ConsumerRecord	record )

Definition at line 134 of file classes.py.

Member Function Documentation

◆ headers()

list[Header] testsuite.databases.kafka.classes.ConsumedMessage.headers ( self )

Definition at line 151 of file classes.py.

◆ key()

str testsuite.databases.kafka.classes.ConsumedMessage.key ( self )

Definition at line 143 of file classes.py.

◆ value()

str testsuite.databases.kafka.classes.ConsumedMessage.value ( self )

Definition at line 147 of file classes.py.

Member Data Documentation

◆ headers_raw

testsuite.databases.kafka.classes.ConsumedMessage.headers_raw = record.headers

Definition at line 140 of file classes.py.

◆ key_raw

str testsuite.databases.kafka.classes.ConsumedMessage.key_raw = record.key

Definition at line 136 of file classes.py.

◆ offset

testsuite.databases.kafka.classes.ConsumedMessage.offset = record.offset

Definition at line 139 of file classes.py.

◆ partition

testsuite.databases.kafka.classes.ConsumedMessage.partition = record.partition

Definition at line 138 of file classes.py.

◆ topic

testsuite.databases.kafka.classes.ConsumedMessage.topic = record.topic

Definition at line 135 of file classes.py.

◆ value_raw

str testsuite.databases.kafka.classes.ConsumedMessage.value_raw = record.value

Definition at line 137 of file classes.py.

The documentation for this class was generated from the following file:

en/testsuite/databases/kafka/classes.py