feat(kafka): Implement basic async kafka consumer #36

	---
	name: CI

	on:
	push:
	branches: ["main"]
	pull_request:
	branches: ["main"]

	env:
	RUSTFLAGS: -Dwarnings

	jobs:
	lint:
	name: Lint
	runs-on: ubuntu-latest
	steps:
	- uses: actions/checkout@v4

	- name: Install protoc
	uses: arduino/setup-protoc@v3

	- name: Install Rust Toolchain
	run: rustup toolchain install stable --profile minimal --component clippy --component rustfmt --no-self-update

	- uses: swatinem/rust-cache@v2

	- name: Run Rustfmt
	run: cargo fmt --all -- --check

	- name: Run Clippy
	run: cargo clippy --workspace --all-features --tests -- -D clippy::all

	test:
	name: Test (ubuntu)
	runs-on: ubuntu-latest

	steps:
	- uses: actions/checkout@v2

	- name: Install protoc
	uses: arduino/setup-protoc@v3

	- uses: actions-rs/toolchain@16499b5e05bf2e26879000db0c1d13f7e13fa3af # pin@v1
	with:
	toolchain: stable
	profile: minimal
	override: true

	- uses: swatinem/rust-cache@81d053bdb0871dcd3f10763c8cc60d0adc41762b # pin@v1
	with:
	key: ${{ github.job }}

	- name: Run Cargo Tests
	uses: actions-rs/cargo@844f36862e911db73fe0815f00a4a2602c279505 # pin@v1
	with:
	command: test
	args: --all

Provide feedback