如何解决Nifi ConsumeIMAP 处理器问题
我们在 nifi 管道中使用 IMAP 消费者处理器来读取来自 office 365 的电子邮件。我们在使用来自 office 365 邮箱的电子邮件时一直在观察 IMAP 处理器中的问题。我们已安排处理器每 30 秒运行 1 个并发任务。获取大小保持为 20。我们的邮箱有 1000 封邮件，但即使我们将获取大小指定为 20，它仍然每 30 秒只获取 1 封邮件。 Processor Conf Processor Conf
请告诉我们可能是什么原因或我们可以为处理器提供的最佳配置是什么。我们希望每天收到大约 10000 封邮件，但我们不希望邮件服务器出现限制错误。
我们也在 ConsumeIMAP 处理器中时不时地遇到以下错误。我们无法找到根本原因。任何帮助表示赞赏。
ERROR [Timer-Driven Process Thread-33] oanifi.processors.email.ConsumeIMAP ConsumeIMAP[id=c31e4176-842d-3464-b870-2460ee675eee] 由于 org.apache.nifi.processor.exception 无法处理会话.ProcessException：无法从电子邮件服务器接收消息：[javax.mail.MessagingException - 复制消息时出现 IOException：org.apache.nifi.processor.exception.ProcessException：无法从电子邮件服务器接收消息：[javax.mail.MessagingException -复制消息时出现 IOException org.apache.nifi.processor.exception.ProcessException：无法从电子邮件服务器接收消息：[javax.mail.MessagingException - 复制消息时出现 IOException 在 org.apache.nifi.processors.email.AbstractEmailProcessor.fillMessageQueueIfNecessary(AbstractEmailProcessor.java:328) 在 org.apache.nifi.processors.email.AbstractEmailProcessor.receiveMessage(AbstractEmailProcessor.java:381) 在 org.apache.nifi.processors.email.AbstractEmailProcessor.onTrigger(AbstractEmailProcessor.java:195) 在 org.apache.nifi.processors.email.ConsumeIMAP.onTrigger(ConsumeIMAP.java:32) 在 org.apache.nifi.processor.AbstractProcessor.onTrigger(AbstractProcessor.java:27) 在 org.apache.nifi.controller.StandardProcessorNode.onTrigger(StandardProcessorNode.java:1176) 在 org.apache.nifi.controller.tasks.ConnectableTask.invoke(ConnectableTask.java:213) 在 org.apache.nifi.controller.scheduling.TimerDrivenSchedulingAgent$1.run(TimerDrivenSchedulingAgent.java:117) 在 org.apache.nifi.engine.FlowEngine$2.run(FlowEngine.java:110) 在 java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) 在 java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308) 在 java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180) 在 java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294) 在 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) 在 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) 在 java.lang.Thread.run(Thread.java:745) 引起：javax.mail.MessagingException: IOException while copying message 在 javax.mail.internet.MimeMessage.(MimeMessage.java:254) 在 org.springframework.integration.mail.AbstractMailReceiver$IntegrationMimeMessage.(AbstractMailReceiver.java:557) 在 org.springframework.integration.mail.AbstractMailReceiver$IntegrationMimeMessage.(AbstractMailReceiver.java:552) 在 org.springframework.integration.mail.AbstractMailReceiver.postProcessFilteredMessages(AbstractMailReceiver.java:415) 在 org.springframework.integration.mail.AbstractMailReceiver.receive(AbstractMailReceiver.java:342) 在 org.apache.nifi.processors.email.AbstractEmailProcessor.fillMessageQueueIfNecessary(AbstractEmailProcessor.java:323) ... 省略了 15 个常用帧 引起：com.sun.mail.util.FolderClosedioException：null 在 com.sun.mail.imap.IMAPInputStream.forceCheckExpunged(IMAPInputStream.java:107) 在 com.sun.mail.imap.IMAPInputStream.fill(IMAPInputStream.java:158) 在 com.sun.mail.imap.IMAPInputStream.read(IMAPInputStream.java:218) 在 com.sun.mail.imap.IMAPInputStream.read(IMAPInputStream.java:244) 在 com.sun.mail.imap.IMAPMessage.writeto(IMAPMessage.java:849) 在 javax.mail.internet.MimeMessage.(MimeMessage.java:245) ...省略了20个常用帧
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。
