apache-kafka - 使用 Pentaho 中 Kafka 主题的参数咨询 SQL
问题描述
我在 pentaho 中有一个 Kafka Consumer，它调用了一个负责在 Salesforce 中进行 upsert 的转换。
在此转换中，我想采用来自 Kafka 的 FK 并将其用作查询中的 WHERE 条件，并且此查询的结果将在 Salesforce 中进行更新。
到目前为止我已经建立了什么：
- 卡夫卡消费主题
- 从已配置的流中获取消息
- JSON输入从我需要使用的kafka中提取FK，它的映射名称为“CpfCnpj”
如何在查询中使用“CpfCnpj”作为参数？
我已经尝试从 JSON 输入中启用“从步骤插入数据”选项并使用 AND C.CLNT_TN_CPF_CNPJ = ${CpfCnpj} 构建查询，但没有奏效。
解决方案
推荐阅读
- vue.js - 当 vuex 的文档说它不应该时，为什么 splice 可以在对象的数组类型属性上工作？
- django - 在 Django handler404 重定向中访问请求的 URL？
- azure - 天蓝色应用程序设置 - 如何添加嵌套项
- ios - iOS - 调整视图层大小以填充 iPhone X Max 背景
- cassandra - Does Cassandra have a sleep cql query?
- android - Why android application gives compiler error for Admob integration using Firebase using c++ SDK
- reactjs - How to Set state of a component from within another component in react
- angular - 带有 HttpAuth 参数的 HTTP GET 请求
- r - 基于嵌套 if else 条件和比较 R 中列表中的值创建新列的有效方法
- php - How i can make some variables in a url and a text $u1.txt