class_docstr: A base hook for interacting with Apache Kafka.
  
  :param kafka_config_id: The connection object to use, defaults to "kafka_default"
class_docstr_tok: ["A","base","hook","for","interacting","with","Apache","Kafka",".",":","param","kafka_config_id",":","The","connection","object","to","use",",","defaults","to","``","kafka_default","''"]
docstr: Get the configuration object.
docstr_tok: ["Get","the","configuration","object","."]
code: def get_conn(self) -> Any:
      """Get the configuration object."""
      config = self.get_connection(self.kafka_config_id).extra_dejson
  
      if not (config.get("bootstrap.servers", None)):
          raise ValueError(
              "config['bootstrap.servers'] must be provided."
          )
  
      return self._get_client(config)
  
file_path: airflow/airflow/providers/apache/kafka/hooks/base.py
imports: from __future__ import annotations
  from functools import cached_property
  from typing import Any
  from confluent_kafka.admin import AdminClient
  from airflow.hooks.base import BaseHook
label_desc: Use image node_id 4 for calling the KafkaBaseHook obj's underlying member method code with example usage: obj.get_conn() and returns: self