#processing each micro batch
def process_events(event):
    return (event[0], Counter(event[1].split(" ")).most_common(3))

lines = kafkaStream.map(lambda x : process_events(x))