code: def _simple_producer(key, value) -> list[tuple[Any, Any]]:
      """simple_producer A function that returns the key,value passed
      in for production via "KafkaProducerOperator"
  
      :param key: the key for the message
      :param value: the value for the message
      :return: The Key / Value pair for production via the operator
      :rtype: List[Tuple[Any, Any]]
      """
      return [(key, value)]
  
file_path: airflow/tests/providers/apache/kafka/operators/test_produce.py
imports: from __future__ import annotations
  import json
  import logging
  from typing import Any
  import pytest
  from airflow.models import Connection
  from airflow.providers.apache.kafka.operators.produce import ProduceToTopicOperator
  from airflow.utils import db
label_desc: Use image node_id 1 for calling a global function with example usage: _simple_producer(key, value) and returns: list