java - 为Nifi编写流媒体服务时如何解决Java的空指针异常？

Question

已关闭。此问题不符合 Stack Overflow guidelines 。目前不接受答案。

---

已关闭 5 年前。

• 此问题是由拼写错误或无法再重现的问题引起的。虽然类似的问题可能是 on-topic在这里，这个问题的解决方式不太可能帮助 future 的读者。
• 编辑问题以包含 desired behavior, a specific problem or error, and the shortest code necessary to reproduce the problem 。这将有助于其他人回答问题。

Improve this question

我正在使用 Nifi 中的处理器从 Kafka 获取数据并将其写入文件。该脚本是用 python 编写的。

import json
import java.io
from org.apache.commons.io import IOUtils
from java.nio.charset import StandardCharsets
from org.apache.nifi.processor.io import StreamCallback

class ModJSON(StreamCallback):
  def __init__(self):
        pass
  def process(self, inputStream, outputStream):
    text = IOUtils.toString(inputStream, StandardCharsets.UTF_8)
    outputStream.write(bytearray(text))

flowFile = session.get()
if (flowFile != None):
  flowFile = session.write(flowFile, ModJSON())
  flowFile = session.putAttribute(flowFile, "filename", flowFile.getAttribute('filename').split('.')[0]+'_translated.json')
session.transfer(flowFile, REL_SUCCESS)
session.commit()

它指出以下错误:

我已经读到了java中的这个错误，但我无法理解为什么它会在这里产生。

Answer 1

如果您只想将消息从 Kafka 写入文件，是否有理由不能只使用 ConsumeKafka -> PutFile？

该错误是因为您只在 if (flowFile != None): 中放入了两行:并且如果 flow file 为 null，您仍在第 18 行调用 Transfer，这会产生错误。