据我了解,只要激活动态分区,就可以在 Firehose 上指定分隔符。您可以在动态分区部分下看到“新行分隔符”选项。 但是,我需要在不使用动态分区的情况下指定分隔符。我在任何地方都看不到这个选项。有可能实现吗?
注意:我正在尝试找到一个内置的解决方案,而不是在生产者应用程序中手动附加
data + "\n"
您必须为 firehose 设置 lambda 函数,它将处理记录并向其添加新行。