mongodb - 如何修复来自设置为源的 kafka-mongo-connector 的消息 ID
问题描述
我正在尝试将 kafka-mongo-connector 添加到 kafka-connect 作为事件的来源。我正在设置这样的连接器:
{"name": "mongo-source",
"config": {
"tasks.max":"1",
"connector.class":"com.mongodb.kafka.connect.MongoSourceConnector",
"connection.uri":"mongodb://mongo1:27017,mongo2:27017,mongo3:27017",
"key.serializer": "org.apache.kafka.common.serialization.JSONSerializer",
"value.serializer": "org.apache.kafka.common.serialization.JSONSerializer",
"key.serializer.schemas.enable": "false",
"value.serializer.schemas.enable": "false",
"topic.prefix":"mongo",
"database":"test",
"collection":"pageviews"
}}' http://localhost:8083/connectors -w "\n"
数据进来了,但关键是奇怪的格式:{"_id": {"_data": "....:}}
.
因此,我无法插入 Elasticsearch 接收器连接器。
有人有解决方案吗?
谢谢,
弗朗切斯科
解决方案
推荐阅读
- javascript - Windows onload 事件不适用于自定义 javascript 结构
- tvml - 在 tvOS TVML 中处理/捕获视频流错误和重定向的方法
- git - 在詹金斯管道作业中使用 git 存档而不是使用凭据进行克隆
- java - 从 ThreadPoolTaskScheduler 池 Spring 中删除任务
- parameter-passing - 在空手道中使用字符串构建请求的嵌入式表达式
- python - Pandas 替换 DataFrame 值
- r - event_data(“plotly_hover”)中的错误?( r 情节,闪亮)
- css - 用于生产的 CSS 网格?
- c# - 如何使用缩进的 xml 消息创建 NLog XmlLayout?
- python - 为什么我的 Flask 应用程序无法在 Google App Engine 上正常运行?