我想使用Apache Pulsar连接器在Elasticsearch中将JSON模式存储为{"name"："Jane"，"age"：25，...}。我试过使用这个数字，但我只能使用{ ：number}结构存储JSON。有人能帮我吗？
浏览 27提问于2021-03-06得票数 0
我是Elastic search的新手，我的问题是“我想在Elastic search数据库中存储大量的日志文件。我很困惑数据文件是如何存储的? elastic search应该存储哪种类型的文件?Elastic search是否只存储结构化数据文件(JSON格式文件或其他结构格式)？或者它也会存储非结构化数据？”
谢谢。
浏览 0提问于2018-05-07得票数 0
我正在尝试从apache 7.1.X版本连接elasticsearch作为输出连接器，但ManifoldCF.Using elasticsearch 7.1.X不工作。你能建议maniFoldCF在最新的elasticsearch版本上工作吗？ 已尝试使用elasticsearch配置存储库和输出插件。已执行作业，但在elasticsearch中未找到任何内容。应将数据从存储库爬行
浏览 40提问于2019-09-24得票数 0
Apache版本为1.1.3，elasticsearch为5.1.1。flink文档仅为ElasticSearch2.xAPI(flink-连接器-弹性搜索2_2.1.1) 解释Flink异常
01/03/2017 20:01:21 Job
浏览 6提问于2017-01-04得票数 0
我正在使用Elasticsearch-hadoop连接器运行PySpark和Elasticsearch。我可以使用以下方法从所需的索引中读取： "es.nodes": "127.0.0.1", sc = SparkContext(conf=conf)
浏览 1提问于2016-04-15得票数 0
回答已采纳
，并将NAR包复制到容器中的Pulsar连接器目录$PULSAR_HOME/connectors。我使用了类似于所描述的的配置，并将tablePath值与我的miniO路径重新放置在一起。我将文件命名为sink-connector-config.json。sink-connector-config.json2022-09-06T16:53:08,396+0000 [main] INFO org.apache.
浏览 19提问于2022-09-20得票数 1
回答已采纳
我在一个主题消息中接收到一个非常复杂的json，所以我想使用它进行一些计算，并发送给不同的elasticsearch indice文档。有可能吗？
我无法找到解决这个问题的办法。
浏览 6提问于2022-11-11得票数 0
我们在执行使用Kafka连接器将来自Kafka主题的消息发送到Elasticsearch的顺序时遇到了问题。在主题中，消息的顺序是正确的，有正确的偏移，但是如果有两条具有相同ID的消息被快速地连续创建，它们就会间歇地以错误的顺序发送到Elasticsearch。文档声明：
通过使用分区级Kafka偏移量作为文档版本，并使用version_mode=external，确保了文档级的更新顺序。
浏览 1提问于2019-01-17得票数 1
回答已采纳
我将事件日志加载到elasticsearch引擎中，并使用Kibana将其可视化。我的事件日志实际上存储在Google Big Query表中。目前，我正在将json文件转储到Google存储桶中，并将其下载到本地驱动器。然后使用logstash将json文件从本地驱动器移动到elastic搜索引擎。现在，我正试图通过在google大查询和弹性搜索之间建立联系来自
浏览 4提问于2016-08-31得票数 7
我使用kafka connect elasticsearch连接器将主题中的数据写入ElasticSearch索引。主题消息的key和value均为json格式。由于以下错误，连接器无法启动： &q
浏览 0提问于2018-04-13得票数 0
尝试使用以下配置创建elasticsearch接收器连接器，创建成功，但当在"my.topic.one“上生成消息时，ES接收器连接器在尝试创建名为"my.topic.one”的索引时失败：“无法创建索引为什么它试图创建一个新的索引，以及如何让连接器索引到以前创建的"elasticsearch_index_name"？",
浏览 19提问于2020-05-20得票数 0
我有一个mongodb->kafka >elasticsearch将数据端发送到端OK的kafka-connect流，但是有效负载文档是JSON编码的。这是我的原始mongodb文档。transforms.RenameTopic.regex": "redacted.redacted_Redacted", }在<
浏览 3提问于2018-11-06得票数 1
我们在EMC Documentum中提供了大量pdf文档我们有一个要求，我们必须将Apache Solr与Documentum集成，以便我们可以在solr中搜索特定文档，并从Documentum获取文档
浏览 0提问于2016-05-19得票数 0
我正在尝试将我的Kafka主题中Json中的长/纪元字段转换为通过连接器推送的Elasticsearch日期类型。这是版本6的一个突破性变化，我相信每个索引只能有一个映射。、时间或日期来翻译连接器中的源消息。at org.apache.kafka.connect.json.JsonConverter.convertToJson(JsonConverter.java:604)
at org.apache</em
浏览 15提问于2019-09-24得票数 4
回答已采纳
1回答
我正在尝试运行，但我不想将数据转移到Elasticsearch，我想使用InfluxDB。# Download connector libraries
RUN wget -P /opt/flink/lib/ https://repo.maven.apache.org
浏览 3提问于2022-06-13得票数 1
回答已采纳
我正在为Flink 1.14.4编写一个简单的连接器(源/接收器)，它主要封装官方的Kafka连接器，并自动设置ups自定义序列化程序/反序列化器。我对和中引入的新源代码/接收器接口的当前状态有点困惑。目前是否可以编写统一的连接器，真的(也就是说，跨不同API(如DataStream/Table)的连接器)？通过查看当前Kafka连接器的代码，我看到它具有传统的和新的风格，但是用于Table的连接器AFAIK仍然只依赖于遗留API
浏览 10提问于2022-04-13得票数 1
回答已采纳
我正在尝试为Elasticsearch 6.x开发一个Kafka连接Sink连接器如何在使用ES接收器连接器时提供自定义_routing值。例如，如果我的文档在Kafka消息的值中有字段'customerId‘，我如何选择它的值作为，从而使文档位于正确的文本碎片中。
浏览 4提问于2021-04-21得票数 0
我使用elasticsearch连接器对从kafka到Elasticsearch的流数据进行连接，我还有下一个问题。}对于这些数据，我在elasticsearch中有下一个索引模板 "version": 1, "value.converter": "org.apach
浏览 10提问于2022-11-04得票数 0
回答已采纳
我注意到，使用kafka elasticsearch连接器在elasticsearch中索引的文档的ids格式如下：topic+partition+offset。我更喜欢使用由elasticsearch生成的id。似乎topic+partition+offset通常不是独一无二的，所以我是。
我如何才能改变这一点？
浏览 0提问于2017-07-11得票数 1
我正在使用kafka -connect Elasticsearch插件从我的kafka获得消息到Elasticsearch。我在kafka中的数据包含一个日期字段(时间戳格式)。我的第一个问题是当我使用这个插件时，Elasticsearch索引没有将日期字段识别为日期类型，而是识别为一个长的.我在连接器配置中使用SMT转换来解决这个问题。下面是我当前的配置，它允许我在弹性中
浏览 0提问于2018-12-25得票数 3
回答已采纳
云服务器
ICP备案
对象存储
实时音视频
云直播
腾讯云开发者
