diff --git a/CHANGELOG.md b/CHANGELOG.md index ccd59e9208..8d9c0592d2 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -5,6 +5,8 @@ All notable changes to this project will be documented in this file. ## Unreleased +## 4.15.0 - 2023-05-05 + ### Added - Flag `--skip-env-var-check` added to the `lint` subcommand, this disables the new linting behaviour where environment variable interpolations without defaults throw linting errors when the variable is not defined. @@ -19,6 +21,7 @@ All notable changes to this project will be documented in this file. - Provide msgpack plugins through `public/components/msgpack`. - The `kafka_franz` input should no longer commit offsets one behind the next during partition yielding. +- The streams mode HTTP API should no longer route requests to `/streams/` to the `/streams` handler. This issue was introduced in v4.14.0. ## 4.14.0 - 2023-04-25 diff --git a/internal/stream/manager/api.go b/internal/stream/manager/api.go index ebc7ef0dde..b9a8a4f7f1 100644 --- a/internal/stream/manager/api.go +++ b/internal/stream/manager/api.go @@ -37,11 +37,14 @@ func (m *Type) registerEndpoints(enableCrud bool) { return } m.manager.RegisterEndpoint( - "/streams", - "GET: List all streams along with their status and uptimes."+ - " POST: Post an object of stream ids to stream configs, all"+ - " streams will be replaced by this new set.", - m.HandleStreamsCRUD, + "/resources/{type}/{id}", + "POST: Create or replace a given resource configuration of a specified type. Types supported are `cache`, `input`, `output`, `processor` and `rate_limit`.", + m.HandleResourceCRUD, + ) + m.manager.RegisterEndpoint( + "/streams/{id}/stats", + "GET a structured JSON object containing metrics for the stream.", + m.HandleStreamStats, ) m.manager.RegisterEndpoint( "/streams/{id}", @@ -51,14 +54,11 @@ func (m *Type) registerEndpoints(enableCrud bool) { m.HandleStreamCRUD, ) m.manager.RegisterEndpoint( - "/streams/{id}/stats", - "GET a structured JSON object containing metrics for the stream.", - m.HandleStreamStats, - ) - m.manager.RegisterEndpoint( - "/resources/{type}/{id}", - "POST: Create or replace a given resource configuration of a specified type. Types supported are `cache`, `input`, `output`, `processor` and `rate_limit`.", - m.HandleResourceCRUD, + "/streams", + "GET: List all streams along with their status and uptimes."+ + " POST: Post an object of stream ids to stream configs, all"+ + " streams will be replaced by this new set.", + m.HandleStreamsCRUD, ) }