private Map<TopicIdPartition, Acknowledgements> acknowledgementsToSend() {
        return currentFetch.takeAcknowledgedRecords();
    }
Returns any ready acknowledgements to be sent to the cluster.
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ShareConsumerImpl.java