#apache-kafka #salesforce #pentaho #pentaho-spoon #pentaho-data-integration
Вопрос:
У меня есть потребитель Кафки в Пентахо, который называет преобразование, ответственное за выполнение обновления в Salesforce.
В этом преобразовании я хотел бы взять FK, взятый из Кафки, и использовать его в качестве условия WHERE в моем запросе, и результат этого запроса я сделаю в Salesforce.
То, что я построил до сих пор:
- Кафка, поглощающий эту тему
- Получить сообщение из потока, уже настроенного
- Ввод JSON извлекает FK из кафки, который мне нужно использовать, он отображается с именем «CpfCnpj».
Как я могу использовать «CpfCnpj» в качестве параметра в своем запросе?
Я уже пытался включить опцию «Вставить данные из шага» из ввода JSON и построить запрос с И C. CLNT_TN_CPF_CNPJ = ${CpfCnpj}, но не сработало.