2

我正在从 nifi-user 日志文件本身读取流/批处理格式的记录以用于测试场景，并使用 ConvertRecord nifi 处理器转换为 Avro 格式，然后使用 PublishKafka_2_0 处理器发布到 kafka 主题。我还在使用 Schema 注册表进行模式构造。因此，现在当记录转储到 kafka 时，它是作为单个数组而不是单个记录完成的。有没有办法将记录分解为单个实体。我已经尝试过拆分记录处理器，它似乎没有达到预期的效果。有没有另一种方法来实现它。

- 更新

4

1 回答 1

0

如需适当的反馈，请分享重现问题的流程，但以下步骤有望满足您的需求：

  • 在发送到 Kafka 之前直接拆分​​您的消息，并确认拆分确实成功
  • 尝试发布 Kafka 记录 2.0 而不是 Publish Kafka 2.0
  • 将最大消息大小设置为 1 字节而不是 1MB？！
于 2019-06-23T13:14:08.030 回答