A telemetry pipeline for vehicle-mounted embedded systems.
- Deserializer: Reads CAN bus data and stores it in Redis
- Redis: In-memory data store for telemetry buffering and persistence
- Kafka-Connector: Reads telemetry from Redis and streams to Kafka
Place your .dbc files in the dbc-files/ directory. All files will be loaded automatically.
Copy .env.example to .env and fill in the required values:
cp .env.example .envSee .env.example for descriptions of each variable.
Build the project:
docker compose buildRun the application:
docker compose upThis application requires a CAN interface. For development/testing, you can use a virtual CAN interface (vcan0).
Run the following commands on the host machine:
Load the vcan kernel module:
modprobe vcanVerify the module loaded successfully:
lsmod | grep vcanExpected output:
vcan 12288 0