org. apache .kafka.connect.errors.ConnectException: превышен допуск в обработчике ошибок - PullRequest
Новая
       36

org. apache .kafka.connect.errors.ConnectException: превышен допуск в обработчике ошибок

0 голосов
/ 14 апреля 2020

Я создаю новый коннектор Elasticsearch от kafka и получаю эту ошибку: org.apache.kafka.connect.errors.ConnectException: Tolerance exceeded in error handler

Похоже, это сериализация topi c, но я протестировал оба JsonConverter и AvroConverter в конвертере значений и ключей.

Есть идеи, какая проблема здесь? 

{
  "connector.class": "io.confluent.connect.elasticsearch.ElasticsearchSinkConnector",
  "connection.url": "es-endpoint",
  "tasks.max": "1",
  "topics": "simple.elasticsearch.data",
  "name": "simple-elasticsearch-connector",
  "type.name": "_doc",
  "value.converter": "org.apache.kafka.connect.json.JsonConverter",
  "value.converter.schemas.enable": "false",
  "schema.ignore": "true",
  "key.ignore": "true"
 }

Я следовал за примерами здесь: https://www.confluent.io/blog/kafka-elasticsearch-connector-tutorial/

...