I am trying to follow the akka-sample-kafka-to-sharding-scala example, but this and the docs seem to assume that I am able to define a Command trait that my Kafka messages will inherit. I don’t have this luxury.
Is there a workaround for this?
Thanks
The command, which is needed since the events are sent to an actor, so needs to be one of the messages in the actor protocol, is only wrapping the parsed protobuf payload in that sample. You could also have a command that contains the a raw/unparsed bytes or string payload from the record, instead of parsing it, like the sample does here
Got it. Thank you.