由于在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);
    }