Как исправить идентификатор сообщения от kafka-mongo-connector, установленного в качестве источника - PullRequest
Новая
       43

Как исправить идентификатор сообщения от kafka-mongo-connector, установленного в качестве источника

0 голосов
/ 08 октября 2019

Я пытаюсь добавить 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 разъем для мойки.

У кого-нибудь есть решение для него?

Спасибо,

Франческо

...