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: Initialize our Base.
docstr_tok: ["Initialize","our","Base","."]
code: def __init__(
      self, kafka_config_id=default_conn_name, *args, **kwargs
  ):
      """Initialize our Base."""
      super().__init__(**kwargs)
      self.kafka_config_id = kafka_config_id
      self.get_conn
  
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 1 to create a new KafkaBaseHook object from inherited base classes: BaseHook with example: obj = KafkaBaseHook(kafka_config_id)