[fix][io] KCA: handle kafka sources that use commitRecord#20121

dlg99 merged 2 commits into

apache:masterapache/pulsar:masterfrom

dlg99:kca-commitrecord-masterdlg99/pulsar:kca-commitrecord-masterCopy head branch name to clipboard