Protobuf To Kafka Topic

Note that it is not correct in general to pass all incoming metadata with the response (from actionContext).metadata()), it includes message attributes like cloud event id, content-type and ce-type for the incoming message which should not be set the same for your outgoing message. Better to only define the ce-subject field like I suggested.