Fix streams mode HTTP API

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/<stream-ID>` to the `/streams` handler. This issue was introduced in v4.14.0.
 
 ## 4.14.0 - 2023-04-25
 

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,
 	)
 }