refactor(kafka): improve tests & error handling #5791

	name: On PR code update

	on:
	pull_request:
	types: [opened, synchronize]

	permissions:
	contents: read

	jobs:
	run-unit-tests:
	uses: ./.github/workflows/reusable-run-linting-check-and-unit-tests.yml

Provide feedback