I am producing events to a topic from Confluent control center.
The topic key is of String type and I am using Serdes.String()
to deserialize it.
streamBuilder.stream[String, MyClass](inputTopic)(Consumed.`with`(Serdes.String(), MyClassSerde))
Because control center only allows json format, I must add quotes when publishing. So "myKey"
instead of myKey
.
But after deserialization the quotes are kept in the key.
Is this is a bug in confluent-cc ? How to send from confluent-cc without quotes ?