try a wrapper around the message

src/unfurlbot/handlers/kafka.py

@@ -4,6 +4,7 @@
 
 from faststream.kafka.fastapi import KafkaRouter
 from faststream.security import BaseSecurity
+from pydantic import BaseModel
 from rubin.squarebot.models.kafka import SquarebotSlackMessageValue
 from structlog import get_logger
 
@@ -18,6 +19,12 @@
 )
 
 
+class SlackMessageContainer(BaseModel):
+    """Container for a Slack message consumed from Kafka."""
+
+    message: SquarebotSlackMessageValue
+
+
 @kafka_router.subscriber(
     config.message_channels_topic,
     config.message_groups_topic,
@@ -26,8 +33,8 @@
     group_id=config.consumer_group_id,
 )
 async def handle_slack_message(
-    msg: SquarebotSlackMessageValue,
+    message: SlackMessageContainer,
 ) -> None:
     """Handle a Slack message."""
     logger = get_logger(__name__)
-    logger.debug("Received a Slack message", text=msg.text)
+    logger.debug("Received a Slack message", type=type(message))