elasticsearch - 融合弹性搜索接收器正则表达式分配给所有主题并发送到索引
问题描述
我有多个这样的主题
client1-table1
client1-table2
client1-table3
client1-table4
我希望我的弹性搜索接收器侦听任何传入消息并将它们相应地发送到索引。但是我当前的配置不起作用......我能做什么......下面是我的弹性搜索接收器
{
"name": "es-data",
"config": {
"_comment": "-- standard converter stuff -- this can actually go in the worker config globally --",
"connector.class": "io.confluent.connect.elasticsearch.ElasticsearchSinkConnector",
"value.converter": "io.confluent.connect.avro.AvroConverter",
"key.converter": "io.confluent.connect.avro.AvroConverter",
"key.converter.schema.registry.url": "http://localhost:8081",
"value.converter.schema.registry.url": "http://localhost:8081",
"_comment": "--- Elasticsearch-specific config ---",
"_comment": "Elasticsearch server address",
"connection.url": "http://127.0.0.1:9200",
"_comment": "If the Kafka message doesn't have a key (as is the case with JDBC source) you need to specify key.ignore=true. If you don't, you'll get an error from the Connect task: 'ConnectException: Key is used as document id and can not be null.",
"key.ignore": "true"
}
}
解决方案
推荐阅读
- c# - 如何删除 Windows IoT 中的工具栏?
- google-app-maker - 选择数组中的项目
- prolog - 如何在 Prolog 中捕获回溯(或定界继续)异常?
- xml - 从 VB.NET 中的 XML 文件中提取特定节点
- r - unzip() 正在覆盖文件,即使使用 overwrite = FALSE
- javascript - 如何观察原始 JS ES6 自定义元素中计算的 css 属性的变化
- angular - 外部 Geodaya 语法问题
- git - 如何从 BitBucket git 存储库历史记录中删除带有密码的提交?
- angular - 初始化后将数据传递给 HttpInterceptor
- docker - Docker 缓存 - 即使我删除了 .git 存储库,构建也很大