Skip to content

test: integration test kafka#894

Open
saksham-datazip wants to merge 11 commits intostagingfrom
test/integration-test-kafka
Open

test: integration test kafka#894
saksham-datazip wants to merge 11 commits intostagingfrom
test/integration-test-kafka

Conversation

@saksham-datazip
Copy link
Copy Markdown
Collaborator

Description

This PR introduces an integration test for the Kafka driver to validate end-to-end data flow and ensure correctness during sync operations.

Along with the test addition, two bugs were identified and fixed:

transformer.go: Fixed an issue related to parsing logic which could lead to incorrect data transformation under certain scenarios.
compare.go: Resolved a bug in comparison logic that was causing mismatches during validation.

These changes improve the reliability of Kafka integrations and ensure more accurate test validation.

No additional dependencies are required for this change.

Fixes # (issue)

Type of change

  • Bug fix (non-breaking change which fixes an issue)
  • New feature (non-breaking change which adds functionality)
  • Breaking change (fix or feature that would cause existing functionality to not work as expected)
  • This change requires a documentation update

How Has This Been Tested?

All tests were executed locally and passed successfully.

  • Scenario A
  • Scenario B

Screenshots or Recordings

N/A

Documentation

  • Documentation Link: [link to README, olake.io/docs, or olake-docs]
  • N/A (bug fix, refactor, or test changes only)

Related PR's (If Any):

@saksham-datazip saksham-datazip changed the title Test/integration test kafka test: integration test kafka Mar 26, 2026
@saksham-datazip saksham-datazip deployed to integration_tests March 30, 2026 05:56 — with GitHub Actions Active
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant