Это моя конфигурация. Перепробовал много чего, но не смог потребить. Заблокировано по этому поводу. Пожалуйста, помогите
properties.setProperty("key.deserializer", StringDeserializer.class.getName());
properties.setProperty("value.deserializer", KafkaAvroDeserializer.class.getName());
properties.setProperty("specific.avro.reader", "true");
Подробнее здесь: https://stackoverflow.com/questions/789 ... he-message
Мобильная версия