class_docstr: A hook for creating a Kafka Consumer.
  
  :param kafka_config_id: The connection object to use, defaults to "kafka_default"
  :param topics: A list of topics to subscribe to.
code: def __init__(
      self,
      topics: Sequence[str],
      kafka_config_id=KafkaBaseHook.default_conn_name,
  ) -> None:
      super().__init__(kafka_config_id=kafka_config_id)
      self.topics = topics
  
file_path: airflow/airflow/providers/apache/kafka/hooks/consume.py
imports: from __future__ import annotations
  from typing import Sequence
  from confluent_kafka import Consumer
  from airflow.providers.apache.kafka.hooks.base import KafkaBaseHook
label_desc: Use image node_id 1 to create a new KafkaConsumerHook object from inherited base classes: KafkaBaseHook with example: obj = KafkaConsumerHook(topics, kafka_config_id)