После борьбы более 3 часов я вынужден спросить об этом. ОШИБКА в этих строках кода:
configProperties.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG,"org.apache.kafka.connect.json.JsonSerializer");
org.apache.kafka.clients.producer.Producer producer = new KafkaProducer(configProperties);
Заранее спасибо !!!