code: def _basic_message_tester(message, test=None) -> Any:
      """a function that tests the message received"""
  
      assert test
      # Confluent Kafka converts messages to bytes
      assert message.value().decode(encoding="utf-8") == test
  
file_path: airflow/tests/integration/providers/apache/kafka/operators/test_consume.py
imports: from __future__ import annotations
  import json
  import logging
  from typing import Any
  import pytest
  from confluent_kafka import Producer
  from airflow.models import Connection
  from airflow.providers.apache.kafka.operators.consume import ConsumeFromTopicOperator
  from airflow.utils import db
label_desc: Use image node_id 2 for calling a global function with example usage: _basic_message_tester(message, test) without return types