docstr: Base object for any client that wants to interact with a Kafka broker.
  This object creates the underlying KafkaDatasource connection which
  is used to read data from Kafka and create cudf Dataframes.
  This class should not be directly instantiated.
  
  Parameters
  ----------
  kafka_configs : dict,
      Dict of Key/Value pairs of librdkafka
      configuration values. Full list of valid configuration
      options can be found at
      https://github.com/edenhill/librdkafka/blob/master/CONFIGURATION.md
docstr_tok: ["Base","object","for","any","client","that","wants","to","interact","with","a","Kafka","broker",".","This","object","creates","the","underlying","KafkaDatasource","connection","which","is","used","to","read","data","from","Kafka","and","create","cudf","Dataframes",".","This","class","should","not","be","directly","instantiated",".","Parameters","--","--","--","--","--","kafka_configs",":","dict",",","Dict","of","Key\/Value","pairs","of","librdkafka","configuration","values",".","Full","list","of","valid","configuration","options","can","be","found","at","https",":","\/\/github.com\/edenhill\/librdkafka\/blob\/master\/CONFIGURATION.md"]
code: def __init__(self, kafka_configs):
      """
      Base object for any client that wants to interact with a Kafka broker.
      This object creates the underlying KafkaDatasource connection which
      is used to read data from Kafka and create cudf Dataframes.
      This class should not be directly instantiated.
  
      Parameters
      ----------
      kafka_configs : dict,
          Dict of Key/Value pairs of librdkafka
          configuration values. Full list of valid configuration
          options can be found at
          https://github.com/edenhill/librdkafka/blob/master/CONFIGURATION.md
      """
  
      self.kafka_configs = kafka_configs
      self.kafka_meta_client = KafkaDatasource(kafka_configs)
      self.ck_consumer = ck.Consumer(kafka_configs)
  
file_path: cudf/python/custreamz/custreamz/kafka.py
imports: import confluent_kafka
  from cudf_kafka._lib.kafka import KafkaDatasource
  import cudf
label_desc: Use image node_id 1 to create a new CudfKafkaClient object  with example: obj = CudfKafkaClient(kafka_configs)