private void process(final ShareAcknowledgeSyncEvent event) {
        if (!requestManagers.shareConsumeRequestManager.isPresent()) {
            return;
        }

        ShareConsumeRequestManager manager = requestManagers.shareConsumeRequestManager.get();
        CompletableFuture<Map<TopicIdPartition, Acknowledgements>> future =
                manager.commitSync(event.acknowledgementsMap(), event.deadlineMs());
        future.whenComplete(complete(event.future()));
    }
Process event that indicates the consumer acknowledged delivery of records synchronously.
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/ApplicationEventProcessor.java