首页
学习
活动
专区
圈层
工具
发布
首页
学习
活动
专区
圈层
工具
MCP广场
社区首页 >问答首页 >继续强制关闭生产者,因为挂起的请求无法在超时30000毫秒内完成

继续强制关闭生产者,因为挂起的请求无法在超时30000毫秒内完成
EN

Stack Overflow用户
提问于 2020-10-16 20:44:44
回答 1查看 927关注 0票数 0

当我试图从DB2数据库中读取大量数据,并写入Kafka主题时,获取此错误-?继续强制关闭生产者,因为挂起的请求无法在超时30000毫秒内完成。如何增加超时时间?

EN

回答 1

Stack Overflow用户

发布于 2020-10-16 21:57:40

此消息来自close()操作。

Spring通常不会关闭生产者,直到应用程序上下文关闭。

您可以在DefaultKafkaProducerFactory上增加此超时。

代码语言:javascript
复制
    /**
     * The time to wait when physically closing the producer via the factory rather than
     * closing the producer itself (when {@link #reset()}, {@link #destroy()
     * #closeProducerFor(String)}, or {@link #closeThreadBoundProducer()} are invoked).
     * Specified in seconds; default {@link #DEFAULT_PHYSICAL_CLOSE_TIMEOUT}.
     * @param physicalCloseTimeout the timeout in seconds.
     * @since 1.0.7
     */
    public void setPhysicalCloseTimeout(int physicalCloseTimeout) {
        this.physicalCloseTimeout = Duration.ofSeconds(physicalCloseTimeout);
    }
票数 1
EN
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接:

https://stackoverflow.com/questions/64389445

复制
相关文章

相似问题

领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档