[
https://issues.apache.org/jira/browse/KAFKA-7404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Oleg Kuznetsov updated KAFKA-7404:
----------------------------------
Description:
Now Source connector can generate lots of events without considering how fast
broker can consume them.
Proposal is simple: add optional parameter *max.queue.size* and pause polling
until current buffer is less this size.
was:
Now Source connector can generate lots of events without considering how fast
broker can consume them.
Proposal is simple: add optional parameter *max.records.to.send* and pause
polling until current buffer is less this size.
> SourceConnector backpressure
> ----------------------------
>
> Key: KAFKA-7404
> URL: https://issues.apache.org/jira/browse/KAFKA-7404
> Project: Kafka
> Issue Type: Improvement
> Components: KafkaConnect
> Affects Versions: 1.1.0
> Reporter: Oleg Kuznetsov
> Priority: Major
>
> Now Source connector can generate lots of events without considering how fast
> broker can consume them.
> Proposal is simple: add optional parameter *max.queue.size* and pause polling
> until current buffer is less this size.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
