Having problem with specific.protobuf.value.type in yaml config using Spring Cloud Kafka binder about demo-scene HOT 5 CLOSED

Thanks, Mike @mperrault
I will look into this

from demo-scene.

Thanks!

from demo-scene.

hi @mperrault

It looks like you have some complex code there. Some of the components managed by SCS. some of them plain spring-kafka.
Could you simplify your problem in 2-3 sentenses so I can write SCS app from the scratch to reproduce problem with protobuf serializer.
Thank you

from demo-scene.

• Refer to Confluent Documentation:
  https://www.confluent.io/blog/spring-for-apache-kafka-deep-dive-part-2-apache-kafka-spring-cloud-stream/
  and section "Overview of Kafka Streams support in Spring Cloud Stream".

• I want to use a protobuf generated class (e.g. PBuffClass1) for the value of input1, and another protobuf generated class for value of input2 (e.g. PBuffClass2). So, the signature of 'process' would look like:
  public KStream<String, Long> process(@input("input1") KStream<String, PBuffClass1> userClicksStream,
  @input("input2") KTable<String, PBuffClass2> userRegionsTable)

• what does this look like in the application.yml file for the Serdes config for input1 and input2 using "specific.protobuf.value.type" ?

from demo-scene.

If this is still an open issue, please post details to https://forum.confluent.io/. Thanks.

from demo-scene.