无法在我的本地系统中使用 NIFI 中的 PublishKafka 连接到 kafka

Question

我正在尝试使用 InvokeHttp 将消息推送到我的 kafka 主题中，但它显示连接错误。

InvokeHttp 工作正常。

Answer 1

在conf目录下的server.properties文件中添加kafka监听器。

# The address the socket server listens on. It will get the value returned from 
# java.net.InetAddress.getCanonicalHostName() if not configured.
#   FORMAT:
#     listeners = listener_name://host_name:port
#   EXAMPLE:
#     listeners = PLAINTEXT://your.host.name:9092
listeners=PLAINTEXT://localhost:9092

之后打开代理。这次应该可以了。