docstr: Creates a KafkaConsumer object which allows for all valid Kafka
  consumer type operations such as reading messages, committing
  offsets, and retrieving the current consumption offsets.
  
  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: ["Creates","a","KafkaConsumer","object","which","allows","for","all","valid","Kafka","consumer","type","operations","such","as","reading","messages",",","committing","offsets",",","and","retrieving","the","current","consumption","offsets",".","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):
      """
      Creates a KafkaConsumer object which allows for all valid Kafka
      consumer type operations such as reading messages, committing
      offsets, and retrieving the current consumption offsets.
  
      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
      """
  
      super().__init__(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 Consumer object from inherited base classes: CudfKafkaClient with example: obj = Consumer(kafka_configs)