Rust Kafka consumer for Bitquery blockchain streams (Solana and EVM: Base, Ethereum, BSC, Tron). Consumes protobuf messages and runs example filters.
- Rust (e.g.
rustup) - A
config.tomlfile (an example is included in the repo)
Edit config.toml:
- Set
chainto one of:"solana","base","ethereum","bsc","tron". - Fill the matching section (
[solana],[base], etc.) with your Bitqueryusername,password, andtopic.
cargo build
cargo runRun from the project root so that config.toml is in the current working directory (the app loads it via the config crate).
To add or modify event filters, edit src/filters.rs.
- Solana (Solana proto schema)
- EVM: Base, Ethereum, BSC, Tron (shared EVM proto schema)