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); помогло, и он автоматически выводит тип сообщения, из схемы...
Обсуждают сегодня