There is a scenario base on Kafka protocol binding and I'm not sure how to use the sdk to achieve it:

When the cloudevent client receives an event, it returns the NACK response to tell Kafka not to commit the message offset. And also forwards the event to the backend program, when the backend program has completely consumed the event, then submits the offset of the message partition.


If I can't use cloudevents client to submit message offset directly, how can I get the message partition and offset from the cloud event? so that the other progress can use the kafka client to submit this offset once the message is consumed successfully.