Add YAML tests for new function

Author: lukewhiting

modules/streams/src/yamlRestTest/resources/rest-api-spec/test/streams/logs/30_param_restrictions.yml

@@ -0,0 +1,45 @@
+---
+teardown:
+  - do:
+      streams.logs_disable: { }
+
+---
+"Check User Can't Use Restricted Params On Logs Endpoint":
+  - do:
+      streams.logs_enable: { }
+  - is_true: acknowledged
+
+  - do:
+      streams.status: { }
+  - is_true: logs.enabled
+
+  - do:
+      bulk:
+        refresh: true
+        body: |
+          { "index": { "_index": "logs"} }
+          { "foo": "bar" }
+          { "index": { "_index": "not-logs" } }
+          { "foo": "bar" }
+  - match: { errors: true }
+  - match: { items.0.index.status: 400 }
+  - match: { items.0.index.error.type: "illegal_argument_exception" }
+  - match: { items.0.index.error.reason: "When writing to a stream, only the following parameters are allowed: [error_trace,timeout]" }
+  - match: { items.1.index.status: 201 }
+
+---
+"Check User Can't Use Restricted Params On Logs Endpoint - Single Doc":
+  - do:
+      streams.logs_enable: { }
+  - is_true: acknowledged
+
+  - do:
+      streams.status: { }
+  - is_true: logs.enabled
+
+  - do:
+      index:
+        refresh: true
+        index: logs
+        body: { "foo": "bar" }
+      catch: bad_request

server/src/main/java/org/elasticsearch/rest/action/document/RestBulkAction.java

@@ -41,6 +41,7 @@
 import java.io.IOException;
 import java.util.ArrayDeque;
 import java.util.ArrayList;
+import java.util.LinkedHashSet;
 import java.util.List;
 import java.util.Set;
 import java.util.concurrent.TimeUnit;
@@ -63,7 +64,12 @@ public class RestBulkAction extends BaseRestHandler {
 
     public static final String TYPES_DEPRECATION_MESSAGE = "[types removal] Specifying types in bulk requests is deprecated.";
     public static final String FAILURE_STORE_STATUS_CAPABILITY = "failure_store_status";
-    public static final Set<String> STREAMS_ALLOWED_PARAMS = Set.of("timeout", "error_trace");
+    public static final LinkedHashSet<String> STREAMS_ALLOWED_PARAMS = new LinkedHashSet<>(2) {
+        {
+            add("error_trace");
+            add("timeout");
+        }
+    };
 
     private final boolean allowExplicitIndex;
     private final IncrementalBulkService bulkHandler;