Skip to content

Commit

Permalink
Merge pull request #16 from indraraj/DBZ-8590
Browse files Browse the repository at this point in the history
DBZ-8590: Add Predicate support in the Transform configuration and ed…
  • Loading branch information
indraraj authored Jan 29, 2025
2 parents 6c7a97b + ef792a7 commit 51b84aa
Show file tree
Hide file tree
Showing 26 changed files with 911 additions and 909 deletions.
1 change: 1 addition & 0 deletions debezium-platform-stage/src/App.tsx
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
import { BrowserRouter as Router } from "react-router-dom";
import "@patternfly/react-core/dist/styles/base.css";
import '@patternfly/react-styles/css/utilities/Spacing/spacing.css';
import { AppLayout } from "./appLayout/AppLayout";
import { AppRoutes } from "./AppRoutes";
import { AppContextProvider } from "./appLayout/AppContext";
Expand Down
28 changes: 28 additions & 0 deletions debezium-platform-stage/src/__mocks__/data/Predicates.json
Original file line number Diff line number Diff line change
@@ -0,0 +1,28 @@
[
{
"properties": {
"pattern": {
"title": "Pattern",
"description": "A predicate which is true for records with a topic name that matches the configured regular expression.",
"type": "STRING",
"x-name": "pattern"
}
},
"predicate": "org.apache.kafka.connect.transforms.predicates.TopicNameMatches"
},
{
"properties": {
"name": {
"title": "Name",
"description": "A predicate which is true for records with at least one header with the configured name.",
"type": "STRING",
"x-name": "name"
}
},
"predicate": "org.apache.kafka.connect.transforms.predicates.HasHeaderKey"
},
{
"properties": {},
"predicate": "org.apache.kafka.connect.transforms.predicates.RecordIsTombstone"
}
]
7 changes: 7 additions & 0 deletions debezium-platform-stage/src/apis/apis.tsx
Original file line number Diff line number Diff line change
Expand Up @@ -67,12 +67,19 @@ export type Source = {
id: number;
};

export type Predicate = {
type: string;
config: Record<string, string>;
negate?: boolean;
}

export type TransformData = {
type: string;
schema: string;
vaults: Vault[];
config: SourceConfig;
description?: string;
predicate?: Predicate;
name: string;
id: number;
};
Expand Down
Loading

0 comments on commit 51b84aa

Please sign in to comment.