当前位置: 首页 > 知识库问答 >
问题:

使用ReplyingKafkaTemplate时,ProducerRecord的答复超时

石正奇
2023-03-14

UnknownServerException:服务器在处理请求时遇到意外错误。

2020-07-06 09:46:23.521警告18218---[TaskScheduler-1]O.S.K.R.ReplyingKafkatemplate:回复超时:ProducerRecord(Topic=Student,Partition=NULL,headers=RecordHeaders(headers=[RecordHeader(key=kafka_replyTopic,值=[114、101、115、117、108、116]),RecordHeader(key=kafka_correlationId,值99,111,109,46,97,115,98,46,101,120,97,109,112,108,101,46,83,116,117,100,101,110,116]],isReadOnly=true),key=std101,value=com.asb.example.student@762dbd5f,timestamp=null),相关ID:[-123310123018425907456692533262240930155]

共有1个答案

曾鸿振
2023-03-14

答复超时:...

这个信息真的不足以说明什么是错的。

??

 类似资料:
  • 我最近在Spring Boot应用程序中从使用标准Rabbit模板改为使用异步Rabbit模板。在此过程中,我从标准的方法切换到使用方法。 进行此更改似乎不会影响向RabbitMQ发布消息,但是现在在发送消息时,我确实看到了如下所示的堆栈跟踪: 我确信我只是缺少一个配置选项,但任何帮助都将是徒劳的。 谢谢。:)

  • 我尝试使用MockWebServer对我的应用编程接口的各种响应。我做了一个简单的例子,只是为了尝试我想做的是一种工作方法。 mockWebServer不是要“模拟”我的http连接的endpoint吗?像真正的服务器?每当我试图打电话时,我都会感到莫名其妙的惊讶。 我用错了吗?它不应该只是替换服务器的响应吗?(嘲笑) E D I T: 我在清单上有互联网许可。 我使用: 代码: Logcat:

  • 我正在尝试使用mocha和mongoose编写一个测试用例。但我编写的以下代码片段在每个“hook:error:timeout of 2000ms extered.确保在此测试中调用了done()回调”之前都给出了错误“Todo”。我无法解决此问题。我是node的初学者。谁能在这个问题上帮我一下吗。提前谢谢。

  • 问题内容: 我正在使用goroutines / channels检查网址列表是否可以访问。这是我的代码。这似乎总是返回true。为什么超时情况没有得到执行?目标是即使无法访问其中一个网址也要返回false 问题答案: 将在 当前的 goroutine(即正在运行的goroutine)中休眠。该语句仅在返回后才能正确运行,并且到那时,这两个分支都可以运行,并且运行时可以选择任何一个它。 您可以通过在

  • 我已经使用ExecutorService实现了超时任务。在下面的方法中,我正在提交超时任务,如果它在给定的时间内超时,我将取消该任务并关闭执行器。 它运行得很好,我没有任何问题。 然而,我想知道这是否是最好的代码设计。我只是想知道如果使用ExecutorService返回的未来是否会更好。submit()获取可调用函数的返回值或超时超时任务。例如 我正在使用JDK7。

  • 我有一个Spring Boot(v2.0.8)应用程序,它使用HikariCP(v2.7.9)池(连接到MariaDB)配置: 问题在于,我们的生产组件每隔几周就会反复抛出 。问题在于它永远不会从中恢复,并且会不断引发异常。因此,需要重新启动计算装置。 从HikariPool源代码来看,这似乎正在发生,因为每次它调用poolEntry都是空的,因此会抛出超时异常。要使其为空,连接池必须没有空闲条目