我正在使用kafka_2.11-0.10.2.1和由google 提供的pubsub连接器。我所要做的就是使用独立的连接器将数据从卡夫卡主题推送到PubSub主题。due to serialization error: at com.fasterxml.jackson.databind.ObjectMapper.readT
浏览 0提问于2017-05-04得票数 3
回答已采纳
at org.apache.kafka.connect.json.JsonConverter.toConnectData(JsonConverter.java:309)worker.propertieskey.c
浏览 13提问于2022-06-19得票数 0
true","pk.mode":"record_value","value.converter": "org.apache.kafka.connect.json.JsonConverter",
"value.converter.schemas.enable":
浏览 2提问于2020-04-18得票数 1
回答已采纳
我想使用JSON和没有模式的JDBC接收器连接器。他们编写()：
key.converter=org.apache.kafka.connect.json.JsonConverter value.converter=org.apache.kafka
浏览 9提问于2021-07-16得票数 2
回答已采纳
我有一个Kafka连接器，为poll()实现中的SourceTask方法提供了以下代码。type":"string","optional":false},"payload":"bar"}echo -e 'foo,bar' > /tmp/test_kafka.txtcat /tmp/test_kafka.txt | kafka-c
浏览 1提问于2016-11-30得票数 0
回答已采纳
1回答
我有一个应用程序，它周期性地用原始JSON生成一系列消息。我可以用Avro工具把它转换成avro。我这样做是因为由于Kafka接收器的限制，我需要消息包含模式。我可以在notepad++上打开这个文件，并看到它包括模式和几行数据。
现在，我想将它发送给我的中心Kafka代理，然后使用Kafka接收器将数据放入数据库。
浏览 3提问于2021-03-31得票数 0
回答已采纳
1回答
Aurora记录将是文本，我需要将记录作为JSON放在MSK中，所以我必须使用模式注册表？模式注册是免费许可还是开源？，如果我必须使用来自汇合或debezium的kafka -connect，我需要EC2实例.In，这是我需要安装的吗？只有卡夫卡或卡夫卡与卡夫卡汇合在一起，也与卡夫卡融为一体。--
请提出一些免费许可和开放源码的建议。
浏览 2提问于2019-12-31得票数 0
回答已采纳
_2.12-3.0.0/config/connect-standalone.properties中，我添加了连接器和转换器：
plugin.path=/home/user/kafkaConnectors/confluentinc-kafka-connect-jdbc-10.3.2,/home/user/kafkaConverters/confluentinc-kafka-connect-json-schema-convert
浏览 12提问于2022-02-08得票数 0
回答已采纳
1回答
我正试图使用apache-kafka二进制文件中的kafka-控制台-生产者来生成消息，并在春季启动时从消费者设置中消费。使用者使用avro架构。当以json格式生成消息时，我的使用者抛出异常--“无法序列化”。
我找到了一个解决方案来使用“7.1”，其中有kafka-avro-console-producer。它支持avro，但它是企业版。是否有一种方法可以使用apache-kafka与kafka控制台生产者一起使用avro模式来生
浏览 6提问于2022-04-26得票数 0
回答已采纳
1回答
expand=info&expand=status{ "info":{
"name":"sink_postgres:472)\n\tat org.apache.kafka.connect.runtime.WorkerSinkTask.poll(WorkerSinkTask.java:322)\n\tat org.apache.k
浏览 1提问于2021-01-11得票数 1
回答已采纳
我正在为kafka ()和JsonEventParser使用hbase接收器连接器，这里我遇到了一些问题。at org.apache.kafka.connect.json.JsonConverter.toConnectData(JsonConverter.java:308)
at org.apache.kafka.connect.runtime.WorkerSinkTask.convertMessagesvalue.converter=org.apach
浏览 0提问于2018-12-07得票数 0
回答已采纳
从读取数据流到Apache的标准方法是： .format("json") \ # or parquet, kafka, orc# format specific options .load("path/to/data")even
浏览 4提问于2017-11-10得票数 1
回答已采纳
我希望得到一些您的专业知识，什么是最好/最有效的方式来同步某些表从客户端数据库到主数据库和其他表从主数据库到客户端数据库在接近实时(在几分钟内)。
浏览 19提问于2020-04-09得票数 1
1回答
按照这里的问题和建议：，我试图使用红移连接器和用python编写的生产者将记录合并为红移。confluent.topic.replication.factor=1auto.create=true
key.converter=org.apache.kafka.connect.storage.StringConvertervalue.converter=org.apache.kafka.connect.<
浏览 9提问于2022-11-23得票数 0
回答已采纳
MSSQL值:列name=prop -> value= 100和列name=role -> value= {“角色”：“参与者”}，{“角色”：“主管”}注意:列:角色以json格式保存。transforms.InsertKey.fields=prop
transforms.extractInt.
浏览 2提问于2020-05-05得票数 0
现在，我需要创建一个Kafka来使用这条AVRO消息，将它转换为Json，然后在Redis DataBase上编写它。 "value.converter": "org.apache.kafka.connect.json.JsonConverter",
"transforms": "createKey, extractStr&q
浏览 5提问于2021-06-24得票数 0
回答已采纳
我正在尝试通过Pepper-Box纯文本配置发送大尺寸的Json，并获得异常：at java.lang.ClassLoader.defineClass1:5.2.1]at org.apache.jmeter.control
浏览 0提问于2020-05-26得票数 0
1回答
我希望使用下面的连接器配置将多个表数据发布到同一个Kafka主题上，但下面是异常。异常连接器似乎忽略了主题策略属性集，并一直使用旧的${topic}-key和${topic}-value subject。curl -i -X POST -H "Accept:application
浏览 1提问于2019-04-25得票数 1
我想使用一个kafka连接jdbc接收器连接器与avro转换器。io.confluent.connect.avro.AvroConverter",架构设置为key.converter.schemas.enable=false现在，当我启动连接器时，我得到这个错误
原因:Struct值架
浏览 4提问于2020-02-19得票数 1
但是，我无法在DeSerialzer中设置序列化器、DeSerialzer属性和其他生产者和使用者属性。我始终会得到序列化/反序列化错误。甚至卡夫卡在春季启动项目中的日志显示，生产者和消费者配置仍然是用户ByteArraySerializer。下面是相同的代码。<?"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.
浏览 1提问于2020-02-21得票数 0
回答已采纳
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号