docstr: Consumes a single message, calls callbacks and returns events.
  
  The application must check the returned Message object's
  Message.error() method to distinguish between proper messages
  (error() returns None), or an event or error
  (see error().code() for specifics).
  
  Parameters
  ----------
  timeout : float
      Maximum time to block waiting for message, event or callback
      (default: infinite (None translated into -1 in the
      library)). (Seconds)
docstr_tok: ["Consumes","a","single","message",",","calls","callbacks","and","returns","events",".","The","application","must","check","the","returned","Message","object's","Message.error","(",")","method","to","distinguish","between","proper","messages","(","error","(",")","returns","None",")",",","or","an","event","or","error","(","see","error","(",")",".code","(",")","for","specifics",")",".","Parameters","--","--","--","--","--","timeout",":","float","Maximum","time","to","block","waiting","for","message",",","event","or","callback","(","default",":","infinite","(","None","translated","into","-1","in","the","library",")",")",".","(","Seconds",")"]
code: def poll(self, timeout=None):
      """
      Consumes a single message, calls callbacks and returns events.
  
      The application must check the returned Message object's
      Message.error() method to distinguish between proper messages
      (error() returns None), or an event or error
      (see error().code() for specifics).
  
      Parameters
      ----------
      timeout : float
          Maximum time to block waiting for message, event or callback
          (default: infinite (None translated into -1 in the
          library)). (Seconds)
      """
      return self.ck.poll(timeout)
  
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 6 for calling the Consumer obj's underlying member method code with example usage: obj.poll(timeout) and returns: self