code: def _producer_function():
      for i in range(20):
          yield (json.dumps(i), json.dumps(i + 1))
  
file_path: airflow/tests/integration/providers/apache/kafka/operators/test_produce.py
imports: from __future__ import annotations
  import json
  import logging
  import pytest
  from confluent_kafka import Consumer
  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: _producer_function() without return types