there is several things need pay attention: - try to make pulsar client also could read the added batch messages. - the original offset of each Record map to Pulsar BatchMessageId.
there is several things need pay attention: