我在pentaho数据集成（pdi）中有一个转换，它向netsuite发出查询，为每一行构建json字符串，最后这些字符串被发送到kafka。这就是转变：

当我对我的本地Kafka测试转换时，它就像一个符咒，如你所见：

问题是当我将连接参数替换为aws ec2示例的连接参数时，其中也有kafka。问题是转换没有给出错误，但是消息没有到达Kafka，如这里所示：


这是Kafka制作者的配置转换步骤：

奇怪的是，虽然它没有将消息发送到kafka，但它似乎确实连接到了服务器，因为组合框中显示了我拥有的主题的名称：

此外，在pdi终端中观察到此错误：

ERROR [NamedClusterServiceLocatorImpl] Could not find service for interface org.pentaho.hadoop.shim.api.jaas.JaasConfigService associated with named cluster null

这对我来说毫无意义，因为我使用的是直接连接，而不是到hadoop集群的连接。
所以我想问这个社区的成员，是否有人使用poi向kafka发送消息，他们是否必须在poi或slack中进行配置才能实现，因为我不知道会发生什么。
提前感谢您的任何想法或意见，以帮助我解决这个问题！