My Filestream源连接器正在kafka主题中将单个XML文件作为多条消息读取，即文件中的每一行都作为单独的消息读取。如何克服这一点，即完整的文件作为一条消息读取？
提前谢谢。
FileStream连接器不能被配置为将多行读取为一条消息，而且也只能用作开发目的的示例(根据文档(，而不是产品化ETL管道的一部分。
因此，您需要其他方法将文件读取为单个字符串。(但也要注意，Kafka的默认消息大小为1MB，不用于文件传输(
相关内容
- 没有找到相关文章
最新更新
- 我怎样才能让我的Angular应用允许在生产环境中刷新——重写URL ?
- VBS 和 WSH 在简单循环和 CPU 过度使用时出现错误
- ComboBox VirtualizingStackPanel WPF Programmatically
- 如何在使用聚合函数时忽略字符
- 如何解决多线程静态变量增量?
- webpack-streams breaks @types/webpack
- 为BASH中的单词数组加边框
- 如何阻止不需要的功能组件被调用?依赖关系在哪里?
- 列表中字符串字符之间的比较
- 即使在我执行 commit() 和 autocommit=True 之后，也无法使用 psycopg2 脚本更新 PostgreSQL 表
- 在x秒后在两个函数之间切换
- 从对象数组中提取属性，并通过lodash创建基于此属性的另一个?
- sectionIndexTitles映射不能正常工作
- Apache commons CSVPrinter正在编码双值
- coinex交换API，并使用Curl /BASH来放置市场订单加密对
- 询问直到输入在列表中?
- Cant 将 2D 数组传递给函数 C++
- 如何同步外表和本表?
- 我如何显示另一个实体链接到主一个在html.twig?
- Material UI自动完成列表框样式没有影响
- 数组中的参数类型问题('float'， 'const int')
- 编译错误在VS Studio编译Fortran代码
- 无法解析身份验证凭证
- Google Maps API查找详细信息
- 是否有一种方法可以访问npm包内的方法?
- 将类添加到viewport中的元素
- 检查JavaScript变量类型是否有键
- 将动态Github工作流矩阵与输入值和预定义值相结合
- 需要构造一个API列表数组
- jQuery的美元语法与美元符号JavaScript "convention"
热门标签：
javascript python java c# php android html jquery c++ css ios sql mysql arrays asp.net json python-3.x ruby-on-rails .net sql-server django objective-c excel regex ruby linux ajax iphone xml vba spring asp.net-mvc database wordpress string postgresql wpf windows xcode bash git oracle list vb.net multithreading eclipse algorithm macos powershell visual-studio image forms numpy scala function api selenium