MsgToSend

Bases: BaseModel

A Pydantic model representing a message to be sent to Kafka.

headers: List[Tuple[str, bytes]]

key: Optional[Union[str, bytes]]

timestamp: int

value: Optional[Union[str, bytes]]