我正在使用confluent-3.0.1平台并构建kafka elasticsearch连接器。为此，我扩展了sinkconnector和sinktask（kafka连接api）以从kafka获取数据。
作为这段代码的一部分，我扩展了sinkconnector的taskconfigs方法以返回“max.poll.records”，一次只获取100条记录。但它不工作，我在同一时间得到所有记录，我没有提交规定的时间内抵消。请任何人帮我配置“max.poll.records”

public List<Map<String, String>> taskConfigs(int maxTasks) {
    ArrayList<Map<String, String>> configs = new ArrayList<Map<String, String>>();
    for (int i = 0; i < maxTasks; i++) {
      Map<String, String> config = new HashMap<String, String>();
      config.put(ConfigurationConstants.CLUSTER_NAME, clusterName);
      config.put(ConfigurationConstants.HOSTS, hosts);
      config.put(ConfigurationConstants.BULK_SIZE, bulkSize);
      config.put(ConfigurationConstants.IDS, elasticSearchIds);
      config.put(ConfigurationConstants.TOPICS_SATELLITE_DATA, topics);
      config.put(ConfigurationConstants.PUBLISH_TOPIC, topicTopublish);
      config.put(ConfigurationConstants.TYPES, elasticSearchTypes);
      config.put("max.poll.records", "100");

      configs.add(config);
    }
    return configs;
  }