[jira] [Updated] (KAFKA-8898) if there is no message for poll, kafka consumer also apply memory
[ https://issues.apache.org/jira/browse/KAFKA-8898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] linking12 updated KAFKA-8898: - Priority: Critical (was: Blocker) > if there is no message for poll, kafka consumer also apply memory > - > > Key: KAFKA-8898 > URL: https://issues.apache.org/jira/browse/KAFKA-8898 > Project: Kafka > Issue Type: Bug > Components: consumer >Affects Versions: 2.1.1 >Reporter: linking12 >Priority: Critical > Labels: performance > Attachments: image-2019-10-08-12-07-37-328.png > > > when poll message, but there is no record,but consumer will apply 1000 byte > memory; > fetched = *new* HashMap<>() is not good idea, it will apply memory in heap > but there is no message; > I think fetched = *new* HashMap<>() will appear in records exist; > > ``` > *public* Map>> fetchedRecords() { > Map>> fetched = *new* > HashMap<>(); > *int* recordsRemaining = maxPollRecords; > ``` -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Updated] (KAFKA-8898) if there is no message for poll, kafka consumer also apply memory
[ https://issues.apache.org/jira/browse/KAFKA-8898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] linking12 updated KAFKA-8898: - Attachment: image-2019-10-08-12-07-37-328.png > if there is no message for poll, kafka consumer also apply memory > - > > Key: KAFKA-8898 > URL: https://issues.apache.org/jira/browse/KAFKA-8898 > Project: Kafka > Issue Type: Bug > Components: consumer >Affects Versions: 2.1.1 >Reporter: linking12 >Priority: Blocker > Labels: performance > Attachments: image-2019-10-08-12-07-37-328.png > > > when poll message, but there is no record,but consumer will apply 1000 byte > memory; > fetched = *new* HashMap<>() is not good idea, it will apply memory in heap > but there is no message; > I think fetched = *new* HashMap<>() will appear in records exist; > > ``` > *public* Map>> fetchedRecords() { > Map>> fetched = *new* > HashMap<>(); > *int* recordsRemaining = maxPollRecords; > ``` -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Updated] (KAFKA-8898) if there is no message for poll, kafka consumer also apply memory
[ https://issues.apache.org/jira/browse/KAFKA-8898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] linking12 updated KAFKA-8898: - Summary: if there is no message for poll, kafka consumer also apply memory (was: if there is no message for poll, kafka consumer apply memory) > if there is no message for poll, kafka consumer also apply memory > - > > Key: KAFKA-8898 > URL: https://issues.apache.org/jira/browse/KAFKA-8898 > Project: Kafka > Issue Type: Bug > Components: consumer >Affects Versions: 2.1.1 >Reporter: linking12 >Priority: Blocker > Labels: performance > > when poll message, but there is no record,but consumer will apply 1000 byte > memory; > fetched = *new* HashMap<>() is not good idea, it will apply memory in heap > but there is no message; > I think fetched = *new* HashMap<>() will appear in records exist; > > ``` > *public* Map>> fetchedRecords() { > Map>> fetched = *new* > HashMap<>(); > *int* recordsRemaining = maxPollRecords; > ``` -- This message was sent by Atlassian Jira (v8.3.2#803003)