code: def get_message_batch_cudf(
      kafka_params, topic, partition, keys, low, high, timeout=None
  ):  # pragma: no cover
      """
      Fetch a batch of kafka messages (currently, messages must be in JSON format)
      in given topic/partition as a cudf dataframe
      """
      from custreamz import kafka
  
      consumer = kafka.Consumer(kafka_params)
      gdf = None
      try:
          gdf = consumer.read_gdf(
              topic=topic,
              partition=partition,
              lines=True,
              start=low,
              end=high + 1,
          )
      finally:
          consumer.close()
      return gdf
  
imports: import asyncio
  from glob import glob
  import queue
  import os
  import time
  from tornado import gen
  import weakref
  from .core import Stream, convert_interval, RefCounter, sync
label_desc: Use image node_id 6 for calling a global function with example usage: get_message_batch_cudf(kafka_params, topic, partition, keys, low, high, timeout) and returns: gdf