akka-kafka-processor:Akka 集群与 kafka 流一起工作

自动扩展 (AWS) 集群以处理来自 kafka 集群的主题： 工作项目...... 主要职责： 验证新主题 注册新工人（节点） 向工作人员询问负载、内存使用情况和网络 使用节点信息决定向何处发送新作业 工人主管 保存kafka提供的数据如何分区的配置。 例如，如果消息有一个日期字段，它可以按小时或按目录分区（如 /date/client/product）划分消息 休息 api 以配置主题。 例如：（MaxMessageInFlight，如何分区） 动态更改配置，停止工作程序，并从偏移量开始新配置 应该通知集群是否在大量使用 如果需要，显示启动新实例。 如果可以，应该关闭实例 应该能够为特定主题注册一个工作人员（例如，如果某个主题已经发送到 s3，我们应该能够注册一个节点并请求相同的主题，以便工作人员可以将其保存在 cassandra 上） master 应该能够从崩溃中恢复 在