class StreamPartitionAssignor implements PartitionAssignor, Configurable {

    void setInternalTopicManager(InternalTopicManager internalTopicManager) {
        this.internalTopicManager = internalTopicManager;
    }

}