(kafka_params, topic, partition, keys, low, high, timeout=None)
return gdf
Fetch a batch of kafka messages (currently, messages must be in JSON format)
    in given topic/partition as a cudf dataframe
Fetch a batch of kafka messages (currently, messages must be in JSON format)
    in given topic/partition as a cudf dataframe
Fetch a batch of kafka messages ( currently messages must be in JSON format ) in given topic / partition as a cudf dataframe
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
def get_message_batch_cudf ( kafka_params , topic , partition , keys , low , high , timeout = None ) : # pragma: no cover 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