Skip to content

Commit 85071ea

Browse files
committed
started new branch with delete topics feature for terminate cluster
1 parent 8d10b18 commit 85071ea

File tree

1 file changed

+9
-8
lines changed

1 file changed

+9
-8
lines changed

ksqljs/ksqlJS.js

Lines changed: 9 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -224,13 +224,13 @@ class ksqljs {
224224
}
225225

226226
/**
227-
*
228-
* @param {string} streamName
229-
* @param {string[]} selectColumns
230-
* @param {string} sourceStream
231-
* @param {object} propertiesObj
232-
* @param {string} conditions
233-
* @param {string} partitionBy
227+
*
228+
* @param {string} streamName
229+
* @param {string[]} selectColumns
230+
* @param {string} sourceStream
231+
* @param {object} propertiesObj
232+
* @param {string} conditions
233+
* @param {string} partitionBy
234234
* @returns {Promise}
235235
*/
236236
createStreamAs = (streamName, selectColumns, sourceStream, propertiesObj, conditions, partitionBy) => {
@@ -488,9 +488,10 @@ class ksqljs {
488488
*
489489
* <p>This method may be used to terminate a ksqlDB cluster. First, shut down all the servers except one.
490490
*
491+
* @param {string[]} topicsToDelete an array of topic names or regular expressions for topic names to delete.
491492
* @return {Promise} this method returns a promise that returns a response object.
492493
*/
493-
terminateCluster() {
494+
terminateCluster(topicsToDelete = []) {
494495
return axios.post(this.ksqldbURL + `/ksql/terminate`, {}, {
495496
headers: {
496497
// 'application/json' is the modern content-type for JSON, but some

0 commit comments

Comments
 (0)