Kafka TestingConsume Raw MessageTODO WIPConsume Json MessageKafka Consume the Latest Message or N Latest Messages