这是我的连接器配置。to start task custdb-s3-connector-0 (org.apache.kafka.connect.runtime.Worker)connect | at org.apache.kafka.comm
浏览 26提问于2018-08-03得票数 0
回答已采纳
我正在尝试为Google服务配置Sink Kafka Connect。使用以下命令配置Kafka Connect：-X POST -H 'Accept: application/jsonpubsub_test","connector":
{"state":"RUNNING","worker_id":"connect:808
浏览 1提问于2018-06-29得票数 1
回答已采纳
"errors.deadletterqueue.topic.name"是否适用于源连接器？我用进行了测试，它可以工作，但我没有发现有序列化错误的记录会进入死信队列。"errors.tolerance": "all","errors.deadletterqueue.topic.name
浏览 1提问于2020-02-19得票数 4
回答已采纳
在我的HBaseSink连接器中，我将新特性“errors.deadletterqueue.topic.name”配置为：
{“名称”：“kafka-hbase4 4”，"config"：{ "connector.class这是否意味着配置"errors.deadletterqueue.topic.name“无法工作？为什么会这样，我如何使这个配置工作呢？
浏览 1提问于2018-11-26得票数 1
1回答
我有一个卡夫卡制作人与以下配置。消费者应用程序即使在request.timeout.ms超过之后也会被调用，但是在生产者中得到超时错误。如果使用者端发生超时错误，我需要限制使用者调用。
浏览 6提问于2022-02-20得票数 0
Spring配置
<int-kafka:outbound-channel-adapter id=
浏览 3提问于2016-12-13得票数 0
回答已采纳
org.apache.kafka.connect.json.JsonConverter我正在使用具有以下连接器配置的分布式连接器
浏览 40提问于2021-05-20得票数 0
1回答
我目前正在配置一个Kafka接收器连接器，以便在Postgres表中编写我的kafka消息。除错误处理部分外，一切正常工作。我希望将这些错误的消息放到DLQ中，并将偏移量提交给处理下一条消息，因此我将连接器配置为"errors.deadletterqueue.topic.name还有其他我遗漏的配置吗？我在汇合的文档中只看到了这两个
(我在中看到，put阶段的错误处理是在10.1.0 (CCDB-192)版本中实现的，我
浏览 3提问于2022-09-23得票数 0
回答已采纳
value.deserializer', StringDeserializer.name)当我执行它时，我会得到以下错误：
org.apache.kafka.common.config.ConfigException:无效值localhost:9092用于配置bootstrap.servers:预期为逗号分隔列表。
浏览 5提问于2016-07-21得票数 2
回答已采纳
2回答
setObject method; use the setNull method or the setObject method with a targetSqlType parameter 我的连接器配置CAL-OUTtable.name.format=K_C_OSUSR_DGL_DFORM_I1_V2errors.tolerance=all
errors.deadletterqueue.topic.name我不知道我是否必须在接收器中更改一些代码，或者只是更改连接器配置。
浏览 37提问于2019-06-05得票数 0
当我在Eclipse中运行我的生产者类时，我得到了这个错误：org.apache.kafka.common.config.ConfigException:缺少必需的配置"bootstrap.servers
浏览 1提问于2017-06-05得票数 9
因此，我的尝试是将这些属性放在salesforce连接器配置中(在这里，我希望连接器缓冲记录10秒，或者直到它们达到1000个字节)：
"confluent.topic.consumer.fetch.max.wait.ms
浏览 5提问于2022-09-14得票数 1
回答已采纳
1回答
我尝试将以下内容添加到S3连接器配置中："errors.tolerance": "all",
"errors.deadletterqueue.topic.name作为连接器配置的一部分？
浏览 2提问于2021-05-11得票数 2
600000","errors.log.enable":"true","errors.deadletterqueue.topic.name,}
}' http://
浏览 0提问于2020-11-26得票数 2
这会导致kafka连接辅助进程抛出异常：
org.apache.kafka.common.config.ConfigException:主题‘slpe- connector偏移’通过'offset.storage.topic更改Connect配置中的“offset.storage.topic”属性，以使用带有“Clearup.Policy=Compact”的主题。问:是否有任何卡夫卡连接工人配置允许吃这个异常来保持工作进程？虽然这是一个风险，但delete不会发生，直到它达到保留或大小限制。
浏览 3提问于2021-01-04得票数 5
回答已采纳
我编写了一个示例应用程序，它创建了一个托管工作配置文件，并将自己设置为配置文件所有者。
我需要通过配置文件所有者来推动一些企业应用程序。所以当我尝试安装时，它说“安装阻塞”，不能从未知的来源安装。如果我切换按钮(设置->security->未知源)，设置将不会反映在工作配置文件中。有没有办法从未知的来源在工作配置文件中安装应用程序？
浏览 2提问于2015-01-31得票数 2
1回答
我试图了解在任何日志文件中是否发生了此命令的日志记录：su: user user1 does not exist注- user1是不存在的.
如果我尝试使用一个有效的用户名并提供一个无效的密码，我就能够在上面的日志文件中看到失败的消息。当用户名无效时，这些文件中不会发生日志记录。如果这是默认行为，那么我们是否可以启用这些消息的日志记录？
浏览 0提问于2017-04-27得票数 0
我看到了一些配置键： 2012-03-08 :00:21:21：(server.c.968)警告:未知配置-键: server.use-noatime (忽略) 2012-03-08 : 07:00:21：(server.c.968)警告:未知配置-键:serv
浏览 2提问于2012-03-08得票数 1
回答已采纳
1回答
当使用Struts2约定插件时，即使没有定义HelloWorld.java，插件也会自动将hello-world.action请求转发给/WEB-INF/content/hello-world.jsp。另一方面，我们将JSP文件置于WEB之下，以避免对JSP文件的任何直接访问。我说的对吗？！如果是，我们可以禁用此功能吗？
浏览 1提问于2013-12-27得票数 3
回答已采纳
我配置了一个Flink 1.15.1作业如果出现以下错误，就会失败
Sink: Committer (2/2)#732Caused by: org.apache.kafka.common.config.ConfigException: Invalid value for configuration transactional.id
浏览 22提问于2022-11-07得票数 1
云服务器
ICP备案
对象存储
云点播
实时音视频
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号