diff --git a/_examples/basic/1-your-first-app/README.md b/_examples/basic/1-your-first-app/README.md
index 770f5b5e8..44249a061 100644
--- a/_examples/basic/1-your-first-app/README.md
+++ b/_examples/basic/1-your-first-app/README.md
@@ -35,7 +35,7 @@ server_1     | 2019/08/29 19:41:28 received event {ID:8}
 server_1     | 2019/08/29 19:41:29 received event {ID:9}
 ```
 
-Open another termial and take a look at Kafka topics to see that all messages are there. The initial events should be present on the `events` topic:
+Open another terminal and take a look at Kafka topics to see that all messages are there. The initial events should be present on the `events` topic:
 
 ```bash
 > docker-compose exec kafka kafka-console-consumer --bootstrap-server localhost:9092 --topic events
diff --git a/dev/coverage.sh b/dev/coverage.sh
index 8a921430d..ca7b71b1c 100755
--- a/dev/coverage.sh
+++ b/dev/coverage.sh
@@ -1,7 +1,7 @@
 #!/bin/sh
 ########
 # Source: https://gist.github.com/lwolf/3764a3b6cd08387e80aa6ca3b9534b8a
-# originaly from https://github.com/mlafeldt/chef-runner/blob/v0.7.0/script/coverage
+# originally from https://github.com/mlafeldt/chef-runner/blob/v0.7.0/script/coverage
 #######
 # Generate test coverage statistics for Go packages.
 #
diff --git a/docs/layouts/shortcodes/render-md.html b/docs/layouts/shortcodes/render-md.html
index 825c3f939..98b6e9e84 100644
--- a/docs/layouts/shortcodes/render-md.html
+++ b/docs/layouts/shortcodes/render-md.html
@@ -6,6 +6,6 @@
 {{% load-snippet-partial (...) %}}
 {{% /render-md %}}
 
-bacause it is rendered as raw text by default
+because it is rendered as raw text by default
 */}}
 {{.Inner}}
\ No newline at end of file
diff --git a/message/router.go b/message/router.go
index c0808bb04..b460970e7 100644
--- a/message/router.go
+++ b/message/router.go
@@ -716,7 +716,7 @@ func (r *Router) decorateHandlerSubscriber(h *handler) error {
 	return nil
 }
 
-// addHandlerContext enriches the contex with values that are relevant within this handler's context.
+// addHandlerContext enriches the context with values that are relevant within this handler's context.
 func (h *handler) addHandlerContext(messages ...*Message) {
 	for i, msg := range messages {
 		ctx := msg.Context()
diff --git a/message/router/middleware/deduplicator.go b/message/router/middleware/deduplicator.go
index 26ad1bb59..de45bd9f1 100644
--- a/message/router/middleware/deduplicator.go
+++ b/message/router/middleware/deduplicator.go
@@ -21,7 +21,7 @@ import (
 const MessageHasherReadLimitMinimum = 64
 
 // ExpiringKeyRepository is a state container for checking the
-// existance of a key in a certain time window.
+// existence of a key in a certain time window.
 // All operations must be safe for concurrent use.
 type ExpiringKeyRepository interface {
 	// IsDuplicate returns `true` if the key
diff --git a/message/subscriber/read.go b/message/subscriber/read.go
index 11d04a48b..9d0555fba 100644
--- a/message/subscriber/read.go
+++ b/message/subscriber/read.go
@@ -6,7 +6,7 @@ import (
 	"github.com/ThreeDotsLabs/watermill/message"
 )
 
-// BulkRead reads provided amount of messages from the provided channel, until a timeout occurrs or the limit is reached.
+// BulkRead reads provided amount of messages from the provided channel, until a timeout occurs or the limit is reached.
 func BulkRead(messagesCh <-chan *message.Message, limit int, timeout time.Duration) (receivedMessages message.Messages, all bool) {
 MessagesLoop:
 	for len(receivedMessages) < limit {
@@ -27,7 +27,7 @@ MessagesLoop:
 }
 
 // BulkReadWithDeduplication reads provided number of messages from the provided channel, ignoring duplicates,
-// until a timeout occurrs or the limit is reached.
+// until a timeout occurs or the limit is reached.
 func BulkReadWithDeduplication(messagesCh <-chan *message.Message, limit int, timeout time.Duration) (receivedMessages message.Messages, all bool) {
 	receivedIDs := map[string]struct{}{}
 
diff --git a/slog.go b/slog.go
index 75d98095a..a7f887766 100644
--- a/slog.go
+++ b/slog.go
@@ -42,7 +42,7 @@ func (s *SlogLoggerAdapter) Debug(msg string, fields LogFields) {
 func (s *SlogLoggerAdapter) Trace(msg string, fields LogFields) {
 	s.slog.Log(
 		// Void context, following the slog example
-		// as it treats context slighly differently from
+		// as it treats context slightly differently from
 		// normal usage, minding contextual
 		// values, but ignoring contextual deadline.
 		// See the [slog] package documentation