使用Kafka流分析加密交易所的实时交易活动
在2019年伦敦卡夫卡峰会上，Ludvig Sandman，产品工程高级副总裁和Bruce Zulu，销售工程主管Panopticon Streaming Analytics发表了一篇论文:
像Coinbase、Binance和Kraken这样的加密货币交易所让投资者可以购买、出售和交易加密货币，包括比特币、莱特币、以太坊等。根据交易所的不同，交易可以使用法定货币(法定政府货币，如美元或欧元)或其他加密货币。大多数交易所还允许投资者用一种加密货币购买另一种加密货币(例如，通过以太坊购买比特币)。鉴于加密货币估值的高速度和高波动性，监测和分析交易活动和交易算法的性能是令人生畏的。Kafka Streams提供了一个完美的基础设施，以非常高的时间准确性支持对市场和参与者行为的可见性，这在交易这种不稳定的工具时是至关重要的。
特别是，加密货币交易员需要几种方式来可视化交易活动，并重建和全面查看他们的订单簿。他们需要能够进行大量复杂实时计算的工具，包括:
- 最佳出价和报价
- 投标和报价的累积规模
- 扩散到中位数
- 价格事件之间的delta
- 时间加权平均值
- 消息费率(新，取消，交易，替换)
- 累计贸易流
所有的计算必须在交易日内实时地对多个法定货币和加密货币进行。交易员必须对每个订单的所有方面都有可视性，直到执行为止。新的工具利用了Kafka Streams的强大功能，使交易员自己能够在屏幕上构建有向图，而无需编写任何代码。有向图控制加密货币交易数据的数据流、计算和统计分析，并可将其输出到屏幕上，用于实时数据的深度监控和分析，以及存储在内存时间序列数据库中的历史交易数据。本文描述了构建和部署Kafka流以支持加密货币交易的实用方法。
点击这里观看他们的演示视频:https://www.confluent.io/kafka-summit-lon19/using-kafka-streams-analyze-trading-crypto-exchanges
