You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Describe the bug
When connector is deployed to read from topics that contains large amounts of record, after some time the connector throws out of memory exception.
Cause
Kafka connect consumer thread keeps on consuming records from the Kafka when connector is busy processing the records in buffer. This leads to Kafka connect running out of memory.
Expected behavior
When the connector starts processing the records in the buffer, it should pause consuming records from the Kafka topic, only once the processing is complete it should resume the consumer.
The text was updated successfully, but these errors were encountered:
Describe the bug
When connector is deployed to read from topics that contains large amounts of record, after some time the connector throws out of memory exception.
Cause
Kafka connect consumer thread keeps on consuming records from the Kafka when connector is busy processing the records in buffer. This leads to Kafka connect running out of memory.
Expected behavior
When the connector starts processing the records in the buffer, it should pause consuming records from the Kafka topic, only once the processing is complete it should resume the consumer.
The text was updated successfully, but these errors were encountered: