class SubscriptionState {

    public synchronized boolean subscribe(Set<String> topics, ConsumerRebalanceListener listener) {
        registerRebalanceListener(listener);
        setSubscriptionType(SubscriptionType.AUTO_TOPICS);
        return changeSubscription(topics);
    }

    public  SubscriptionState(LogContext logContext, OffsetResetStrategy defaultResetStrategy);

}