[jira] [Created] (KAFKA-13310) KafkaConsumer cannot jump out of the poll method, and the consumer is blocked in the ConsumerCoordinator method maybeAutoCommitOffsetsSync(Timer timer). Broker end cpu a

2021-09-18 Thread RivenSun (Jira)
RivenSun created KAFKA-13310: Summary: KafkaConsumer cannot jump out of the poll method, and the consumer is blocked in the ConsumerCoordinator method maybeAutoCommitOffsetsSync(Timer timer). Broker end cpu and traffic increase sharply

[jira] [Updated] (KAFKA-13310) KafkaConsumer cannot jump out of the poll method, and the consumer is blocked in the ConsumerCoordinator method maybeAutoCommitOffsetsSync(Timer timer). Broker end cpu a

2021-09-18 Thread RivenSun (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RivenSun updated KAFKA-13310: - Description: Foreword:       Because our consumers' consumption logic is sometimes heavier, we refer t

[jira] [Updated] (KAFKA-13310) KafkaConsumer cannot jump out of the poll method, and the consumer is blocked in the ConsumerCoordinator method maybeAutoCommitOffsetsSync(Timer timer). Broker end cpu a

2021-09-18 Thread RivenSun (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RivenSun updated KAFKA-13310: - Description: h2. Foreword       Because our consumers' consumption logic is sometimes heavier, we refer

[jira] [Updated] (KAFKA-13310) KafkaConsumer cannot jump out of the poll method, and the consumer is blocked in the ConsumerCoordinator method maybeAutoCommitOffsetsSync(Timer timer). Broker end cpu a

2021-09-18 Thread RivenSun (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RivenSun updated KAFKA-13310: - Description: h2. Foreword       Because our consumers' consumption logic is sometimes heavier, we refer

[jira] [Updated] (KAFKA-13310) KafkaConsumer cannot jump out of the poll method, and the consumer is blocked in the ConsumerCoordinator method maybeAutoCommitOffsetsSync(Timer timer). Broker end cpu a

2021-09-18 Thread RivenSun (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RivenSun updated KAFKA-13310: - Reviewer: Guozhang Wang > KafkaConsumer cannot jump out of the poll method, and the consumer is blocked

[jira] [Commented] (KAFKA-13310) KafkaConsumer cannot jump out of the poll method, and the consumer is blocked in the ConsumerCoordinator method maybeAutoCommitOffsetsSync(Timer timer). Broker end cpu

2021-09-18 Thread RivenSun (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17417083#comment-17417083 ] RivenSun commented on KAFKA-13310: -- [~guozhang] hi Guozhang, can you help deal with thi

[jira] [Updated] (KAFKA-13310) KafkaConsumer cannot jump out of the poll method, and the consumer is blocked in the ConsumerCoordinator method maybeAutoCommitOffsetsSync(Timer timer). Broker end cpu a

2021-09-18 Thread RivenSun (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RivenSun updated KAFKA-13310: - Priority: Major (was: Critical) > KafkaConsumer cannot jump out of the poll method, and the consumer is

[jira] [Commented] (KAFKA-13310) KafkaConsumer cannot jump out of the poll method, and the consumer is blocked in the ConsumerCoordinator method maybeAutoCommitOffsetsSync(Timer timer). Broker end cpu

2021-09-18 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17417130#comment-17417130 ] Luke Chen commented on KAFKA-13310: --- Nice RCA and good suggestions.   My 2 cents: F

[jira] [Updated] (KAFKA-13310) KafkaConsumer cannot jump out of the poll method, and the consumer is blocked in the ConsumerCoordinator method maybeAutoCommitOffsetsSync(Timer timer). Broker end cpu a

2021-09-18 Thread RivenSun (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RivenSun updated KAFKA-13310: - Attachment: SecondDeleteConsumerLog.png > KafkaConsumer cannot jump out of the poll method, and the cons

[jira] [Commented] (KAFKA-13310) KafkaConsumer cannot jump out of the poll method, and the consumer is blocked in the ConsumerCoordinator method maybeAutoCommitOffsetsSync(Timer timer). Broker end cpu

2021-09-18 Thread RivenSun (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17417145#comment-17417145 ] RivenSun commented on KAFKA-13310: -- Thank you [~showuon] very much for your reply I pe

[jira] [Updated] (KAFKA-13310) KafkaConsumer cannot jump out of the poll method, and the consumer is blocked in the ConsumerCoordinator method maybeAutoCommitOffsetsSync(Timer timer). Broker end cpu a

2021-09-18 Thread RivenSun (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RivenSun updated KAFKA-13310: - Attachment: SecondDeleteDebugLog.png > KafkaConsumer cannot jump out of the poll method, and the consume

[jira] [Comment Edited] (KAFKA-13310) KafkaConsumer cannot jump out of the poll method, and the consumer is blocked in the ConsumerCoordinator method maybeAutoCommitOffsetsSync(Timer timer). Broker en

2021-09-18 Thread RivenSun (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17417145#comment-17417145 ] RivenSun edited comment on KAFKA-13310 at 9/18/21, 1:55 PM:

[jira] [Comment Edited] (KAFKA-13310) KafkaConsumer cannot jump out of the poll method, and the consumer is blocked in the ConsumerCoordinator method maybeAutoCommitOffsetsSync(Timer timer). Broker en

2021-09-18 Thread RivenSun (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17417145#comment-17417145 ] RivenSun edited comment on KAFKA-13310 at 9/18/21, 1:56 PM:

[jira] [Comment Edited] (KAFKA-13310) KafkaConsumer cannot jump out of the poll method, and the consumer is blocked in the ConsumerCoordinator method maybeAutoCommitOffsetsSync(Timer timer). Broker en

2021-09-18 Thread RivenSun (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17417145#comment-17417145 ] RivenSun edited comment on KAFKA-13310 at 9/18/21, 2:05 PM:

[jira] [Comment Edited] (KAFKA-13310) KafkaConsumer cannot jump out of the poll method, and the consumer is blocked in the ConsumerCoordinator method maybeAutoCommitOffsetsSync(Timer timer). Broker en

2021-09-18 Thread RivenSun (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17417145#comment-17417145 ] RivenSun edited comment on KAFKA-13310 at 9/18/21, 2:54 PM:

[jira] [Comment Edited] (KAFKA-13310) KafkaConsumer cannot jump out of the poll method, and the consumer is blocked in the ConsumerCoordinator method maybeAutoCommitOffsetsSync(Timer timer). Broker en

2021-09-18 Thread RivenSun (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17417145#comment-17417145 ] RivenSun edited comment on KAFKA-13310 at 9/18/21, 2:57 PM:

[jira] [Comment Edited] (KAFKA-13310) KafkaConsumer cannot jump out of the poll method, and the consumer is blocked in the ConsumerCoordinator method maybeAutoCommitOffsetsSync(Timer timer). Broker en

2021-09-18 Thread RivenSun (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17417145#comment-17417145 ] RivenSun edited comment on KAFKA-13310 at 9/18/21, 2:57 PM:

[jira] [Comment Edited] (KAFKA-13310) KafkaConsumer cannot jump out of the poll method, and the consumer is blocked in the ConsumerCoordinator method maybeAutoCommitOffsetsSync(Timer timer). Broker en

2021-09-18 Thread RivenSun (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17417145#comment-17417145 ] RivenSun edited comment on KAFKA-13310 at 9/18/21, 3:01 PM:

[jira] [Comment Edited] (KAFKA-13310) KafkaConsumer cannot jump out of the poll method, and the consumer is blocked in the ConsumerCoordinator method maybeAutoCommitOffsetsSync(Timer timer). Broker en

2021-09-18 Thread RivenSun (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17417145#comment-17417145 ] RivenSun edited comment on KAFKA-13310 at 9/18/21, 3:03 PM:

[jira] [Updated] (KAFKA-13310) KafkaConsumer cannot jump out of the poll method, and the consumer is blocked in the ConsumerCoordinator method maybeAutoCommitOffsetsSync(Timer timer). Cpu and traffic

2021-09-18 Thread RivenSun (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RivenSun updated KAFKA-13310: - Summary: KafkaConsumer cannot jump out of the poll method, and the consumer is blocked in the ConsumerCo

[jira] [Updated] (KAFKA-13310) KafkaConsumer cannot jump out of the poll method, and the consumer is blocked in the ConsumerCoordinator method maybeAutoCommitOffsetsSync(Timer timer). Cpu and traffic

2021-09-18 Thread RivenSun (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RivenSun updated KAFKA-13310: - Description: h2. Foreword       Because our consumers' consumption logic is sometimes heavier, we refer

[jira] [Commented] (KAFKA-13310) KafkaConsumer cannot jump out of the poll method, and the consumer is blocked in the ConsumerCoordinator method maybeAutoCommitOffsetsSync(Timer timer). Cpu and traffi

2021-09-18 Thread RivenSun (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17417165#comment-17417165 ] RivenSun commented on KAFKA-13310: -- And I think the most important and critical point i

[jira] [Comment Edited] (KAFKA-13310) KafkaConsumer cannot jump out of the poll method, and the consumer is blocked in the ConsumerCoordinator method maybeAutoCommitOffsetsSync(Timer timer). Cpu and t

2021-09-18 Thread RivenSun (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17417165#comment-17417165 ] RivenSun edited comment on KAFKA-13310 at 9/18/21, 3:50 PM:

[jira] [Commented] (KAFKA-13261) KTable to KTable foreign key join loose events when using several partitions

2021-09-18 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17417203#comment-17417203 ] Matthias J. Sax commented on KAFKA-13261: - Let keep the discussion on the mailin

[jira] [Updated] (KAFKA-13310) KafkaConsumer cannot jump out of the poll method, and the consumer is blocked in the ConsumerCoordinator method maybeAutoCommitOffsetsSync(Timer timer). Cpu and traffic

2021-09-18 Thread RivenSun (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RivenSun updated KAFKA-13310: - Description: h2. Foreword       Because our consumers' consumption logic is sometimes heavier, we refer

[GitHub] [kafka] abbccdda commented on a change in pull request #11333: KAFKA-13306: Null connector config value passes validation, but fails creation

2021-09-18 Thread GitBox
abbccdda commented on a change in pull request #11333: URL: https://github.com/apache/kafka/pull/11333#discussion_r711655376 ## File path: connect/api/src/main/java/org/apache/kafka/connect/connector/Connector.java ## @@ -150,4 +152,15 @@ public Config validate(Map connectorC

[jira] [Commented] (KAFKA-13310) KafkaConsumer cannot jump out of the poll method, and the consumer is blocked in the ConsumerCoordinator method maybeAutoCommitOffsetsSync(Timer timer). Cpu and traffi

2021-09-18 Thread RivenSun (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17417270#comment-17417270 ] RivenSun commented on KAFKA-13310: -- [~showuon] After thinking about it, here is my la

[GitHub] [kafka] vijaykriishna commented on pull request #10873: KAFKA-7360 Fixed code snippet

2021-09-18 Thread GitBox
vijaykriishna commented on pull request #10873: URL: https://github.com/apache/kafka/pull/10873#issuecomment-922391928 @halorgium @astubbs @alexism @glasser Please review the PR. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHu

[jira] [Comment Edited] (KAFKA-13310) KafkaConsumer cannot jump out of the poll method, and the consumer is blocked in the ConsumerCoordinator method maybeAutoCommitOffsetsSync(Timer timer). Cpu and t

2021-09-18 Thread RivenSun (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17417270#comment-17417270 ] RivenSun edited comment on KAFKA-13310 at 9/19/21, 12:24 AM: -

[jira] [Assigned] (KAFKA-13186) Proposal for commented code

2021-09-18 Thread Vijay (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vijay reassigned KAFKA-13186: - Assignee: Vijay > Proposal for commented code > --- > > Key: KA

[jira] [Commented] (KAFKA-13310) KafkaConsumer cannot jump out of the poll method, and the consumer is blocked in the ConsumerCoordinator method maybeAutoCommitOffsetsSync(Timer timer). Cpu and traffi

2021-09-18 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17417277#comment-17417277 ] Luke Chen commented on KAFKA-13310: --- [~RivenSun], thanks for your response. For your l

[GitHub] [kafka] guozhangwang merged pull request #11329: KAFKA-13301; Optimized the interpretation of the relationship between 'request.timeout. ms' and 'max.poll.interval.ms' in the document.

2021-09-18 Thread GitBox
guozhangwang merged pull request #11329: URL: https://github.com/apache/kafka/pull/11329 -- 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: jira-unsu

[jira] [Resolved] (KAFKA-13301) The relationship between request.timeout. ms and max.poll.interval.ms in the Consumer Configs is incorrect.

2021-09-18 Thread Guozhang Wang (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-13301. --- Fix Version/s: 3.1.0 Resolution: Fixed > The relationship between request.timeout. ms

[jira] [Commented] (KAFKA-13310) KafkaConsumer cannot jump out of the poll method, and the consumer is blocked in the ConsumerCoordinator method maybeAutoCommitOffsetsSync(Timer timer). Cpu and traffi

2021-09-18 Thread RivenSun (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17417285#comment-17417285 ] RivenSun commented on KAFKA-13310: --   Thank you [~showuon]  very much for your reply,

[jira] [Comment Edited] (KAFKA-13310) KafkaConsumer cannot jump out of the poll method, and the consumer is blocked in the ConsumerCoordinator method maybeAutoCommitOffsetsSync(Timer timer). Cpu and t

2021-09-18 Thread RivenSun (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17417285#comment-17417285 ] RivenSun edited comment on KAFKA-13310 at 9/19/21, 6:05 AM: