Не удалось закрыть значение valueSerializer производителя для значения JSON в kafka - PullRequest
0 голосов
/ 16 апреля 2020

После борьбы более 3 часов я вынужден спросить об этом. ОШИБКА в этих строках кода:

configProperties.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG,"org.apache.kafka.connect.json.JsonSerializer");
org.apache.kafka.clients.producer.Producer producer = new KafkaProducer(configProperties);

Заранее спасибо !!!

...