diff --git a/clients/bigquery/storagewrite.go b/clients/bigquery/storagewrite.go
index af27f1236..ffba7df79 100644
--- a/clients/bigquery/storagewrite.go
+++ b/clients/bigquery/storagewrite.go
@@ -21,7 +21,7 @@ import (
 	"google.golang.org/protobuf/types/known/timestamppb"
 )
 
-// columnToTableFieldSchema returns a [*storagepb.TableFieldSchema] suitable for transfering data of the type that the column specifies.
+// columnToTableFieldSchema returns a [*storagepb.TableFieldSchema] suitable for transferring data of the type that the column specifies.
 // Not that the data type is not necessarily the data type that the table in the database is using.
 func columnToTableFieldSchema(column columns.Column) (*storagepb.TableFieldSchema, error) {
 	var fieldType storagepb.TableFieldSchema_Type
@@ -150,7 +150,7 @@ func rowToMessage(row map[string]any, columns []columns.Column, messageDescripto
 				}
 				message.Set(field, protoreflect.ValueOfFloat64(floatValue))
 			default:
-				return nil, fmt.Errorf("expected float32/float64/int32/int64/string recieved %T with value %v", value, value)
+				return nil, fmt.Errorf("expected float32/float64/int32/int64/string received %T with value %v", value, value)
 			}
 		case typing.EDecimal.Kind:
 			if decimalValue, ok := value.(*decimal.Decimal); ok {
diff --git a/clients/mssql/dialect/dialect.go b/clients/mssql/dialect/dialect.go
index a34787bee..5f71bbdb9 100644
--- a/clients/mssql/dialect/dialect.go
+++ b/clients/mssql/dialect/dialect.go
@@ -149,7 +149,7 @@ func (MSSQLDialect) IsTableDoesNotExistErr(err error) bool {
 }
 
 func (MSSQLDialect) BuildCreateTableQuery(tableID sql.TableIdentifier, _ bool, colSQLParts []string) string {
-	// Microsoft SQL Server uses the same syntax for temporary and permanant tables.
+	// Microsoft SQL Server uses the same syntax for temporary and permanent tables.
 	// Microsoft SQL Server doesn't support IF NOT EXISTS
 	return fmt.Sprintf("CREATE TABLE %s (%s);", tableID.FullyQualifiedName(), strings.Join(colSQLParts, ","))
 }
diff --git a/clients/redshift/dialect/dialect.go b/clients/redshift/dialect/dialect.go
index 29ae4e00f..5c99da741 100644
--- a/clients/redshift/dialect/dialect.go
+++ b/clients/redshift/dialect/dialect.go
@@ -117,7 +117,7 @@ func (RedshiftDialect) IsTableDoesNotExistErr(err error) bool {
 }
 
 func (RedshiftDialect) BuildCreateTableQuery(tableID sql.TableIdentifier, _ bool, colSQLParts []string) string {
-	// Redshift uses the same syntax for temporary and permanant tables.
+	// Redshift uses the same syntax for temporary and permanent tables.
 	return fmt.Sprintf("CREATE TABLE IF NOT EXISTS %s (%s);", tableID.FullyQualifiedName(), strings.Join(colSQLParts, ","))
 }
 
diff --git a/lib/config/constants/constants.go b/lib/config/constants/constants.go
index 835e22857..b626a0458 100644
--- a/lib/config/constants/constants.go
+++ b/lib/config/constants/constants.go
@@ -8,7 +8,7 @@ const (
 	ToastUnavailableValuePlaceholder = "__debezium_unavailable_value"
 
 	// DebeziumTopicRoutingKey - https://debezium.io/documentation/reference/stable/transformations/topic-routing.html#by-logical-table-router-key-field-name
-	// This key is added to ensure no compaction or mutation happens since multiple tables are now going into the same topic and may have overlaping key ids.
+	// This key is added to ensure no compaction or mutation happens since multiple tables are now going into the same topic and may have overlapping key ids.
 	// We will strip this out from our partition key parsing.
 	DebeziumTopicRoutingKey = "__dbz__physicalTableIdentifier"