微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

由于在30000毫秒的超时时间内无法完成待处理的请求,因此强制关闭生产者

如何解决由于在30000毫秒的超时时间内无法完成待处理的请求,因此强制关闭生产者

当我尝试从DB2数据库中读取大量数据并写入Kafka主题时,遇到此错误-? 由于无法在30000毫秒的超时时间内完成待处理的请求,因此请强制关闭生产者。如何增加超时时间?

解决方法

此消息来自close()操作。

在应用程序上下文关闭之前,Spring通常不会关闭生产者。

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

    /**
     * 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);
    }

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。