Closed ylcolala closed 4 years ago
By the way, if I use input->input.print(printed.tosysout()), it can show the avro data. however, any other operations like mapValues throw this exception. And I code kafka stream without spring cloud stream to pull the topic, it works.
@ylcolala Can you provide a small sample where we can run and reproduce the issue?
I recode the project without my old project code. And it works. So I guess it's a version confliction. And I will migrate my old project code to new project which it works, step by step. Thank you for you help anyway. Now I close the issue.
Context: Spring Cloud Stream + Kafka streams +confluent schema registry 5.2.2 + Spring cloud dependency version Hoxton.RELEASE
My configuration:
Error details:
Actually, I followed the spring cloud stream kafka stream example. There is still an error. How can I fix it? Thank you very much.