Create and Start Pipeline from java code

Help Connectors and Pipelines
1

Hello Team,

Does memSQL support creation of Pipeline from java. Something like :

String createPipelineStmt = “CREATE OR REPLACE PIPELINE TEST_PIPELINE AS LOAD DATA
KAFKA ‘kafka-host:port/kafka_topic1’ INTO TABLE event”;
try (Connection con = customMemSqlService.getDatabaseConnection();
Statement stmt = con.createStatement(); ) {
stmt.execute(createPipelineStmt);
}
catch (Exception e) {
}

2

Hey Team,

I was facing issues in creating pipeline due to a small syntax error at my end.
But it is sorted now.

Pipelines are successfully created and started successfully from java.

Thank you