code: def setup_method(self):
      for num in [1]:
          db.merge_conn(
              Connection(
                  conn_id=f"trigger.await_message.test.integration.test_{num}",
                  conn_type="kafka",
                  extra=json.dumps(
                      {
                          "socket.timeout.ms": 10,
                          "bootstrap.servers": "broker:29092",
                          "group.id": f"trigger.await_message.test.integration.test_{num}",
                          "enable.auto.commit": False,
                          "auto.offset.reset": "beginning",
                      }
                  ),
              )
          )
  
file_path: airflow/tests/integration/providers/apache/kafka/triggers/test_await_message.py
imports: from __future__ import annotations
  import json
  import pytest
  from confluent_kafka import Producer
  from airflow.models import Connection
  from airflow.providers.apache.kafka.triggers.await_message import AwaitMessageTrigger
  from airflow.utils import db
label_desc: Use image node_id 1 for calling the TestTrigger obj's underlying member method code with example usage: obj.setup_method() without return types