private void scheduleConsumerGroupJoinTimeoutIfAbsent(
        String groupId,
        String memberId,
        int rebalanceTimeoutMs
    ) {
        timer.scheduleIfAbsent(
            consumerGroupJoinKey(groupId, memberId),
            rebalanceTimeoutMs,
            TimeUnit.MILLISECONDS,
            true,
            () -> consumerGroupFenceMemberOperation(groupId, memberId, "the classic member failed to join within the rebalance timeout.")
        );
    }
Schedules a join timeout for the member if there's not a join timeout.

@param groupId               The group id.
@param memberId              The member id.
@param rebalanceTimeoutMs    The rebalance timeout.
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java