Equipment Data Generation

Data Generation for the equipment stream analytics

Prerequisite

Python Packages Required :

confluent_kafka,kafka,kafka-python,requests,avro

Configure the config.properties

For creating mock avro records (Equipment Mock Streams)

python equipmentProduce.py

For creating meta json records (Meta Update Streams)

python equipmentConsume.py

For schema evolution change the config.properties to match the upgraded schema

equipment-value-schema=equipment-value-upgrade.avsc
mock_data=equipment-upgrade-mock