class_docstr: Test ConsumeFromTopic
code: def test_operator_callable(self):
      operator = ConsumeFromTopicOperator(
          kafka_config_id="kafka_d",
          topics=["test"],
          apply_function=_no_op,
          task_id="test",
          poll_timeout=0.0001,
      )
  
      # execute the operator (this is essentially a no op as the broker isn't setup)
      operator.execute(context={})
  
file_path: airflow/tests/providers/apache/kafka/operators/test_consume.py
imports: from __future__ import annotations
  import json
  import logging
  from typing import Any
  from unittest import mock
  import pytest
  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 3 for calling the TestConsumeFromTopic obj's underlying member method code with example usage: obj.test_operator_callable() without return types