I can't get key of message in FastStream

[alm0ra]

here i my code

import asyncio

from faststream import FastStream
from faststream.kafka import KafkaBroker

broker = KafkaBroker("kafka:9092")
app = FastStream(broker)


@broker.subscriber(
    *["accounting_failed", "accounting_internal"],
    group_id="group",
    auto_commit=True,
)
async def handler(msg: str):
    print(msg)


async def main():
    await app.run()


if __name__ == '__main__':
    asyncio.run(main())

but how do I get the key and headers in my Kafka message?
it just returns body in the message

[alm0ra]

i found the answer

@broker.subscriber(
    *["accounting_failed", "accounting_internal"],
    group_id="group",
    auto_commit=False,
)
async def handler(msg: str, key: bytes = Context("message.raw_message.key"),
                  headers: bytes = Context("message.raw_message.headers"),
                  topic: str = Context("message.raw_message.topic")):
    print(key)
    print(msg)
    print(headers)
    print(topic)