### Question:
KafkaSinkConnector extends SinkConnector { @Override public List<Map<String, String>> taskConfigs(int totalConfigs) { return IntStream.range(0, totalConfigs).mapToObj(i -> config).collect(Collectors.toList()); }  @Override String version(); @Override void start(Map<String, String> taskConfig); @Override Class<? extends Task> taskClass(); @Override List<Map<String, String>> taskConfigs(int totalConfigs); @Override void stop(); @Override ConfigDef config(); static final String PRODUCER_PREFIX; }### Answer:
@Test public void taskConfigs() { connector.start(startConfig); assertThat(connector.taskConfigs(3), is(Arrays.asList(taskConfig, taskConfig, taskConfig))); }