public static final StreamConfiguration encode ( final StreamConfig config ) { Preconditions . checkNotNull ( config , "config" ) ; return StreamConfiguration . builder ( ) . scalingPolicy ( encode ( config . getScalingPolicy ( ) ) ) . retentionPolicy ( encode ( config . getRetentionPolicy ( ) ) ) . build ( ) ; }
Helper to convert StreamConfig into Stream Configuration Impl .