Skip to content

Commit 21e39f4

Browse files
authored
filestream: make gzip a beta feature (#46492)
1 parent 178c0c3 commit 21e39f4

File tree

4 files changed

+12
-11
lines changed

4 files changed

+12
-11
lines changed

CHANGELOG.next.asciidoc

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -69,7 +69,7 @@ already present as `container.id` and `container.log.tag` is dropped because it
6969
otherwise no tag is added. {issue}42208[42208] {pull}42403[42403]
7070
- Fixed race conditions in the global ratelimit processor that could drop events or apply rate limiting incorrectly.
7171
- Fixed password authentication for ACL users in the Redis input of Filebeat. {pull}44137[44137]
72-
- Add experimental GZIP file ingestion in filestream. {pull}45301[45301]
72+
- Add beta GZIP file ingestion in filestream. {pull}45301[45301]
7373
-Change aws.cloudwatch.* field in awscloudwatch input to nested object. {pull}46357[46357]
7474
- Filestream's `clean_inactive` setting is now validated, if the validation fails, Filebeat exits with an error code. To keep the legacy behavior of not validating set `legacy_clean_inactive: true`. {issue}45601[45601]
7575
{pull}46373[46373]

docs/reference/filebeat/filebeat-input-filestream.md

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -26,7 +26,7 @@ Use the `filestream` input to read lines from log files. It is the improved alte
2626
* Only the most recent updates are serialized to the registry. In contrast, the `log` input has to serialize the complete registry on each ACK from the outputs. This makes the registry updates much quicker with this input.
2727
* The input ensures that only offsets updates are written to the registry append only log. The `log` writes the complete file state.
2828
* Stale entries can be removed from the registry, even if there is no active input.
29-
* {applies_to}`stack: preview 9.2.0` As a technical preview feature, it can read GZIP files.
29+
* {applies_to}`stack: beta 9.2.0` As a beta feature, it can read GZIP files.
3030

3131

3232
To configure this input, specify a list of glob-based [`paths`](#filestream-input-paths) that must be crawled to locate and fetch the log lines.
@@ -72,14 +72,14 @@ filebeat.inputs:
7272
## Reading GZIP files
7373

7474
```{applies_to}
75-
stack: preview 9.2.0
75+
stack: beta 9.2.0
7676
```
7777

7878
::::{warning}
79-
This functionality is in technical preview and may be changed or removed in a future release. Elastic will work to fix any issues, but features in technical preview are not subject to the support SLA of official GA features.
79+
This functionality is in beta and is subject to change. The design and code is less mature than official GA features and is being provided as-is with no warranties. Beta features are not subject to the support SLA of official GA features.
8080
::::
8181

82-
The `filestream` input can ingest GZIP files as a **technical preview** feature.
82+
The `filestream` input can ingest GZIP files as a **beta** feature.
8383
A GZIP file is treated like any other file, with the same guarantees `filestream`
8484
offers. This includes offset tracking and resuming from partially read files.
8585

filebeat/input/filestream/config.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -44,7 +44,7 @@ type config struct {
4444
FileWatcher fileWatcherConfig `config:"prospector.scanner"`
4545
FileIdentity *conf.Namespace `config:"file_identity"`
4646

47-
// GZIPExperimental enables tech-preview support for ingesting GZIP files.
47+
// GZIPExperimental enables beta support for ingesting GZIP files.
4848
// When set to true the input will transparently stream-decompress GZIP files.
4949
// This feature is experimental and subject to change.
5050
GZIPExperimental bool `config:"gzip_experimental"`
@@ -231,8 +231,8 @@ func (c config) checkUnsupportedParams(logger *logp.Logger) {
231231
"highly discouraged.")
232232
}
233233
if c.GZIPExperimental {
234-
logger.Named("filestream").Warn(cfgwarn.Experimental(
235-
"filestream: experimental gzip support enabled"))
234+
logger.Named("filestream").Warn(cfgwarn.Beta(
235+
"filestream: beta gzip support enabled"))
236236
}
237237
}
238238

filebeat/testing/integration/filestream_gzip_test.go

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -127,7 +127,7 @@ output.file:
127127
}
128128
})
129129

130-
t.Run("TechPreviewWarning", func(t *testing.T) {
130+
t.Run("BetaWarning", func(t *testing.T) {
131131
ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second)
132132
defer cancel()
133133

@@ -162,8 +162,9 @@ output.console:
162162
WithReportOptions(reportOptions).
163163
ExpectStart().
164164
ExpectOutput(
165-
"EXPERIMENTAL: filestream: experimental gzip support enabled").
166-
Start(ctx).Wait()
165+
"BETA: filestream: beta gzip support enabled").
166+
Start(ctx).
167+
Wait()
167168
})
168169
}
169170

0 commit comments

Comments
 (0)