Skip to content

Commit 0714213

Browse files
committed
docs: TOMBSTONE
1 parent f4524ed commit 0714213

2 files changed

Lines changed: 6 additions & 0 deletions

File tree

docs/docs/en/confluent/message.md

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -26,6 +26,9 @@ This object serves as a unified **FastStream** wrapper around the native broker
2626
* `#!python topic(): str`
2727
* `#!python value(): Optional[Union[str, bytes]]`
2828

29+
!!! note
30+
A `None` value() is a Kafka tombstone, the delete marker on a compacted topic. FastStream represents it as `faststream.message.TOMBSTONE`, kept distinct from an empty payload (`b""`).
31+
2932
For example, if you would like to access the headers of an incoming message, you would do so like this:
3033

3134
```python hl_lines="1 6"

docs/docs/en/kafka/message.md

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -31,6 +31,9 @@ This object serves as a unified **FastStream** wrapper around the native broker
3131
* `#!python topic: str`
3232
* `#!python value: Optional[aiokafka.structs.VT]`
3333

34+
!!! note
35+
A `None` value is a Kafka tombstone, the delete marker on a compacted topic. FastStream represents it as `faststream.message.TOMBSTONE`, kept distinct from an empty payload (`b""`).
36+
3437
For example, if you would like to access the headers of an incoming message, you would do so like this:
3538

3639
```python hl_lines="1 6"

0 commit comments

Comments
 (0)