来自https://micronaut-projects.github.io/micronaut-kafka/latest/guide/wguide/#kafkastream,我可以看到有一种运行kstream kstream的简单方法。
如果我不想使用kStream,但是想使用具有拓扑模式的kafkastream api,这是可以用micronaut实现的吗?
是的,您肯定可以。Kafka Streams是客户库,您将其添加为依赖关系,并将其与您的应用程序一起添加。它不取决于您如何部署它,您应该考虑与应用程序实例之间如何共享负载相关的实例/线程的数量/线程。
,为了澄清混乱,kafka流是库名称,kStream是您可以在应用程序中使用的类型,请检查以下链接以澄清。
https://kafka.apache.org/22/documentation/streams/core-concepts
https://docs.confluent.io/current/current/streams/javadocs/index.html?org/apache/kafkace/kafka/kafka/streams/kstreams/kstreams/package-summary.htmar.html