node.js - 更改 aws kcl 的故障转移时间

标签 node.js amazon-kinesis failover terraform-provider-aws amazon-kcl

如果应用程序出现连接问题,AWS 建议增加 KCL (kinesis) 的故障转移时间。 https://docs.aws.amazon.com/streams/latest/dev/troubleshooting-consumers.html

但我找不到如何更改故障转移时间。

我正在寻找(一个或全部):

  • AWS 控制台中的设置

  • node.js kcl 包的设置

  • Terraform 设置

最佳答案

故障转移时间是 Kinesis Client Library 的一个配置选项。它不是流上的属性。因此,您无法在 AWS 控制台中更改它。

使用属性文件配置适用于 Node.js 的 AWS Kinesis 客户端库。我假设您已经有一个属性文件,否则您将无法启动您的消费者应用程序。您需要做的是将其添加到您的属性文件中:

# Fail over time in milliseconds.
failoverTimeMillis = 10000

请参阅库提供的示例属性文件: https://github.com/awslabs/amazon-kinesis-client-nodejs/blob/master/samples/basic_sample/consumer/sample.properties#L38

另请参阅此文档以了解有关如何更改属性文件的更多详细信息: https://docs.aws.amazon.com/streams/latest/dev/kinesis-record-processor-implementation-app-nodejs.html#kinesis-record-processor-initialization-nodejs

关于node.js - 更改 aws kcl 的故障转移时间,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/57382813/

相关文章:

mysql - Sequelize 在收到 SequelizeDatabaseError : ER_LOCK_DEADLOCK 后正在创建悬空/挂起的 mysql 连接

amazon-web-services - Kinesis Firehose 是 Kinesis Streams 的替代品吗?

node.js - 使用 Typescript 向 expressjs 中的 req 对象添加属性

node.js - 使用 Node js 从打印机扫描

java - 使用大量连接时 Kinesis 出现错误

amazon-s3 - 带Lambda的Amazon Step Function从Kinesis触发

postgresql - 同一数据库上的两个主实例

apache-spark - 如何配置 alb 在故障转移后指向新的主实例 (EMR)

java - 为什么 Spring Integration 故障转移不显示异常

node.js - 使用 Google App Engine 对私有(private)模块进行 NPM 身份验证