Skip to content

Commit

Permalink
Temp commit
Browse files Browse the repository at this point in the history
  • Loading branch information
mukesh-ctds committed Jul 22, 2024
1 parent e611d1d commit 087b6f6
Showing 1 changed file with 8 additions and 8 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -48,15 +48,15 @@ public PulsarDebeziumSourcesTest() {
super(FunctionRuntimeType.PROCESS);
}

@Test(groups = "source")
public void testDebeziumMySqlSourceJson() throws Exception {
testDebeziumMySqlConnect("org.apache.kafka.connect.json.JsonConverter", true, false);
}
// @Test(groups = "source")
// public void testDebeziumMySqlSourceJson() throws Exception {
// testDebeziumMySqlConnect("org.apache.kafka.connect.json.JsonConverter", true, false);
// }

@Test(groups = "source")
public void testDebeziumMySqlSourceJsonWithClientBuilder() throws Exception {
testDebeziumMySqlConnect("org.apache.kafka.connect.json.JsonConverter", true, true);
}
// @Test(groups = "source")
// public void testDebeziumMySqlSourceJsonWithClientBuilder() throws Exception {
// testDebeziumMySqlConnect("org.apache.kafka.connect.json.JsonConverter", true, true);
// }

// @Test(groups = "source")
// public void testDebeziumMySqlSourceAvro() throws Exception {
Expand Down

0 comments on commit 087b6f6

Please sign in to comment.