只是想知道在使用Kafka Streams Builder编写持久性层时可能会遇到什么样的问题，或者像Kafka Connect JDBC(Sink(这样的任何建议？
是的，使用 Kafka Connect — 从主题流式传输到数据存储正是它:)
如果要在将数据登陆数据库之前对其进行处理/扩充，则可以使用 KStreams(或 KSQL(，并流式传输到第二个主题，然后将其连接到 Connect。
相关内容
- 没有找到相关文章
最新更新
- 在Shopify中隐藏折扣代码输入字段
- 无法导入外部 NPM 包来制作角度库
- 掩码输入字段的长度验证
- 用点分隔符分隔列
- 在Mac上将Xerces库构建为通用二进制文件的问题
- 在同级组件之间使用共享服务共享数据，在Angular中返回空
- 为什么我的 C 结构在输入中没有获取任何数据？
- org.keycloak.adapters.springboot.KeycloakSpringBootConfigResolver 不存在
- 为一个非常大的数据库优化SPARQL查询
- Python线程请求计数
- 将结果保存为pyspark多输出循环中的数据帧
- 这两个数组的区别是什么?
- 如何在主线程上运行async await
- React Native FlatList ListEmptyComponent总是显示，即使不是空的
- Android Emulator未在M1上运行
- 我的' collate_fn '函数在传递给Trainer函数的collate_fn参数时得到空数据
- 访问documentRoot以外的所有图像，而不是Apache windows
- 如何从React或Javascript中的对象属性中获取值
- Redux工具箱:从切片文件导出一个自定义钩子来访问动作，而不是导出所有的动作，然后再次调用调度? &
- CSS难题:孩子们总是闯入多行
- 贴现率，公式
- 使用 Javascript 的嵌套数组循环生成和排序所有象限中 (0,0) 周围的笛卡尔坐标
- 如何在Windows上添加现有的mysql模式
- 从Google VPS中恢复删除的文件夹
- ffmpeg/映射代码的几个输出
- r语言 - 在部署到shinyapps.io的Shiny应用中使用readClipboard()的问题 &
- 如何适应事件SelectionChange代码在事件计算工作?
- 类型错误：.map 不是一个函数不明白出了什么问题
- 在Rust中定义无限嵌套HashMap
- 为什么有些符号表达式没有简化？
热门标签：
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