上传者: 42099814
|
上传时间: 2021-10-26 18:46:26
|
文件大小: 1.15MB
|
文件类型: -
卡夫卡
Playframework - 简单的 Kafka 示例
这个例子使用
Scala 2.11.1
游戏框架 2.3.8
卡夫卡 2.11_0.8.2.1
引导程序 3.3.2
AngularJS 1.2.18
关于
应用程序的作用:
按钮 (PUT /tick) 捕获当前服务器时间戳
时间戳被格式化为一个 json 块
json 生成到 kafka 主题
json 从 kafka topic 消费,广播到 iteratee chanel
UI 显示来自 kafka 主题 (GET /feed/tick) 的消费时间戳的提要
截屏
卡夫卡设置
此应用程序依赖于 kafka 的运行实例
服务器设置和主题名称从 application.conf 中提取
您可以使用您选择的任何 Kafka 服务器设置。
最简单的方法是遵循
bin/zookeeper-server-start