kafka protocol: code refactoring (#1787) #6753

Job	Run time
prepare pre-build environment for tests	18s
build-hstream-admin-store	4m 4s
build-ghc-9.4.8	19m 23s
test-ghc-9.4.8	4m 5s
integration-tests-9.4.8	19m 15s
deploy-to-minikube-ghc-${{ matrix.ghc }}	0s
integration-tests-rqlite-9.4.8	20m 42s
integration-tests-kafka-9.4.8	14m 14s
integration-tests-kafka-rqlite-9.4.8	13m 19s
distributed-tests-9.4.8	6m 12s
	1h 41m 32s

Provide feedback