我正在尝试使用@google-cloud/pubsub模块在节点js中推送PubSub主题这里是Javascript代码 const { pubsub } = require('@google-cloud/pubsub');
this.publisherUser = pubsub.topic(before any response w
浏览 23提问于2019-10-05得票数 4
回答已采纳
3回答
卡夫卡生产者配置重试策略
、、、、
需要更改Kafka配置的哪些参数，以便生产者应该: 1)在n次间隔后对同一消息重试n次2)，以防代理关闭。
我需要处理一个与此相关的情况：
浏览 5提问于2017-03-02得票数 3
2回答
然后，我使用Stripe Checkout，在“测试”模式中，我故意返回400 http响应或超时响应200 http响应到Stripe在<code>E 110</code>“test”模式<code>在此之后，可以在仪表板中手动重试Webhooks，您还可以使用来协调任意时间的数据。
Stripe为3xx、4xx或5xx响应</e
浏览 19提问于2022-07-28得票数 0
回答已采纳
我使用下面的方法来获取来自truncate namespace.set.bins的数据 val calendar = Calendar.getInstance()
calendar.setTimeInMillis(startTime + 1262304000000L) // uses CITRUSLEAF_EPOCH - see https://discuss.aerospike.com/t/how-to-use-view-and-calulate-last-update-time-lut-for-the-truncate-command
浏览 6提问于2021-08-08得票数 1
回答已采纳
在我们的应用程序中，对于每个导致数据更新/插入到DB的请求( REST端点后调用)，我们必须向Kafka发布/生成一条消息，以便下游系统使用并进行进一步处理。这意味着，在POST调用中结束的任何处理都应该在5秒内完成，以避免超时问题。使用这种设置，如果一个场景中我已经结束了一个DB调用，并在一个POST调用中调用了Kafka来生成一条消息，那么我的问题是，我如何控制/设置我的kafka制作人在得到代理响应
浏览 2提问于2020-01-30得票数 0
回答已采纳
在这种情况下，我想取消请求：
注意，我并不是在请求中查找timeout参数，因为这是一个仅针对不活动的超时。我无法找到与总超时有关的任何方法，也无法找到限制总</em
浏览 5提问于2014-03-12得票数 18
回答已采纳
1回答
使用PubSub将数据流到负责将数据上传到Google BigQuery的微服务中。还有一些服务通过将CRM和其他服务分割成更小的块，从CRM和其他服务中流出更高的数据负载(> 1GB)。用于在微服务中传递不需要立即响应的不同事件的消息。
发布时收到</em
浏览 6提问于2021-11-18得票数 1
回答已采纳
基本上，当我这样做的时候(超时以毫秒为单位)_ignitedHttp.setSocketTimeout(60000); // 60 seconds_ignitedHttp.setConnectionTimeout(60000); // 60我是否误解了套接字和连接超时之间的区别？这个库是 (还没有正式发布)。
浏览 0提问于2011-09-09得票数 150
回答已采纳
我有一个java应用程序，在该应用程序中，我使用HttpURLConnection下载文件。我在连接超时设置了15秒，在读取超时属性中设置了1个小时。根据我的理解，如果服务器上的文件足够大，需要1小时以上才能下载，则超时异常将失败。效果很好。问题是，在下载过程中(从InputStream读取缓冲区)时，当我从客户端计算机拔出互联网电缆时，下载过程不会立即终止，中断下载需要1小时(读取超时)。有什么方法可以终止下载过程吗？
浏览 0提问于2015-10-05得票数 4
回答已采纳
1回答
configuration.timeoutIntervalForResource = 30 }()在测试时，我注意到只有我的GET请求在30秒时超时。有没有人能解释一下原因，并可能告诉我如何使POST请求在60秒时也超时？
谢谢你，辣椒粉
浏览 2提问于2021-11-19得票数 0
2回答
我需要用于超时的CORBA客户端属性，以便在客户端设置超时，并限制连接保持打开的时间；应该为所有场景设置它，以限制最大请求时间：
为了更清楚起见，在这些属性(上面)旁边设置了使用属性org.omg.CORBA.ORBInitialHost
浏览 3提问于2013-06-20得票数 9
1回答
我正在尝试设置每个调用超时在扳手nodejs客户端.我已经阅读了给定的扳手文档，其中最好的是：。这些文档忽略了您需要提供gaxOptions。at Object.onReceiveStatus (/Users/benjamingodlove/Developer/spanner-node-repro/node_modules/grpc-gcp"author": "",
"license": "ISC"
浏览 2提问于2021-10-14得票数 0
回答已采纳
我试图弄清楚这一点已经有一段时间了，但就是想不通。当向服务A(也使用具有主重试和延迟重试的nservicebus实现)发出请求，并且服务A由于瞬时/半瞬时错误而失败时，服务重试，直到所有重试耗尽并且消息被发送到错误队列(假设我们正在使用ASB或rabbitmq或者可能是msmq)，在来自服务A的响应决定saga是向服务B还是服务C发出请求的情况下，saga应该如何表现。或者，如果在设定的时间内没有接收到预期的响应</
浏览 2提问于2018-05-14得票数 1
在中，request.timeout.ms的条目是：
配置控制客户端等待请求响应的最长时间。如果在超时之前未收到响应，则客户端将在必要时重新发送请求，如果重试已用尽，则失败请求。
浏览 1提问于2018-12-05得票数 0
回答已采纳
2回答
将同步副本配置为Acks=all和min.insync.replicas = N，当Kafka无法处理ISR时，在线记录在处理过程中是N-1，最小配置的
浏览 8提问于2021-01-17得票数 0
3回答
recordMetadata, Exception e) { // OK // NOT OK }考虑到生产者中的buitl-in重试逻辑，我想知道开发人员应该明确地处理哪种异常？
浏览 2提问于2020-05-07得票数 3
回答已采纳
2回答
REST:如何确定瞬态异常？
、、、、
当我试图处理当我调用RESTful端点或任何HTTP端点时发生故障的可能性时，我一直在想，在HTTP规范中还是在业界中是否有任何标准或模式来解决确定异常何时是短暂的以及何时不是特别用于可重选的目的的问题例如，如果远程服务使用数据库，而我得到查询超时导致的5xx错误，那么重新尝试是安全的，因为条件是短暂的，如果我重试，服务调用很可能会成功。但是，可能还有其他类型的错误，这些错误不是暂时性的，我更希望避免重试。例如，在过去，由于DBA将一个新约束添加到表<
浏览 0提问于2017-02-03得票数 11
回答已采纳
我正在构建一个运行在Cloud Run上的服务，该服务由PubSub通过EventArc触发。“PubSub”保证交付至少一次，并将在每一个acknowledgement截止日期重新尝试。此截止日期设置在队列订阅详细信息中。
在请求开始时，一旦收到请求。然后，服务将继续以自己的速度处理请求。因此，在开始时发送响应可能不是一种选择。
浏览 5提问于2021-06-24得票数 1
它绝对不应该在HTTP处理程序中运行，因为它需要10分钟才能完成。相反，处理应该由某种类型的工作人员异步完成，并且最好向用户报告任务执行的进度。(或者我是否应该为此目的使用自定义任务服务，例如芹菜和红葡萄酒)云运行作业似乎也具有一些类似的功能，但是没有任何队列系统来管理工作人员。
浏览 10提问于2022-09-29得票数 1
回答已采纳
云服务器
ICP备案
对象存储
即时通信 IM
云直播
腾讯云开发者
