Use Apicurio SerDe ProtobufKafkaDeserializer against Confluent SerDe Serialized messages

[AndreaScarselliAx]

Hi all,

I am trying to deserialize Protobuf messages with ProtobufKafkaDeserializer. These messages have been produced using io.confluent.kafka.serializers.protobuf.KafkaProtobufSerializer.

I have already been able to do the same for Avro messages by adding the following to the AvroKafkaDeserializer object:

srConfigs.putIfAbsent(SerdeConfig.ENABLE_CONFLUENT_ID_HANDLER, Boolean.TRUE.toString());
srConfigs.putIfAbsent(SerdeConfig.USE_ID, IdOption.contentId.name());

Doing the same for Protobuf doesn't seem to work, I am actually getting:

org.apache.kafka.common.config.ConfigException: Invalid value java.lang.reflect.InvocationTargetException for configuration Not a valid protobuf builder

Is there anything else needed for Protobuf to work?

Thank you and kind regards,
Andrea