private void onFailure(final Throwable exception, final long responseTimeMs) {
        this.heartbeatRequestState.onFailedAttempt(responseTimeMs);
        this.heartbeatState.reset();
        if (exception instanceof RetriableException) {
            String message = String.format("ShareGroupHeartbeatRequest failed because of retriable exception. " +
                            "Will retry in %s ms: %s",
                    heartbeatRequestState.remainingBackoffMs(responseTimeMs),
                    exception.getMessage());
            logger.debug(message);
        } else {
            logger.error("ShareGroupHeartbeatRequest failed due to fatal error: {}", exception.getMessage());
            handleFatalFailure(exception);
        }
    }
Reset the poll timer, indicating that the user has called consumer.poll(). If the member
is in {@link MemberState#STALE} state due to expired poll timer, this will transition the
member to {@link MemberState#JOINING}, so that it rejoins the group.
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ShareHeartbeatRequestManager.java