processing is currently split between 2 separate services, the first effectively just takes raw bitcoin blocks and transactions and pushes them to the next service through kafka. Currently the second service is responsible for filtering, so for that to be effective I have to provide the data tagged somehow. Though architecturally I'm not a 100% happy with this yet tbh