JoeShi / kafka-realtime-data-processing

MIT License
0 stars 2 forks source link

程序测试 #11

Closed JoeShi closed 5 years ago

JoeShi commented 5 years ago
  1. 增加 Kinesis shard 数量到 4
  2. datagen 产生的模拟数据速率增大到 200条/s
  3. 将时间范围缩小到48个小时内,1573657982 to 1573830782
  4. Spark Streaming 落盘时间调整为 1 min