为了进行基准测试，我必须模拟一个在线数据流（时间序列数据），由各种数据库接收。
在这个特定的用例中，时间序列数据应该以非常高的频率记录。
我会用apachekafka处理这个流。
流本质上是由许多实值数字组成的，带有它们的时间戳和文本标签。
我见过许多kafka生产者的例子，但是没有一个能很好地适合我的用例：我如何使用kafka来生成和处理这样的数据流？？
编辑：
使用pythonapi，我现在能够直接将数据发送到各种数据库。剩下的问题是速度：我的目标频率接近15khz。
使用相同的（多线程）python脚本，我几乎不能达到2khz。
有什么建议吗？