from __future__ import annotations

from dataclasses import dataclass
from typing import Any


@dataclass(frozen=True)
class MQMessage:
    app: Any
    topic: str
    partition: int
    offset: int
    key: Any
    raw_key: bytes | None
    value: Any
    raw_value: bytes | None
    headers: dict[str, bytes | None]
    timestamp: tuple[int, int] | None
    raw_message: Any