public static Builder<String, String> builder(String bootstrapServers, String... topics) {
        return new Builder<String, String>(bootstrapServers, topics).withStringDeserializers();
    }
@Test
    public void testThrowsIfEnableAutoCommitIsSet() {
        Assertions.assertThrows(IllegalStateException.class, () -> KafkaSpoutConfig.builder("localhost:1234", "topic")
            .setProp(ConsumerConfig.ENABLE_AUTO_COMMIT_CONFIG, true)
            .build());
    }