我需要找到或编写一个SMT，它将添加头字段到一个请求。请求缺少一些类型字段，我想添加它们。 如何在SMT中添加标题?我所看到的只是如下所示的记录转换，但如果这是我想要更改或添加字段的标题怎么办？
浏览 13提问于2020-08-07得票数 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
标题怎么说，有一种方法可以设置Kafka JDBC Source连接器从数据库读取的记录的主键吗？这是来自connect-file-source.properties的配置 name=jdbc_source_postgres_foobar_01value.convert
浏览 22提问于2020-10-16得票数 0
"name": "cdc.swip.bi.ods.sink.contract", "connector.class": "io.confluent.connect.jdbc.JdbcSinkConnector"SqlServerDatabaseDialect", "key.converter&
浏览 222提问于2019-07-30得票数 5
回答已采纳
我正在使用Kafka Connect加快速度。尝试使用Kafka Connect Elasticsearch Service接收器连接器将我们的数据从Kafka移动到Elasticsearch。我们的应用程序发布一个删除操作的事件，并将其设置为Kafka消息中标头值的一部分。我们希望删除文档本身，而不是使用此删除操作信息更新elastic中的文档。我们如何使用Kafka Connect来读取这个头值并从Elastic中删除给定密钥的文
浏览 23提问于2021-04-07得票数 0
回答已采纳
我遇到了这样一种情况:我需要在Kafka Connect记录中插入一个新字段，但似乎InsertField转换仅限于静态值。https://docs.confluent.io/current/connect/transforms/insertfield.html 有没有办法根据记录中的其他字段添加动态值？因此，我需要以下字段： "insert.mode": "ups
浏览 24提问于2020-06-09得票数 2
回答已采纳
avro架构中的某些字段不需要在数据库表中下沉。table CLEARING_TEST ID int not null primary key,);
我能忽略卡夫卡连接器中的STAT字段吗
浏览 3提问于2020-02-17得票数 1
回答已采纳
etc/schema-registry/connect-avro-standalone.properties share/confluent-hub-components/confluentinc-kafka-connect-mqtt(org.apache.kafka.connect.runtime.Worker:235)
[2018-12-25 23:07:52,616] INFO Instantiated connectorMyMongoDbSinkConnec
浏览 1提问于2018-12-25得票数 0
我正在使用源连接器从数据库中的视图中读取数据，并将其发布到kafka上，它运行良好。
我的用例是，用户可以创建多个对象，并且对象的顺序在我的应用程序中很重要。我的问题是如何在Kafka连接源连接器中定义消息键？
浏览 1提问于2018-06-21得票数 5
回答已采纳
我想在使用Kafka Connect Source JDBC连接器导入表格时设置mesage键。当有多个表被定义为从JDBC连接器读取时，Kafka Connect/Source中的单个消息转换(SMT)如何针对正确的字段？SMT需要一个列名，当有多个表时，列名可能会有所不同。我没有看到一种根据表名或类似名称过滤SMT定义的方法。下面的代码示例运行良好，因为它只是一个表。
但是，如果您有不同的表，例如User、Order、Product，该怎
浏览 12提问于2019-07-13得票数 2
回答已采纳
"transforms"："TimestampConverter"， "transforms.TimestampConverter.type": "org.apache.kafka.connect.transforms.TimestampConvertertransforms.TimestampConverter.target.type": "string",
"transforms.TimestampConverter.field" :
浏览 15提问于2020-07-26得票数 0
回答已采纳
1回答
过滤数据库中的行
、、
我想知道kafka平台是否适合下面的工作。例如，如果基于日期，将来可能会满足条件，那么是否有机会再次过滤被拒绝的邮件，以最终通过过滤器并进一步处理？在给Kafka提供数据之前先过滤数据行是不是更好？
谢谢。
浏览 9提问于2017-08-11得票数 0
回答已采纳
我们刚开始使用Kafka ( connector )，并且有一个使用JDBC源连接器的项目。使用这种方法，在将数据存储在主题上时，是否也可以对数据进行加密以隐藏个人信息等？
浏览 2提问于2020-10-23得票数 1
回答已采纳
是否可以使用带有Kafka连接的SMT删除嵌套字段？我知道以下几点非常有效："transforms.ReplaceField.type": "org.apache.kafka.connect.transforms.ReplaceField$Value",
"transforms.ReplaceField.blacklist": "Fie
浏览 12提问于2019-10-31得票数 1
回答已采纳
正在尝试将此架构id转换SMT ()应用到mirror maker群集，但它无法识别该SMT。如果我使用SMT作为kafka connect worker配置，它可以正常工作。错误： at org.apache.<
浏览 11提问于2020-05-12得票数 1
Toketi“Hub”提供了以下配置文件(edge节点)tasks.max=1IotHub.EventHubCompatibleName=iothub-toketi
浏览 0提问于2019-04-16得票数 3
1回答
多亏了Debezium的ExtractNewRecordState SMT，我在我的主题中得到了以下信息。\":1594566354199}", "created_on":1594595154267} 添加value.converter.schemas.enable\":1594566354199}",
"payload":"MSG 19"
浏览 16提问于2020-07-12得票数 1
我使用的是jdbc源连接器，我的表名具有DB引擎可以接受的特殊字符(即$)，但是当我使用下面的配置运行kafka-connect时，它试图创建带有这个前缀的kafka主题，加上表名，但是表名上的特殊字符不一定是kafka可以接受的。
浏览 63提问于2019-09-19得票数 0
我用Debezium把这些文档传送到Kafka。我怎样才能让ObjectId被写成卡夫卡的UUID？U06d2Rk4nUG7Fz3iASM9LQ=="), "BrandList" : [ "Sony2", "SUNY2" ],}
Kafka
浏览 4提问于2022-03-03得票数 0
回答已采纳
1回答
"database.server.id": "184054", "database.history.kafka.bootstrap.servers": "kafka:9092",
"database.history.kafka.topic": "schema-changes.inventory&q
浏览 0提问于2020-05-23得票数 2
云服务器
ICP备案
云直播
即时通信 IM
实时音视频
腾讯云开发者
