Это моя конфигурация. Много чего перепробовал, но потребить не смог.
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