Class: Ksql::Api::Terminate

Inherits:

Object

• Object
• Ksql::Api::Terminate

Defined in:

lib/ksql/api/terminate.rb

Constant Summary

Headers =

{ 'Accept' => 'application/json' }.freeze

Class Method Summary

• .build(delete_topic_list = null, headers:) ⇒ Ksql::Connection::Request

  Build the ksqlDB /ksql/terminate request.

Class Method Details

.build(delete_topic_list = null, headers:) ⇒ Ksql::Connection::Request

Build the ksqlDB /ksql/terminate request

Parameters:

• delete_topic_list (Array<String>) (defaults to: null) —

  Kafka topic names or regular expressions

• headers (Hash) —

  Request headers

Returns:

• (Ksql::Connection::Request) —

  Request instance

# File 'lib/ksql/api/terminate.rb', line 16

def self.build(delete_topic_list = null, headers:)
  ::Ksql::Connection::Request.new(
    { deleteTopicList: delete_topic_list }.compact,
    '/ksql/terminate',
    Headers.merge(headers),
    :post
  )
end