[type: Feature] add logging kafka e2e test

[RayayChung]

Make sure that:

• [ ] You have read the contribution guidelines.
• [ ] You submit test cases (unit or integration tests) that back your changes.
• [ ] Your local test passed ./mvnw clean install -Dmaven.javadoc.skip=true.