我正在使用支持Debezium源连接器的Pulsar IO，以便从您的数据库获取流更改。从文档中可以清楚地看到如何连接到MYSQL， $ bin/pulsar-admin source localrun --sourceConfigFile debezium-mysql-source-config.yaml监视连接器的步骤 bin/pulsar-admin functions getstatus \
--
浏览 10提问于2019-08-31得票数 0
我找不到Apache Pulsar的Hazlecast Jet源连接器。有人试过这个吗？如果我必须为Pulsar编写一个自定义的stream连接器作为Jet的源，感谢任何方向，要点，来源，考虑因素？
浏览 20提问于2019-12-30得票数 3
在Azure中，我能够使用Call Mode: SOAP to REST创建到SOAP端点的连接器。此Service需要一个名为Cookie的Header，其值为LoginCert=。在修改此连接器的请求时，我无法找到在REST请求中添加Cookie HTTP头的方法，并将相同的Cookie添加到SOAP请求中。是否有人知道如何或是否可能将<em
浏览 0提问于2019-03-08得票数 0
回答已采纳
我们有一个.NET web应用程序，它有REST。每个客户都有自己的API密钥。现在我们想要创建一个Power自定义连接器，它允许我们的用户通过API轻松地在我们的系统中创建项目。例如，当我们使用内置SharePoint连接器时，我们可以在应用程序中执行以下操作：将表单的源定义为SharePoint list
然后Power将自动添加表单中</
浏览 8提问于2022-02-23得票数 0
我目前正在研究Pulsar JDBC接收器，因为我们计划很快使用一个PostgresSQL接收器。现在，已经提到JDBC接收器支持insert/ update /delete ops，但是我没有找到任何关于接收器连接器如何实际决定执行什么的文档(对于一个新事件是插入、更新还是删除？)如果这是正确的，请告诉我：
1.)对于1 db实体类型，需要有3个不同的主题。将实体类型插入到表中的一个主题，一个用于更新同一实体类型的</em
浏览 4提问于2022-03-16得票数 1
回答已采纳
我们有一个使用案例，我们的消息处理器处理消息，对来自少数主题的消息进行非常复杂的计算。这些计算未在配置的重新计价期限内完成。我们是否可以为需要消息保留更长时间的少数主题设置此设置，而不是全局增加所有主题的消息保留时间？按主题保留消息是可能的吗？
浏览 55提问于2020-12-10得票数 1
我很难找到一种连接到身份验证/授权/令牌发布过程的方法。在提供用户名+密码时，如果凭据是有效的，则用户将登录，如果凭据有效，我们将进行附加检查，以确定用户是否被禁止(通过在自定义数据库中检查用户名)，如果用户被禁止，则拒绝登录。我想知道Azure AD或Azure AD B2C是否支持这种连接到其过程中的功能，如果支持，我在哪里可以找到更多关于它的信息？文件？样本代码？等
浏览 6提问于2021-02-19得票数 0
回答已采纳
1回答
用于雪花的python本机连接器按照使用REST Apis。查看这个连接器的代码，它似乎使用了REST，如ret = self.rest.request( _include_retry_params=
浏览 2提问于2022-11-21得票数 1
回答已采纳
在Mule 3.9环境中，mule代码是通过ftp连接器读取文件的。如何在表单数据方面将相同的文件发送到另一个rest api (http连接器)。
浏览 32提问于2020-12-07得票数 0
我的sharepoint中有这个excel表格。因此，我连接到我的excel工作表，然后执行一些ETL。这些数据被传递到mysql数据库。因此，我不想再次对所有行运行ETL流程，而是只对新行运行ETL流程。
浏览 1提问于2021-05-30得票数 0
Zapier的世界来到了Mulesoft，Zapier有一个REST poll连接器，它可以轮询REST GET API，并可以根据Id对记录进行重复数据删除，以找到新创建的记录并定期流式传输这些记录。我只是好奇在MuleSoft中是否存在这样的连接器。
浏览 13提问于2019-08-20得票数 0
回答已采纳
我有一个应用程序，该应用程序在特定主题下向Pulsar生成消息，并在该应用程序完成后关闭该应用程序；同时，不存在用于读取该主题的使用者。过了一段时间，当我创建一个使用者并想要读取写入的数据时，我发现所有的数据都丢失了，因为我编写的主题被Pulsar删除了。
如何在Pulsar中禁用非活动主题的自动删除？
浏览 0提问于2019-07-24得票数 4
回答已采纳
我研究Apache Pulsar已经有一段时间了，我很高兴。但是，我刚开始使用身份验证/授权，并且在Java管理客户机中遇到了一个奇怪的错误。虽然我可以执行所有类型的操作，如创建/删除租户、创建/删除名称空间、创建/删除分区主题、向租户添加管理员角色等，但尝试使用
org.apache.pulsar.client.admin.Namespaces.grantPermission
浏览 1提问于2020-05-20得票数 0
逻辑应用连接器是闭源的，Azure门户中的“自动化脚本”选项将属性节点的身份验证部分从连接器中剥离。这是当您为与CRM对话的逻辑应用程序编写ARM模板时，门户会提供给您的内容。{ "customParameterValues": {},
&q
浏览 1提问于2018-01-15得票数 1
1回答
如何拦截rest-connector执行，以格式化来自REST API连接器的响应？我将‘新闻’添加到datasources.json文件中： "file": { "localStorage": "", },
"new
浏览 1提问于2016-10-03得票数 1
我正在尝试为Apache Pulsar设置一个异步消费者，但我的问题是只收到一条消息，除非我重新启动Spring Boot应用程序，否则没有其他消息。它确实说“一旦返回的CompletableFuture收到消息，就应该随后调用receiveAsync()，否则它会在应用程序中造成接收请求的积压。”Docs: Pulsar Docs：https://pulsar.apache.org/docs/en/client-lib
浏览 111提问于2021-04-20得票数 1
回答已采纳
我有一个Java客户端客户端正在接收Pulsar (v2.10.0) AVRO消息(雇员)，如下所示：importorg.apache.pulsar.client.api.Message;import org.apache.pulsar.client.
浏览 2提问于2022-05-31得票数 2
如何调用在基于APIKit的消息流中返回JSON的rest服务。我希望为Rest服务准备请求，并希望在消息流中提取JSON消息。谢谢
浏览 2提问于2015-07-13得票数 0
1回答
几个简短的问题：
我想使用外部REST服务(例如AgileCRM)。对于他们的服务，我想在允许我使用CRUD AgileCRM的API的模型中使用REST连接器。这个是可能的吗？我希望合并来自AgileCRM和PersistedModel (例如MySQL)的数据。我应该通过关系或继承来做到这一点吗？如果继承，哪一个应该是父模型？最好使用来自AgileCRM的所有数据(在LB中表示为模型，如果可
浏览 0提问于2015-05-17得票数 1
我需要为REST API创建kafka源连接器与头部身份验证，如curl -H "Authorization: Basic“-H "clientID：”"https:< url for source>我使用的是apache kafka，我使用的是连接器类com.github.castorm.kafka.connect.http.HttpSourceConnector这里是连接器的json文件
浏览 14提问于2020-09-06得票数 0
回答已采纳
云服务器
对象存储
ICP备案
云点播
实时音视频
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号