int preferredLocalParallelism() {
        if (options.containsKey(SqlConnector.OPTION_PREFERRED_LOCAL_PARALLELISM)) {
            return Integer.parseInt(options.get(SqlConnector.OPTION_PREFERRED_LOCAL_PARALLELISM));
        }
        return StreamKafkaP.PREFERRED_LOCAL_PARALLELISM;
    }
@Test
    public void when_preferredLocalParallelism_isNotDefined_then_useDefault() {
        KafkaTable table = new KafkaTable(
                null, null, null, null, null, null, null,
                emptyMap(),
                null, null, null, null, null
        );

        assertThat(table.preferredLocalParallelism())
                .isEqualTo(StreamKafkaP.PREFERRED_LOCAL_PARALLELISM);
    }