rk (1) [Avatar] Offline
I created topic - 'some-topic' but when I try to run the code provided in the example it comes back with an error

Exception in thread "main" org.apache.kafka.common.errors.SerializationException: Can't convert key of class bbejeck.model.PurchaseKey to class org.apache.kafka.common.serialization.StringSerializer specified in key.serializer
Caused by: java.lang.ClassCastException: bbejeck.model.PurchaseKey cannot be cast to java.lang.String

Do I need to use a different serializer as key is of type bbejeck.model.PurchaseKey?
If so how do I write my own serializer?