to work with topics with heterogeneous types, you must provide additional information to the schema. Configure the deserializer with derive_type=true, and then specify either java_outer_classname or java_multiple_files=true in the schema.
Configure the deserializer with derive_type=true
Как!... как его сконфигурировать с этой опцией, где написано?
props.put(KafkaProtobufDeserializerConfig.DERIVE_TYPE_CONFIG,true); помогло, и он автоматически выводит тип сообщения, из схемы...
Обсуждают сегодня