我要开始讨论了https://disqus.com like Spring启动应用程序。
用户可以创建圆（社区/组）
用户可以订阅/取消订阅圈子。
用户可以将文档/图像/视频发布到圆形或单个用户
每个用户都有一个收件箱提要
为具有高可扩展性需求的高用户活动而设计，我将关闭以kafka为 Backbone.js 的活动流（w3c activity stream 2.0）。
我已经建立了一个分布式云本地微服务架构（spring配置服务器、api网关、eureka发现）和angular2.0前端。
我正在研究Kafka，想听听你对我应该如何进行建筑和设计，以满足我的要求的看法。
具体来说：
kafka生产者负责将通过http发送的活动转换为基于activity2.0规范的pojo，并将其发布到kafka。我应该如何设计发布服务器来处理，比如说每秒一百万条消息。
消费者是不同的服务，如圈子服务、推荐服务、用户服务等。我天真的想法是让这些服务订阅一个主题，然后只提取他们感兴趣的消息。例如，如果一个用户发布到一个圈子，圈子服务将使用它来复制并分发给该圈子的所有用户。另一个问题。如果一个圆包含1000个用户，那么制作拷贝的最佳方法是什么？
提前谢谢。