This file contains hidden or 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
| package main | |
| /* | |
| This simple chat program illustrates a horizontally scaled, master-client architecture chat server that uses kafka as a distributed pub-sub system | |
| Each server has: | |
| - one kafka consumer group by port | |
| - a map of connected clients (state maintained by the server whenever clients connect and disconnect) | |
| - one kakfa producer |