class_docstr: Test consumer hook.
docstr: test initialization of AdminClientHook
code: def test_init(self):
      """test initialization of AdminClientHook"""
  
      # Standard Init
      KafkaConsumerHook(["test_1"], kafka_config_id="kafka_d")
  
      # Not Enough Args
      with pytest.raises(ValueError):
          KafkaConsumerHook(["test_1"], kafka_config_id="kafka_bad")
  
file_path: airflow/tests/providers/apache/kafka/hooks/test_consume.py
imports: from __future__ import annotations
  import json
  import pytest
  from airflow.models import Connection
  from airflow.providers.apache.kafka.hooks.consume import KafkaConsumerHook
  from airflow.utils import db
label_desc: Use image node_id 2 for calling the TestConsumerHook obj's underlying member method code with example usage: obj.test_init() without return types