Fix typos

urban-adeininger · mmatczuk · commit e1545204a3b4 · 2026-03-06T15:41:27.000+01:00
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -207,7 +207,7 @@ All notable changes to this project will be documented in this file.
 
 - `redpanda_migrator` output now supports two-way syncing using provenance headers (@mmatczuk)
 - `schema_registry_encode` gains a new `protobuf.serialize_to_json` option that is by default true. If disabled, then messages are decoded into a structured format which preserves types better and is faster. (@rockwotj)
-- Add `decode` option to field `operator` in `protobuf` processor that decodes messages into a structured format (as opposed to serializing to JSON) that perserves types better and is faster. (@rockwotj)
+- Add `decode` option to field `operator` in `protobuf` processor that decodes messages into a structured format (as opposed to serializing to JSON) that preserves types better and is faster. (@rockwotj)
 - `redpanda_migrator` output `schema_registry.interval` default value changed to `5m` enabling continuous schema migration by default. (@mmatczuk)
 - The `redpanda` and `redpanda_migrator` input and output `metadata_max_age` default value changed to `1m`. (@mmatczuk)
 
@@ -463,7 +463,7 @@ All notable changes to this project will be documented in this file.
 
 ### Changed
 
-- The way in which custom parameters for the experimental `mcp-server` subcommand are defined have changed. When defined they will now yield a JSON message to tool processors and outputs instead of complementary metadata keys, and there is no longer an implicit `value` field under these cirumstances. (@rockwotj)
+- The way in which custom parameters for the experimental `mcp-server` subcommand are defined have changed. When defined they will now yield a JSON message to tool processors and outputs instead of complementary metadata keys, and there is no longer an implicit `value` field under these circumstances. (@rockwotj)
 - The old deprecated `elasticsearch` output has been removed. This is not a change we would traditionally make without waiting for a major version increment. However, a dependency of the library used in this component is compromised and is now a significant security concern, which warrants the immediate removal. (@Jeffail)
 
 ## 4.54.1 - 2025-04-30
@@ -1121,7 +1121,7 @@ All notable changes to this project will be documented in this file.
 
 - Bloblang error messages for bad function/method names or parameters should now be improved in mappings that use shorthand for `root = ...`.
 - All redis components now support usernames within the configured URL for authentication.
-- The `protobuf` processor now supports targetting nested types from proto files.
+- The `protobuf` processor now supports targeting nested types from proto files.
 - The `schema_registry_encode` and `schema_registry_decode` processors should no longer double escape URL unsafe characters within subjects when querying their latest versions.
 
 ## 4.23.0 - 2023-10-30
@@ -1738,7 +1738,7 @@ This is a major version release, for more information and guidance on how to mig
 - The `dedupe` processor now acts upon individual messages by default, and the `hash` field has been removed.
 - The `log` processor now executes for each individual message of a batch.
 - The `sleep` processor now executes for each individual message of a batch.
-- The `benthos test` subcommand no longer walks when targetting a directory, instead use triple-dot syntax (`./dir/...`) or wildcard patterns.
+- The `benthos test` subcommand no longer walks when targeting a directory, instead use triple-dot syntax (`./dir/...`) or wildcard patterns.
 - Go API: Module name has changed to `github.com/benthosdev/benthos/v4`.
 - Go API: All packages within the `lib` directory have been removed in favour of the newer [APIs within `public`](https://pkg.go.dev/github.com/benthosdev/benthos/v4/public).
 - Go API: Distributed tracing is now via the Open Telemetry client library.
@@ -2212,7 +2212,7 @@ This is a major version release, for more information and guidance on how to mig
 
 ### Changed
 
-- Go API: Component implementations now require explicit import from `./public/components/all` in order to be invokable. This should be done automatically at all plugin and custom build entry points. If, however, you notice that your builds have begun complaining that known components do not exist then you will need to explicitly import the package with `_ "github.com/Jeffail/benthos/v3/public/components/all"`, if this is the case then please report it as an issue so that it can be dealt with.
+- Go API: Component implementations now require explicit import from `./public/components/all` in order to be invocable. This should be done automatically at all plugin and custom build entry points. If, however, you notice that your builds have begun complaining that known components do not exist then you will need to explicitly import the package with `_ "github.com/Jeffail/benthos/v3/public/components/all"`, if this is the case then please report it as an issue so that it can be dealt with.
 
 ## 3.42.1 - 2021-03-26
 
@@ -3205,7 +3205,7 @@ This is a major version release, for more information and guidance on how to mig
 
 ### Added
 
-- Go API: A new service method `RunWithOpts` has been added in order to accomodate service customisations with opt funcs.
+- Go API: A new service method `RunWithOpts` has been added in order to accommodate service customisations with opt funcs.
 
 ## 2.8.1 - 2019-06-28
 
diff --git a/config/rag/eval.yaml b/config/rag/eval.yaml
@@ -82,7 +82,7 @@ pipeline:
               root.ollama_pgvector = this.ollama_pgvector
             processors:
               - mapping: |
-                  # This computes the combination of all retrival results
+                  # This computes the combination of all retrieval results
                   let results = this.without("query").keys()
                   root.processed = []
                   root.unprocessed = range(0, $results.length()).fold([], i -> (
@@ -109,7 +109,7 @@ pipeline:
                           model: gemini-2.5-pro-preview-03-25
                           prompt: |
                             Below is a YAML document with 3 keys, one is a query from a user,
-                            and two other keys contain documents that were retrived based on
+                            and two other keys contain documents that were retrieved based on
                             the user's query. Please rate which set of documents are better
                             suited to give context to answer the user's question.
 
diff --git a/config/test/infile_resource_mock.yaml b/config/test/infile_resource_mock.yaml
@@ -5,7 +5,7 @@ pipeline:
 processor_resources:
   - label: http_submit
     http:
-      url: http://nonexistant.foo/
+      url: http://nonexistent.foo/
       verb: POST
 
 tests:
diff --git a/docs/modules/guides/pages/bloblang/methods.adoc b/docs/modules/guides/pages/bloblang/methods.adoc
@@ -3868,7 +3868,7 @@ The following algorithms require a key, which is specified as a second argument:
 
 ==== Parameters
 
-*`algorithm`* &lt;string&gt; The hasing algorithm to use.  
+*`algorithm`* &lt;string&gt; The hashing algorithm to use.  
 *`key`* &lt;(optional) string&gt; An optional key to use.  
 *`polynomial`* &lt;string, default `"IEEE"`&gt; An optional polynomial key to use when selecting the `crc32` algorithm, otherwise ignored. Options are `IEEE` (default), `Castagnoli` and `Koopman`  
 
diff --git a/internal/impl/couchbase/integration_test.go b/internal/impl/couchbase/integration_test.go
@@ -103,7 +103,7 @@ func setupCouchbase(tb testing.TB) (*dockertest.Pool, *dockertest.Resource, erro
 		return nil, nil, err
 	}
 
-	// Look for readyness
+	// Look for readiness
 	var stderr bytes.Buffer
 	time.Sleep(15 * time.Second)
 	for {
diff --git a/internal/impl/iceberg/writer.go b/internal/impl/iceberg/writer.go
@@ -120,7 +120,7 @@ func (w *writer) Write(ctx context.Context, batch service.MessageBatch) error {
 			int64(len(pf.result.data)),
 		)
 		if err != nil {
-			return fmt.Errorf("unable to create data file buider: %w", err)
+			return fmt.Errorf("unable to create data file builder: %w", err)
 		}
 
 		// Extract parquet statistics
diff --git a/internal/impl/jaeger/tracer_jaeger.go b/internal/impl/jaeger/tracer_jaeger.go
@@ -127,7 +127,7 @@ func NewJaeger(config jaegerConfig) (trace.TracerProvider, error) {
 		case "const":
 			sampler = tracesdk.TraceIDRatioBased(config.SamplerParam)
 		case "probabilistic":
-			return nil, errors.New("probabalistic sampling is no longer available")
+			return nil, errors.New("probabilistic sampling is no longer available")
 		case "ratelimiting":
 			return nil, errors.New("rate limited sampling is no longer available")
 		case "remote":
diff --git a/internal/impl/mongodb/cdc/integration_test.go b/internal/impl/mongodb/cdc/integration_test.go
@@ -540,7 +540,7 @@ mongodb_cdc:
 	output.NackAll()
 	// For some reason the stream's Run doesn't exit until the context is cancelled.
 	// I'm not sure why that doesn't work, but for this test we can just cancel and
-	// let the cancelation happen after the test is done.
+	// let the cancellation happen after the test is done.
 	//
 	// Ideally wait would return immediately after StopNow is called...
 	wait := stream.RunAsyncWithErrors(t)
diff --git a/internal/impl/mssqlserver/integration_test.go b/internal/impl/mssqlserver/integration_test.go
@@ -59,7 +59,7 @@ func TestIntegration_MicrosoftSQLServerCDC_SnapshotAndStreaming(t *testing.T) {
 			stream       *service.Stream
 			err          error
 		)
-		t.Log("Lauching component...")
+		t.Log("Launching component...")
 		{
 			cfg := `
 microsoft_sql_server_cdc:
@@ -157,7 +157,7 @@ microsoft_sql_server_cdc:
 			stream       *service.Stream
 			err          error
 		)
-		t.Log("Lauching component...")
+		t.Log("Launching component...")
 		{
 			cfg := `
 microsoft_sql_server_cdc:
@@ -263,7 +263,7 @@ func TestIntegration_MicrosoftSQLServerCDC_ConcurrentSnapshot(t *testing.T) {
 		stream       *service.Stream
 		err          error
 	)
-	t.Log("Lauching component...")
+	t.Log("Launching component...")
 	{
 		cfg := `
 microsoft_sql_server_cdc:
@@ -335,7 +335,7 @@ microsoft_sql_server_cdc:
 		outBatchesMu sync.Mutex
 	)
 
-	t.Log("Lauching component to stream initial data...")
+	t.Log("Launching component to stream initial data...")
 	{
 		require.NoError(t, streamBuilder.AddBatchConsumerFunc(func(_ context.Context, mb service.MessageBatch) error {
 			msgBytes, err := mb[0].AsBytes()
diff --git a/internal/impl/mssqlserver/replication/snapshot.go b/internal/impl/mssqlserver/replication/snapshot.go
@@ -69,7 +69,7 @@ func (s *Snapshot) Prepare(ctx context.Context) (LSN, error) {
 		return nil, err
 	} else if len(maxLSN) == 0 {
 		// rare, but possible if the user enabled CDC on a table seconds before running snapshot or the agent has stopped working for some reason
-		return nil, errors.New("unable to captue max_lsn, this can be due to reasons such as the log scanning agent has stopped")
+		return nil, errors.New("unable to capture max_lsn, this can be due to reasons such as the log scanning agent has stopped")
 	}
 
 	return maxLSN, nil
diff --git a/internal/impl/mssqlserver/replication/stream_message.go b/internal/impl/mssqlserver/replication/stream_message.go
@@ -39,7 +39,7 @@ func (lsn *LSN) Scan(src any) error {
 	}
 }
 
-// String formats the LSN to the hexidecimal equivalent.
+// String formats the LSN to the hexadecimal equivalent.
 func (lsn LSN) String() string {
 	if len(lsn) == 0 {
 		return ""
diff --git a/internal/impl/nats/auth.go b/internal/impl/nats/auth.go
@@ -74,7 +74,7 @@ func authFieldSpec() *service.ConfigField {
 			Secret().
 			Optional().
 			Version("4.38.0").
-			Example("UDXU4RCSJNZOIQHZNWXHXORDPRTGNJAHAHFRGZNEEJCPQTT2M7NLCNF4"), // don't worry, this sample seed is from Nats offical doc
+			Example("UDXU4RCSJNZOIQHZNWXHXORDPRTGNJAHAHFRGZNEEJCPQTT2M7NLCNF4"), // don't worry, this sample seed is from Nats official doc
 		service.NewStringField("user_credentials_file").
 			Description("An optional file containing user credentials which consist of an user JWT and corresponding NKey seed.").
 			Example("./user.creds").
diff --git a/internal/impl/postgresql/pglogicalstream/logical_stream.go b/internal/impl/postgresql/pglogicalstream/logical_stream.go
@@ -466,7 +466,7 @@ func (s *Stream) streamMessages(currentLSN LSN) error {
 			if err != nil {
 				return fmt.Errorf("decoding postgres changes failed: %w", err)
 			}
-			// See the explaination above about lastEmittedCommitLSN but if this is a commit message, we want to
+			// See the explanation above about lastEmittedCommitLSN but if this is a commit message, we want to
 			// only remap the commit of the last message in a transaction, so only update the remapped value if
 			// it was a suppressed commit, otherwise we just provide a noop mapping of commit LSN
 			switch result {
@@ -759,7 +759,7 @@ func (s *Stream) Messages() chan []StreamMessage {
 	return s.messages
 }
 
-// Errors is a channel that can be used to see if and error has occured internally and the stream should be restarted.
+// Errors is a channel that can be used to see if and error has occurred internally and the stream should be restarted.
 func (s *Stream) Errors() chan error {
 	return s.errors
 }
diff --git a/internal/impl/postgresql/pglogicalstream/pglogrepl.go b/internal/impl/postgresql/pglogicalstream/pglogrepl.go
@@ -377,7 +377,7 @@ func CreatePublication(ctx context.Context, conn *pgconn.PgConn, publicationName
 }
 
 // GetPublicationTables returns a list of tables currently in the publication
-// Arguments, in order: list of the tables, exist for all tables, errror.
+// Arguments, in order: list of the tables, exist for all tables, error.
 func GetPublicationTables(ctx context.Context, conn *pgconn.PgConn, publicationName string) ([]TableFQN, bool, error) {
 	query, err := sanitize.SQLQuery(`
 		SELECT DISTINCT
diff --git a/internal/impl/postgresql/pglogicalstream/types.go b/internal/impl/postgresql/pglogicalstream/types.go
@@ -18,7 +18,7 @@ type TableFQN struct {
 	Table  string
 }
 
-// String satifies the Stringer interface
+// String satisfies the Stringer interface
 func (t TableFQN) String() string {
 	return fmt.Sprintf("%s.%s", t.Schema, t.Table)
 }
diff --git a/internal/impl/qdrant/integration_test.go b/internal/impl/qdrant/integration_test.go
@@ -244,7 +244,7 @@ qdrant:
 		output = append(output, m)
 		return nil
 	})
-	require.NoError(t, err, "failed to create conusmer")
+	require.NoError(t, err, "failed to create consumer")
 	stream, err := builder.Build()
 	require.NoError(t, err, "failed to create stream")
 	streamCtx, cancel := context.WithCancel(ctx)
diff --git a/internal/impl/snowflake/streaming/api_errors.go b/internal/impl/snowflake/streaming/api_errors.go
@@ -21,7 +21,7 @@ type APIError struct {
 
 var _ error = &APIError{}
 
-// Error statisfies the Error interface.
+// Error satisfies the Error interface.
 func (e *APIError) Error() string {
 	msg := e.Message
 	if msg == "" {
diff --git a/internal/impl/snowflake/streaming/int128/int128.go b/internal/impl/snowflake/streaming/int128/int128.go
@@ -6,8 +6,8 @@
 //
 // https://github.com/redpanda-data/connect/blob/main/licenses/rcl.md
 
-// package int128 contains an implmentation of int128 that is more
-// efficent (no allocations) compared to math/big.Int
+// package int128 contains an implementation of int128 that is more
+// efficient (no allocations) compared to math/big.Int
 //
 // Several Snowflake data types are under the hood int128 (date/time),
 // so we can use this type and not hurt performance.
@@ -81,7 +81,7 @@ var (
 	}
 )
 
-// Num is a *signed* int128 type that is more efficent than big.Int
+// Num is a *signed* int128 type that is more efficient than big.Int
 //
 // Default value is 0
 type Num struct {
diff --git a/internal/impl/snowflake/streaming/streaming.go b/internal/impl/snowflake/streaming/streaming.go
@@ -583,7 +583,7 @@ func (c *SnowflakeIngestionChannel) InsertRows(ctx context.Context, batch servic
 	return insertStats, err
 }
 
-// IngestionFailedError is an error that occurs when registing a BDEC file with Snowflake.
+// IngestionFailedError is an error that occurs when registering a BDEC file with Snowflake.
 type IngestionFailedError struct {
 	DatabaseName, SchemaName, TableName string
 	ChannelName                         string
diff --git a/internal/impl/snowflake/streaming/userdata_converter_test.go b/internal/impl/snowflake/streaming/userdata_converter_test.go
@@ -505,7 +505,7 @@ func TestTimestampLTZConverter(t *testing.T) {
 			input:     "2013-04-28T20:57:00Z",
 			err:       true,
 			scale:     0,
-			precision: 9, // Mor precision needed
+			precision: 9, // More precision needed
 		},
 	}
 	for _, tc := range tests {
diff --git a/internal/impl/timeplus/http/sse_lib.go b/internal/impl/timeplus/http/sse_lib.go
@@ -79,7 +79,7 @@ func containsDoubleNewline(data []byte) (int, int) {
 	crlfcrlf := bytes.Index(data, []byte("\r\n\r\n"))
 	// Find the earliest position of a double newline combination
 	minPos := minPosInt(crcr, minPosInt(lflf, minPosInt(crlflf, minPosInt(lfcrlf, crlfcrlf))))
-	// Detemine the length of the sequence
+	// Determine the length of the sequence
 	nlen := 2
 	switch minPos {
 	case crlfcrlf:
diff --git a/internal/mcp/mcp.go b/internal/mcp/mcp.go
@@ -48,7 +48,7 @@ func (g *gMux) HandleFunc(pattern string, handler func(http.ResponseWriter, *htt
 	g.m.Path(pattern).HandlerFunc(handler) // TODO: PathPrefix?
 }
 
-// Server runs an mcp server against a target directory, with an optiona base
+// Server runs an mcp server against a target directory, with an optional base
 // URL for an HTTP server.
 type Server struct {
 	base             *mcp.Server
diff --git a/internal/rpcplugin/runtimepb/message.pb.go b/internal/rpcplugin/runtimepb/message.pb.go
diff --git a/internal/template/template.go b/internal/template/template.go
@@ -52,7 +52,7 @@ func WithRenames(renames map[string]string) Options {
 	}
 }
 
-// CreateTemplate generates the embeded filesystem to the output directory replacing variables found in vars.
+// CreateTemplate generates the embedded filesystem to the output directory replacing variables found in vars.
 func CreateTemplate(tfs fs.ReadFileFS, outputDir string, options ...Options) error {
 	o := opts{
 		root:      ".",
diff --git a/public/plugin/go/rpcn/rpcn.go b/public/plugin/go/rpcn/rpcn.go
@@ -17,7 +17,7 @@
 package rpcn
 
 // !!! NOTE !!!
-// If you're looking at the source of this package to reimplment it for your language then please open
+// If you're looking at the source of this package to reimplement it for your language then please open
 // an issue at github.com/redpanda-data/connect and let us know. We would love to help you out, and it's
 // likely we're going to move quickly here and change versions and you're going to be way better off
 // working with us instead of trying to keep up with changes here. And if you're willing to write an SDK

Original file line number	Diff line number	Diff line change
`@@ -103,7 +103,7 @@ func setupCouchbase(tb testing.TB) (dockertest.Pool, dockertest.Resource, erro`
`103`	`103`	`return nil, nil, err`
`104`	`104`	`}`
`105`	`105`
`106`		`- // Look for readyness`
	`106`	`+ // Look for readiness`
`107`	`107`	`var stderr bytes.Buffer`
`108`	`108`	`time.Sleep(15 * time.Second)`
`109`	`109`	`for {`
Original file line number	Diff line number	Diff line change
`@@ -120,7 +120,7 @@ func (w *writer) Write(ctx context.Context, batch service.MessageBatch) error {`
`120`	`120`	`int64(len(pf.result.data)),`
`121`	`121`	`)`
`122`	`122`	`if err != nil {`
`123`		`- return fmt.Errorf("unable to create data file buider: %w", err)`
	`123`	`+ return fmt.Errorf("unable to create data file builder: %w", err)`
`124`	`124`	`}`
`125`	`125`
`126`	`126`	`// Extract parquet statistics`
Original file line number	Diff line number	Diff line change
`@@ -59,7 +59,7 @@ func TestIntegration_MicrosoftSQLServerCDC_SnapshotAndStreaming(t *testing.T) {`
`59`	`59`	`stream *service.Stream`
`60`	`60`	`err error`
`61`	`61`	`)`
`62`		`- t.Log("Lauching component...")`
	`62`	`+ t.Log("Launching component...")`
`63`	`63`	`{`
`64`	`64`	cfg := `
`65`	`65`	`microsoft_sql_server_cdc:`
`@@ -157,7 +157,7 @@ microsoft_sql_server_cdc:`
`157`	`157`	`stream *service.Stream`
`158`	`158`	`err error`
`159`	`159`	`)`
`160`		`- t.Log("Lauching component...")`
	`160`	`+ t.Log("Launching component...")`
`161`	`161`	`{`
`162`	`162`	cfg := `
`163`	`163`	`microsoft_sql_server_cdc:`
`@@ -263,7 +263,7 @@ func TestIntegration_MicrosoftSQLServerCDC_ConcurrentSnapshot(t *testing.T) {`
`263`	`263`	`stream *service.Stream`
`264`	`264`	`err error`
`265`	`265`	`)`
`266`		`- t.Log("Lauching component...")`
	`266`	`+ t.Log("Launching component...")`
`267`	`267`	`{`
`268`	`268`	cfg := `
`269`	`269`	`microsoft_sql_server_cdc:`
`@@ -335,7 +335,7 @@ microsoft_sql_server_cdc:`
`335`	`335`	`outBatchesMu sync.Mutex`
`336`	`336`	`)`
`337`	`337`
`338`		`- t.Log("Lauching component to stream initial data...")`
	`338`	`+ t.Log("Launching component to stream initial data...")`
`339`	`339`	`{`
`340`	`340`	`require.NoError(t, streamBuilder.AddBatchConsumerFunc(func(_ context.Context, mb service.MessageBatch) error {`
`341`	`341`	`msgBytes, err := mb[0].AsBytes()`
Original file line number	Diff line number	Diff line change
`@@ -69,7 +69,7 @@ func (s *Snapshot) Prepare(ctx context.Context) (LSN, error) {`
`69`	`69`	`return nil, err`
`70`	`70`	`} else if len(maxLSN) == 0 {`
`71`	`71`	`// rare, but possible if the user enabled CDC on a table seconds before running snapshot or the agent has stopped working for some reason`
`72`		`- return nil, errors.New("unable to captue max_lsn, this can be due to reasons such as the log scanning agent has stopped")`
	`72`	`+ return nil, errors.New("unable to capture max_lsn, this can be due to reasons such as the log scanning agent has stopped")`
`73`	`73`	`}`
`74`	`74`
`75`	`75`	`return maxLSN, nil`