主页 / coding / 问题 / 79200458
Accepted
Shuffling2241
Asked: 2024-11-18 23:10:00 +0800 CST

使用 KinesisMessageDrivenChannelAdapter 平衡消费者

  • 772

目前如何KinesisMessageDrivenChannelAdapter处理多个实例之间的平衡？我希望当我启动另一个实例进行扩展时，碎片分布得比较均匀。

我找到了这张旧票https://github.com/spring-projects/spring-integration-aws/issues/99。 似乎没有重新平衡。

感谢您的意见！

spring-integration

1 个回答

  1. Best Answer

    AWS Kinesis 中没有消费者组管理，而且从此KinesisMessageDrivenChannelAdapter客户端很难实现这一点。我们需要其他一些独立的应用程序来协调该行为。这已经超出了spring-integration-aws范围。

    目前它的工作原理是：先进先出。因此，确实可能存在所有分片都被单个实例占用的情况。

    • 0

相关问题