Method●Since v0.3

messages_from_latest

Reset to the end offset. Try to consume messages if available.

messages_from_latest(
  self,
  max_message_count: Optional[int] = 5,
  max_time_sec: Optional[float] = 5.0
) -> List[BaseMessage]

Returns: List of messages.

Parameters

Name	Type	Description
`max_message_count`	`Optional[int]`	Default:`5` Maximum number of messages to consume.
`max_time_sec`	`Optional[float]`	Default:`5.0` Time limit in seconds to consume messages.