如何解决在 micronaut 中创建自己的 kafka 工作线程
我正在开发一个应用程序,它从数据库事务日志处理 kafka 中的 CDC 记录,并使用它们来创建新的 kafka 事件。这将涉及主题/分区偏移量的重大移动,以及对各种事件结构(avro 记录)的 kafka 事务支持,因此我选择直接使用 KafkaConsumer
和 KafkaProducer
API,而不是 micronaut 的内置 kafka 框架。
在 micronaut 中创建长期工作线程(应用程序长度)的最佳方法是什么? @Async @EventListener
处理 ServiceReadyEvent
是一个可行的选择吗? Micronaut 在幕后使用 Netty;我会更好地尝试利用它吗?如果是这样,如何?
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。