如果应用程序存在连接问题,AWS建议增加KCL(kinesis)的故障切换时间。https://docs.aws.amazon.com/streams/latest/dev/troubleshooting-consumers.html
但我找不到如何更改故障切换时间。
我正在寻找(一个或全部):
>
node.jskcl包的设置
地形设置
故障转移时间是Kinesis客户端库的配置选项。它不是流中的属性。因此,您无法在AWS控制台中更改它。
为节点配置AWS Kinesis客户端库。js是使用属性文件完成的。我假设您已经有了一个属性文件,否则您将无法启动您的消费者应用程序。您需要做的是将其添加到属性文件中:
# 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-记录处理器初始化节点JS
我想知道是否可以在Kafka制作程序中配置2个不同的Kafka集群。 目前我正试图让我的制片人 我正在使用Apache Kafka 2.8和Python 3.7的confluent_kafka==1.8.2包。 生产商代码下方: 当我杀死clusterB时,我得到了以下错误消息。
我正在尝试将OSS Ehcache与兵马俑集群一起使用,但未能从ehcache客户端实现故障转移。 我在这里的文档中找到了这种配置 但是这个连接只接受一个URL。如果集群中有两台terracotta服务器,我希望HA具有故障转移功能。类似ActiveMQ故障转移url: 我的问题是:这在开源ehcache中是可能的,还是我需要有企业版本,如果可能的话,如何配置它。 更新 我试过<代码> 如果我尝试
跟随wiki页面https://cwiki.apache.org/qpid/amqp-java-jms-messaging-client.html到https://cwiki.apache.org/qpid/connection-url-format.html. Simple me需要qpid-amqp-1-0-client-jms-0.20-sources。jar接受URI格式,但它似乎忽视了一
我尝试使用故障切换URI连接到Qpid JMS 0.48.0客户端和启用SSL的RabbitMQ集群(启用了AMQP 1.0插件)。 这不起作用: 但这是有效的(没有SSL): SSL配置良好,如下所示: 标准输出上没有错误消息,没有日志。 当连接到Artemis集群时,我得到了完全相同的行为。 此外,我可以在Python中使用Qpid Proton客户端的多个URI和SSL: 你能告诉我发生了什
我的计算机使用Intel显卡运行Ubuntu 16.04。我的OpenGL配置文件使用Mesa 11.2。 我简陋的OpenGL程序在窗口中显示一个简单的正方形。如果我按某个键,我想让程序切换到线框图模式,所以我定义了以下回调函数: 不幸的是,在我的程序运行时按m会导致段错误。不过,奇怪的是,在我的另一台计算机(运行Ubuntu 16.04但使用Nvidia GPU)上,我没有这样的问题,并且程序
有没有一种方法来捕获400到599超文本传输协议状态在onFail()方法通过使用改造2.0?每当其他api返回400,401等,然后改型像200响应,并在on成功()上处理它。我怎样才能实现呢?