kafka_data/*.json