-
Notifications
You must be signed in to change notification settings - Fork 414
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Update consumer groups example (#352)
- Loading branch information
Showing
4 changed files
with
30 additions
and
2 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -1,9 +1,35 @@ | ||
# Consumer Groups Example | ||
# Interactive Consumer Groups Example (Routing Events) | ||
|
||
This example shows how Customer Groups work, i.e. how to decide which handlers receive which events. | ||
|
||
Consumer Group is a concept used in Apache Kafka®, but many other Pub/Subs use a similar mechanism. | ||
|
||
The example uses Watermill and Redis Streams Pub/Sub, but the same idea applies to other Pub/Subs as well. | ||
|
||
## Live video | ||
|
||
This example was showcased on the Watermill v1.2 Launch Event. You can see the [recording on YouTube](https://www.youtube.com/live/wjnd0Hj6CaM?t=1020) (starts at 17:00). | ||
|
||
[![Live Recording](https://img.youtube.com/vi/wjnd0Hj6CaM/0.jpg)](https://www.youtube.com/live/wjnd0Hj6CaM?t=1020) | ||
|
||
## Running | ||
|
||
``` | ||
docker-compose up | ||
``` | ||
|
||
Then visit [localhost:8080](http://localhost:8080). | ||
Then visit [localhost:8080](http://localhost:8080) and check the examples in each tab. | ||
|
||
## Screenshots | ||
|
||
![](docs/screen2.png) | ||
|
||
![](docs/screen1.png) | ||
|
||
## Code | ||
|
||
See [crm-service](crm-service) and [newsletter-service](newsletter-service) for the Watermill handlers setup. | ||
|
||
## How does it work? | ||
|
||
This example uses SSE for pushing events to the frontend UI. See the [other example on SEE](../server-sent-events) for more details. |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Loading
Sorry, something went wrong. Reload?
Sorry, we cannot display this file.
Sorry, this file is invalid so it cannot be displayed.
Loading
Sorry, something went wrong. Reload?
Sorry, we cannot display this file.
Sorry, this file is invalid so it cannot be displayed.