Skip to content

Commit

Permalink
fix: documentation typos
Browse files Browse the repository at this point in the history
  • Loading branch information
lpcouto committed Feb 26, 2024
1 parent fcd2eda commit b4cade2
Show file tree
Hide file tree
Showing 5 changed files with 5 additions and 5 deletions.
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

0 comments on commit b4cade2

Please sign in to comment.