kafka connect的sink connector中put方法一次拉取的消息量如何配置?

@Override
public void put(final Collection<SinkRecord> sinkRecords) {}

如上sinkRecords.size()一直都是四百多，配置过consumer.properties的

max.poll.records
max.partition.fetch.bytes
fetch.min.bytes
fetch.max.wait.ms

都没用

刚开始用kafka connect，希望不吝赐教。

kafka connect的sink connector中put方法一次拉取的消息量如何配置?

@Override
public void put(final Collection<SinkRecord> sinkRecords) {}

如上sinkRecords.size()一直都是四百多,配置过consumer.properties的
max.poll.records
max.partition.fetch.bytes
fetch.min.bytes
fetch.max.wait.ms
都没用
刚开始用kafka connect,希望不吝赐教