Extended internal API to be able to read kafka message key