diff --git a/server/src/main/java/org/elasticsearch/cluster/metadata/StreamsMetadata.java b/server/src/main/java/org/elasticsearch/cluster/metadata/StreamsMetadata.java index 71dd9eeaff24f..99758350559d3 100644 --- a/server/src/main/java/org/elasticsearch/cluster/metadata/StreamsMetadata.java +++ b/server/src/main/java/org/elasticsearch/cluster/metadata/StreamsMetadata.java @@ -59,7 +59,13 @@ public String getWriteableName() { @Override public TransportVersion getMinimalSupportedVersion() { - return TransportVersions.STREAMS_LOGS_SUPPORT; + return TransportVersions.STREAMS_LOGS_SUPPORT_8_19; + } + + @Override + public boolean supportsVersion(TransportVersion version) { + return version.onOrAfter(TransportVersions.STREAMS_LOGS_SUPPORT) + || version.isPatchFrom(TransportVersions.STREAMS_LOGS_SUPPORT_8_19); } public static NamedDiff readDiffFrom(StreamInput in) throws IOException {