oscerd commented on issue #1340: URL: https://github.com/apache/camel-kafka-connector/issues/1340#issuecomment-6632172233
Sorry this went unanswered. On the source side, records are handed to Kafka Connect in batches bounded by `camel.source.maxBatchPollSize` (default 1000 records per poll) and `camel.source.maxPollDuration` (default 1000 ms), and messages waiting for the task are buffered in an internal queue sized by `camel.source.pollingConsumerQueueSize` (default 1000); see https://camel.apache.org/camel-kafka-connector/next/user-guide/basic-configuration.html. Batching of the actual produce requests is done by the Kafka producer (`batch.size`, `linger.ms`), which you can override per connector with `producer.override.*` if the worker's `connector.client.config.override.policy` allows it. Closing this as a usage question; if these options do not behave as documented with camel-salesforce-source-kafka-connector on 4.22.x, please open a new issue with your configuration. --- _Claude Code on behalf of Andrea Cosentino_ -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
