Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

fix: documentation typos #533

Merged
merged 1 commit into from
Feb 26, 2024
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion website/docs/getting-started/installation.md
Original file line number Diff line number Diff line change
Expand Up @@ -86,6 +86,6 @@ public void Configure(
}
```

Now you can create Message Handlers or access Producers and start exchanging events trouh Kafka.
Now you can create Message Handlers or access Producers and start exchanging events through Kafka.


2 changes: 1 addition & 1 deletion website/docs/guides/admin/web-api.md
Original file line number Diff line number Diff line change
Expand Up @@ -177,7 +177,7 @@ await consumerAdmin.RestartConsumerAsync(consumerName);
```

#### Reset Offsets
Reset the offset of all topics listening by the Kafka consumers with the name and groupId informed. To achieve this, KafkaFlow needs to stop the consumers, search for the lowest offset value in each topic/partition, commit these offsets, and restart the consumers. This operation causes a rebalance between the consumers. ** All topic messages will be reprocessed **
Reset the offset of all topics listening by the Kafka consumers with the name and groupId informed. To achieve this, KafkaFlow needs to stop the consumers, search for the lowest offset value in each topic/partition, commit these offsets, and restart the consumers. This operation causes a rebalance between the consumers. **All topic messages will be reprocessed**

Endpoint

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -39,7 +39,7 @@ Configuring Dynamic Worker Configuration is straightforward with the fluent inte
)
```

In this example, the number of worker threads is adjusted dynamically based on whether it's a peak hour or off-peak hour. You can implement your custom logic in the `WithWorkersCount`` method to suit your application's specific requirements.
In this example, the number of worker threads is adjusted dynamically based on whether it's a peak hour or off-peak hour. You can implement your custom logic in the `WithWorkersCount` method to suit your application's specific requirements.

That's it! Your KafkaFlow consumer will now dynamically adjust the number of worker threads based on your custom logic and the specified evaluation interval.

Expand Down
2 changes: 1 addition & 1 deletion website/docs/guides/middlewares/middlewares.md
Original file line number Diff line number Diff line change
Expand Up @@ -44,7 +44,7 @@ The message will be delivered as a byte array to the first middleware; you will

## When Producing

The middlewares are called when the `Produce` or `PoduceAsync` of the `IMessageProducer` is called. After all the middlewares execute, the message will be published to Kafka.
The middlewares are called when the `Produce` or `ProduceAsync` of the `IMessageProducer` is called. After all the middlewares execute, the message will be published to Kafka.

## Creating a middleware

Expand Down
2 changes: 1 addition & 1 deletion website/docs/guides/middlewares/serializer-middleware.md
Original file line number Diff line number Diff line change
Expand Up @@ -43,7 +43,7 @@ services.AddKafka(kafka => kafka
resolver => new JsonMessageSerializer(...),
resolver => new YourTypeResolver(...))
// or
.AddSingleTypeSerializer<JsonMessageSerializer, YourMessageType>()
.AddSingleTypeSerializer<YourMessageType, JsonMessageSerializer>()
// or
.AddSingleTypeSerializer<YourMessageType>(resolver => new JsonMessageSerializer(...))
...
Expand Down
Loading