为了比较使用rocksdb或内存的spring云流应用程序（与kafka）的性能，我想将rocksdb改为内存。不幸的是我找不到任何解决办法。我已经找到了dsl api和处理器api的解决方案(https://simplydistributed.wordpress.com/2017/03/21/kafka-streams-state-stores/)，但我不确定它是否适用于Kafka流活页夹。有人能帮我解决这个问题吗？
向马丁问好
为了比较使用rocksdb或内存的spring云流应用程序（与kafka）的性能，我想将rocksdb改为内存。不幸的是我找不到任何解决办法。我已经找到了dsl api和处理器api的解决方案(https://simplydistributed.wordpress.com/2017/03/21/kafka-streams-state-stores/)，但我不确定它是否适用于Kafka流活页夹。有人能帮我解决这个问题吗？
向马丁问好
1条答案
按热度按时间epfja78i1#
spring cloud stream kafka streams binder不直接与rocksdb交互以执行任何状态存储操作。它甚至不知道它正在和rocksdb通信。所有通信都是通过kafka流api和抽象实现的。因此，您可以按照文档的建议将自定义状态存储与kafka流一起使用，绑定器将继续工作。看看它是否有效，请让我们知道如果你发现任何问题。