сливаемое упругое поисковое регулярное выражение, чтобы назначить на все темы и отправить в индекс - PullRequest
Новая
       62

сливаемое упругое поисковое регулярное выражение, чтобы назначить на все темы и отправить в индекс

0 голосов
/ 21 мая 2018

У меня есть несколько тем, подобных этой 

client1-table1
client1-table2
client1-table3
client1-table4

Я хочу, чтобы мой приемникasticsearch прослушивал любые входящие сообщения и соответственно отправлял их в индекс.Однако мои текущие конфигурации не работают ... что я могу сделать ... ниже мой приемник упругого поиска 

{
  "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"
  }
}
...