Consumer {
   /**
     * Alert the consumer to trigger a new rebalance by rejoining the group. You should not need to call this during
     * normal processing, as the consumer group will manage itself automatically and rebalance when necessary. However
     * there may be situations where the application wishes to trigger a rebalance that would otherwise not occur,. forFor
     * example, if some condition has changed that external and invisible to the Consumer and its group membership changes in a way that
	 * has implications for the partition assignment, this method can be used to trigger a reassignment. The kind of
	 * system change that would merit calling this method is one that would also be reflected in the Subscription 
	 * userdata that is passed to the assignor so it can make assignment decisions based on more than group membership
	 * and metadata. If your assignor does not use this userdata, or you do not use a custom assignor, you should not
	 * use this API.
     * <p>
     * If a rebalance is already in progress, an exception will be thrown so you can choose to retry or not once the
     * current rebalance completes.
     *
     * @param timeout The maximum amount of time to wait for the rebalance
     *
     * @return Whether the rebalance completed within the given timeout.
     * @throws java.lang.IllegalStateException if the consumer does not use group subscription
     * @throws org.apache.kafka.common.errors.RebalanceInProgressException if a rebalance is already in progress
     * @throws org.apache.kafka.common.KafkaException if the rebalance callback throws an exception
     */
    boolean enforceRebalance(Duration timeout) {
}