来自https://micronaut-projects.github.io/micronaut-kafka/latest/guide/#kafkaStream ,我可以看到有一种简单的方法来运行运行 KStream 的应用程序。
如果我不想使用 KStream,但想使用具有拓扑模式的 KafkaStream API,这可以通过 Micronaut 实现吗?
最佳答案
是的,你当然可以。 Kafka 流是一个客户端库,您可以将其添加为依赖项并与应用程序打包在一起。它不取决于您如何部署它,您应该考虑实例/线程的数量,因为它与应用程序实例之间如何共享负载相关。
为了澄清混淆,Kafka Streams 是库名称,KStream 是您可以在应用程序中使用的类型,请检查以下链接以进行澄清。
https://kafka.apache.org/22/documentation/streams/core-concepts
关于java - 如何使用 Micronaut 运行 KafkaStream 应用程序?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/56248830/