diff --git a/aiokafka/record/_crecords/default_records.pyi b/aiokafka/record/_crecords/default_records.pyi index c1815317..c56775fb 100644 --- a/aiokafka/record/_crecords/default_records.pyi +++ b/aiokafka/record/_crecords/default_records.pyi @@ -21,6 +21,8 @@ from aiokafka.record._types import ( @final class DefaultRecord(DefaultRecordProtocol): offset: int + timestamp: int + timestamp_type: int key: bytes | None value: bytes | None headers: list[tuple[str, bytes | None]] @@ -35,10 +37,6 @@ class DefaultRecord(DefaultRecordProtocol): value: bytes | None, headers: list[tuple[str, bytes | None]], ) -> None: ... - @property - def timestamp(self) -> int | None: ... - @property - def timestamp_type(self) -> int | None: ... @final class DefaultRecordBatch(DefaultRecordBatchProtocol): diff --git a/aiokafka/record/_crecords/default_records.pyx b/aiokafka/record/_crecords/default_records.pyx index ba49411d..40a945e2 100644 --- a/aiokafka/record/_crecords/default_records.pyx +++ b/aiokafka/record/_crecords/default_records.pyx @@ -448,20 +448,6 @@ cdef class DefaultRecord: record.headers = headers return record - @property - def timestamp(self): - if self.timestamp != -1: - return self.timestamp - else: - return None - - @property - def timestamp_type(self): - if self.timestamp != -1: - return self.timestamp_type - else: - return None - def __repr__(self): return ( "DefaultRecord(offset={!r}, timestamp={!r}, timestamp_type={!r},"