Kafka Request Body

payload, err := json.Marshal(&r.Body)
if err != nil {
    p.logger.ErrorWithContext(r.Context(), err)
    w.Commit(kafkalib.StatusFailedPrecondition)
    return
}

if err := p.uc.EventStore.ProcessEventStore(r.Context(), string(payload[:])); err != nil {
    p.logger.ErrorWithContext(r.Context(), err)
    w.Commit(kafkalib.StatusFailedPrecondition)
    return
}