java - 如何使用 Micronaut 运行 KafkaStream 应用程序?

标签 java apache-kafka apache-kafka-streams micronaut

来自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

https://docs.confluent.io/current/streams/javadocs/index.html?org/apache/kafka/streams/kstream/package-summary.html

关于java - 如何使用 Micronaut 运行 KafkaStream 应用程序?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/56248830/

相关文章:

java - 读取包含输入值的文件并使用结果生成 .out

java - 了解创建的 StreamProcessor 实例数以及流任务是否共享同一个流处理器实例?

apache-kafka - Kafka Connect 错误 : com. aerospike.connect.inbound.aerospike.exception.ConvertToAerospikeException:记录中缺少用户 key

java - Zookeeper 不适用于 32 位 Windows 上安装的 JRE

node.js - 发送到当前已关闭的 NodeRed 输出 Node 的数据会发生什么情况?

apache-kafka - 水平扩展kafka节点时保证快速数据处理

apache-kafka - 如何最小化 Kafka Streams 应用程序中的延迟?

java - 如何给JMenu Screen添加背景图片?

java - 具有个体截止时间的任务调度算法

java - Spring boot,如何从json文件读取特定对象,我需要什么注释?