TolstochenkoDaniil

# Following gist is the example of sentry integration for
# faststream app (https://github.com/airtai/faststream) and only kafka broker as the use case
# Feel free to contact if you have any suggestions or help for refactoring and/or scale the integration

from typing import Any, Optional
from datetime import UTC, datetime
import sys

from faststream.broker.core.usecase import BrokerUsecase
from faststream.broker.publisher.proto import ProducerProto