Please check if the PR fulfills these requirements
[x] The commit messages are descriptive
[x] Tests for the changes have been added (for bug fixes / features)
[ ] Docs have been added / updated (for bug fixes / features)
[ ] An issue has been created for the pull requests. Some issues might require previous discussion.
What kind of change does this PR introduce? (Bug fix, feature, docs update, ...)
Test for existing code. Minor src code refactoring to help with testability.
What is the current behavior? (You can also link to an open issue here)
No tests for KafkaBackend
What is the new behavior (if this is a feature change)?
Unit tests for KafkaBackend
Does this PR introduce a breaking change? (What changes might users need to make in their application due to this PR?)
No
Other information:
This is my first contribution to this project. Please let me know if any issues.
Please check if the PR fulfills these requirements
[x] The commit messages are descriptive
[x] Tests for the changes have been added (for bug fixes / features)
[ ] Docs have been added / updated (for bug fixes / features)
[ ] An issue has been created for the pull requests. Some issues might require previous discussion.
What kind of change does this PR introduce? (Bug fix, feature, docs update, ...) Test for existing code. Minor src code refactoring to help with testability.
What is the current behavior? (You can also link to an open issue here) No tests for KafkaBackend
What is the new behavior (if this is a feature change)? Unit tests for KafkaBackend
Does this PR introduce a breaking change? (What changes might users need to make in their application due to this PR?) No
Other information: This is my first contribution to this project. Please let me know if any issues.