Apache Flink的Webhook流式连接器
根据ApacheFlink文档，它有预定义的数据源。它还提到了其他一些连接器，例如RabitMq连接器等。我想知道是否有类似的项目可以使用Webhook作为数据源。
共有1个答案
不，Flink没有webhook数据源，但有一个套接字连接器。
关于为Flink的有状态函数添加webhook入口之类的东西，已经有一些初步的讨论，其中这样的数据源更适合。
-
我有2个使用kafka主题创建的流，我正在使用DataStream API加入它们。我希望将连接（应用）的结果发布到另一个kafka主题。我在外部主题中看不到连接的结果。 我确认我向两个源主题发布了正确的数据。不确定哪里出了问题。下面是代码片段， 创建的流如下所示。 流连接使用等于的连接执行，如下所示。 如下所述， 有什么线索吗，哪里出了问题？我可以在拓扑中看到可用的消息，谢谢
-
我们已经成功地使用了MySQL - 使用jdbc独立连接器的kafka数据摄取，但现在在分布式模式下使用相同的连接器（作为kafka connect服务）时面临问题。 用于独立连接器的命令，工作正常 - 现在，我们已经停止了这一项，并以分布式模式启动了kafka connect服务，如下所示 2 个节点当前正在运行具有相同连接服务。 连接服务已启动并正在运行，但它不会加载 下定义的连接器。 应该对
-
我正在创建一个webhook。Net Core 3 Web API，用于DocuSign Connect调用并向我提供状态更新我的应用程序创建的信封中的签名文档。C#示例位于https://www.docusign.com/blog/dsdev-adding-webhooks-application这对我几乎达到目标很有帮助。示例中的代码是： 出于测试目的，我的网络应用编程接口允许所有来源并通过N
-
我想连接两个主题流（左连接），并在连接的流上进行基于窗口的聚合。然而，聚合将某些消息计数两倍，因为在连接期间，根据正确主题中的延迟，某些消息将发出两倍。以下是POC的代码。 它是否可以修复以避免因连接而重复？
-
我正在尝试为ApacheFlink导入ScalaAPI流扩展，如中所述https://ci.apache.org/projects/flink/flink-docs-master/apis/scala_api_extensions.html 但是，我的ScalaIDE抱怨以下消息：对象扩展不是包的成员org.apache.flink.streaming.api.scala 我使用的是scala 2
-
我有以下代码来计算socketTextStream中的单词。累积字数和时间窗字数都是必需的。该程序存在累积计数始终与窗口计数相同的问题。为什么会出现这个问题？根据加窗计数计算累积计数的正确方法是什么？