1回答
\":1594566354199}", "created_on":1594595154280
} 我想更进一步，只提取customer_code字段。**更新** 我正在使用connect-standalone worker.properties sqlserver.properties运行Kafka Connect。worker.properties offset.stor
浏览 16提问于2020-07-12得票数 1
my_name","SETTING_KEY":"my_setting_key"}name=data.app_settingtimestamp.column.name=LAST_MOD_DATE
key.converter=org.apache.kafka.connect.
浏览 1提问于2018-10-10得票数 7
回答已采纳
Kafka中可用的消息/数据是AVRO格式的，因此我试图使用AVRO转换器通过提供模式注册表详细信息来解析数据。但是，在使用该消息时，我看到了一个DataError异常。 "topics": "mytopic",
"connector.class": "streams.kafka.connect.sink.Neo4jSinkConnector",errors.deadletterqueue.topic.re
浏览 12提问于2022-05-11得票数 0
我使用kafka RMQ源连接器从RMQ队列获取数据。其中一个字段是base64encoded，它具有json结构。我正在使用提取转换来提取这个字段，但是我不确定如何解码这个字段，我试图编写自己的smt来解码这个字段，但是当我解码这个字段并试图将它放入记录的updatedvalue中时，我得到了错误的java.lang.ClassCastException{
"name" : "RabbitMQ_
浏览 26提问于2020-03-30得票数 0
回答已采纳
我正在尝试使用一个kafka连接JDBC接收器连接器与avro。但是当我尝试启动连接器时，我一直收到以下两个错误：
java.lang.NoClassDefFoundError: io/confluent/connect/avro/AvroConverterConfig
浏览 1提问于2020-02-17得票数 0
我使用Fluentd将日志转发到Kafka，然后将它们存储在Cassandra中以备后用。为此，我使用kafka-cassandra接收器连接器。如何做到这一点？topics=test_AF1
connect.cassandra.kcql=INSERT INTO test_event1 SELECT now() as id, messageas msg FROM test_AF1 TIMESTAMP=sys_tim
浏览 0提问于2019-07-18得票数 0
specify the format of data in Kafka and how to translate it into Connect data.from or stored into Kafkavalue.converter==org.apache.kafka.connect.json.JsonConverter
internal.value
浏览 0提问于2019-07-26得票数 2
使用合流社区包在DC/OS上运行Kafka 4.1.1。我们如何上传或添加jdbc驱动程序到远程集群？
更新:它是一个安装了DC/OS目录的包，它是一个mesos框架，运行的是docker映像。
浏览 1提问于2018-11-11得票数 1
1回答
将Avro消息发送到Kafka主题的代码 io.confluent.kafka.serializers.KafkaAvroSerializer.classprops.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG,
io.confluent.kafka.serializers.KafkaAvroSeria
浏览 4提问于2017-10-05得票数 0
from or stored into Kafkavalue.converter=org.apache.kafka.connect.json.JsonConverter at org.apache.<e
浏览 3提问于2020-01-14得票数 0
回答已采纳
因此，我希望仅当插入操作发生时，才从mysql数据库用户表中提取电子邮件字段的值。", "key.converter.schemas.enable$Value", }
浏览 5提问于2022-04-12得票数 0
1回答
在核心方面，我们正在使用kafka代理来分发事件。数十种设备都会产生卡夫卡主题的事件(每种类型的事件都有一个kafka主题)，其中事件在google的protobuf中被序列化。我们需要的是，对于一些事件，我们需要应用一些转换，然后将转换输出发布到其他kafka主题。当然，卡夫卡流是实现这一目标的一种方式，。我们可以有几个工作人员，我们可以将他们部署到一个kafka连接实例/或集群中。问题是；
用卡夫卡连接从一个卡夫卡主题获取信息并发送到另一个卡夫卡主题有意义吗？
浏览 6提问于2021-03-20得票数 0
回答已采纳
主要的事情是我想使用CDC方法将Azur SQL连接到confluent kafka，然后我想把数据放到s3中。
浏览 9提问于2019-09-05得票数 0
我设置了一个Kafka Connect配置来从DB2拉取数据。我使用的不是Avro，而是开箱即用的json。
浏览 15提问于2020-02-01得票数 0
大多数博客声明将Kafka特定的文件或项目jars放在Kafka目录中。我使用brew安装了Kafka，因此在查找位置和跟踪大多数KafkaConnect博客时遇到了困难。
浏览 8提问于2022-11-13得票数 0
回答已采纳
ReplaceField转换仅用于替换或屏蔽字段名，还是可以使用某些表达式使用静态值更改字段的值？
在发表到卡夫卡主题之前，我需要将两个字段的价值连接起来。
浏览 1提问于2018-11-09得票数 0
是否可以在不对getLatestSourceOffset()进行额外检查的情况下修复它，比如添加字段以确定它是否是第一次轮询？或者没有办法避免它，我们应该增加检查？at org.apache.kafka.connect.json.JsonConverter.toConnectData(JsonConverter.java:309)
at org.apache.kafka.connect.storage.OffsetStorageReaderImpl.offsets(OffsetStorag
浏览 13提问于2022-06-19得票数 0
我已经实现了一个Kafka Connect JDBC Source连接器，它连接到Oracle-Database，并将数据写入Kafka-Topic。目前，我已经在设置value.converter.schemas.enable=false的情况下设置了选项value.converter=org.apache.kafka.connect.json.JsonConverter该选项允许将JSON数据写入Kafka主题(顺便说一句，它工作得很好)，但不包括在将数据发送到Kafka</
浏览 3提问于2021-02-18得票数 0
云服务器
ICP备案
云直播
即时通信 IM
对象存储
腾讯云开发者
