Skip to content

Commit

Permalink
docs: tiny fix
Browse files Browse the repository at this point in the history
  • Loading branch information
alebabai committed Feb 21, 2024
1 parent 978e76d commit 424ce13
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
2 changes: 1 addition & 1 deletion handler.go
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@ import (
"context"
)

// Handler is an interface for processing Kafka messages.
// Handler is an interface for processing Apache Kafka messages.
type Handler interface {
Handle(ctx context.Context, msg Message) error
}
Expand Down
2 changes: 1 addition & 1 deletion router.go
Original file line number Diff line number Diff line change
Expand Up @@ -33,7 +33,7 @@ func (fn RouterFunc) Handle(ctx context.Context, msg Message) error {
// StaticRouterByTopic routes messages to handlers based on the topic.
type StaticRouterByTopic map[string]Handler

// Route resolves a [Handler] based on the message's topic.
// Route resolves a [Handler] based on the topic of the [Message].
func (r StaticRouterByTopic) Route(_ context.Context, msg Message) (Handler, error) {
h, ok := r[msg.Topic]
if !ok {
Expand Down

0 comments on commit 424ce13

Please sign in to comment.