Azure Logic Apps到KAFKA双向（生产者/消费者）连接器 [英] Azure Logic Apps to KAFKA bidirectional (producer/consumer) connector

问题描述

Hello Experts， 



我们正在使用Logic Apps来实施业务流程工作流程。我们正试图解决一个有趣的问题，其中包括行动/逻辑应用程序工作流程中的步骤想要将事件/有效负载推送到KAFKA主题。 

我们期待通过实现Web APP（具有KAFKA库支持的中间件）来实现这一目标）弥合这一差距并表现得像Logic App连接器，同时利用KAFKA库实现KAFKA主题消费者/制作人。 

逻辑应用程序操作 - > Web App（KAFKA连接生产者功能） - >制片人到KAFKA主题 

KAFKA主题  - > Web App（KAFKA连接消费者功能） - >触发逻辑应用操作

是否有人遇到此类问题并找到了更好的解决方案。 

感谢建议论坛!!
$


干杯，

SameerK

解决方案

< blockquote>

这确实是实现此目的的完美方式。

Logic Apps中的每个连接器都是幕后的API。逻辑应用程序旨在作为连接这些API以执行有意义的工作流程的一种方式。

因此，您将拥有一个连接到Kafka的API应用程序，并为您的Logic App提供联络服务。工作流程。

1。 Logic App操作非常简单。您可以构建标准API，如果您有OpenAPI规范，则只需

从中创建自定义连接器。

2。对于触发器，最好的方法是实现
webhook行动。这是一个
样本（有点旧），可以帮助您开始这一点。它展示了Poll和Push风格触发器。

Hello Experts, 

We are using Logic Apps to implement Business Process Workflow. We are trying to solve an interesting problem wherein actions/steps in logic app workflow wants to push events/payload to a KAFKA Topic. 

We are looking forward to achieve this by implementing a Web APP (a middle ware with KAFKA library support) to bridge this gap and behave like Logic App connector at the same time leverage KAFKA libraries to implement KAFKA topic Consumer/Producer. 

Logic App Action--> Web App (KAFKA connect producer capabilities) --> Producer to KAFKA Topic 

KAFKA Topic  --> Web App (KAFKA connect consumer capabilities) --> Trigger Logic App Action

Has anyone came across such problem and found better solution. 
Appreciate advise from the forum !!

Cheers,
SameerK

解决方案

This is indeed the perfect way to implement this.

Every connector in Logic Apps is an API behind the scenes. Logic Apps is meant to act as a way to connect those many APIs to perform meaningful workflows.

So, you would have an API App which connects to Kafka and acts a liaison for your Logic App workflows.

1. The Logic App action is pretty straightforward. You can build a standard API and if you have an OpenAPI spec, you can just create the custom connector from that.

2. For the Trigger, the best way is to implement a webhook action for it. Here is a sample (a bit old) which can help you get started on this. It showcases both Poll and Push style triggers.

这篇关于Azure Logic Apps到KAFKA双向（生产者/消费者）连接器的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！