Sha256: 8bd5fe528c047a38a6602ce425e4781e9299fe58eb86a06cb86d8e8934114868
Contents?: true
Size: 861 Bytes
Versions: 17
Compression:
Stored size: 861 Bytes
Contents
class KafkaConnect
def initialize(host, connector_name)
uri = URI(host)
@http = Net::HTTP.new(uri.host, uri.port)
@connector_name = connector_name
end
def configure(config)
request = Net::HTTP::Put.new("/connectors/#{@connector_name}/config")
request.body = config.to_json
request.content_type = "application/json"
@http.request(request)
end
def delete
request = Net::HTTP::Delete.new("/connectors/#{@connector_name}")
@http.request(request)
end
def info
request = Net::HTTP::Get.new("/connectors/#{@connector_name}")
response = @http.request(request)
JSON.parse(response.body, symbolize_names: true)
end
def status
request = Net::HTTP::Get.new("/connectors/#{@connector_name}/status")
response = @http.request(request)
JSON.parse(response.body, symbolize_names: true)
end
end
Version data entries
17 entries across 17 versions & 1 rubygems