Пн go коннектор кафка, вопрос по десериализатору

Question

Я использую kafka connect, чтобы читать данные из mon go и записывать их в kafka topi c. Я использую исходный разъем mon go kafka. Сообщение, поступающее на мой слушатель, выдает следующее исключение, когда я пытаюсь десериализатор.

(although at least one Creator exists): no String-argument constructor/factory method to deserialize from String value

почему указанная выше ошибка?

Answer 1

мои соединители имели org.apache.kafka.connect.json.JsonConverter вместо org.apache.kafka.connect.storage.StringConverter. Это решило проблему.

Также весной при инициализации прохода JsonDeserializer в настраиваемом objectMapper, например, как показано ниже

objectMapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false); objectMapper.registerModule(new JavaTimeModule());

надеюсь, это кому-то поможет