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.
docstr: Return a Consumer that has been subscribed to topics.
code: def get_consumer(self) -> Consumer:
      """Return a Consumer that has been subscribed to topics."""
      consumer = self.get_conn
      consumer.subscribe(self.topics)
  
      return consumer
  
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 3 for calling the KafkaConsumerHook obj's underlying member method code with example usage: obj.get_consumer() and returns: consumer