[jira] [Updated] (KAFKA-9822) java kafka-client use "props.put("retries", "5")" ,why print 2 log ?

2020-04-04 Thread startjava (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] startjava updated KAFKA-9822: - Description: package test2;package test2; import java.util.Properties; import org.apache.kafka.clients.pr

[jira] [Updated] (KAFKA-9822) java kafka-client use "props.put("retries", "5")" ,why print 2 log ? Should 6 log !

2020-04-04 Thread startjava (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] startjava updated KAFKA-9822: - Summary: java kafka-client use "props.put("retries", "5")" ,why print 2 log ? Should 6 log ! (was: java

[jira] [Updated] (KAFKA-9822) java kafka-client use "props.put("retries", "5")" ,why print 2 log ?

2020-04-04 Thread startjava (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] startjava updated KAFKA-9822: - Description: [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.clients.NetworkClient -

[jira] [Updated] (KAFKA-9822) java kafka-client use "props.put("retries", "3")" ,but print 2 log , but 3 log better..

2020-04-04 Thread startjava (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] startjava updated KAFKA-9822: - Summary: java kafka-client use "props.put("retries", "3")" ,but print 2 log , but 3 log better.. (was: j

[jira] [Created] (KAFKA-9822) java kafka-client use "props.put("acks", "1")" ,but print 2 log , but 3 log better..

2020-04-04 Thread startjava (Jira)
startjava created KAFKA-9822: Summary: java kafka-client use "props.put("acks", "1")" ,but print 2 log , but 3 log better.. Key: KAFKA-9822 URL: https://issues.apache.org/jira/browse/KAFKA-9822 Project: K

[jira] [Comment Edited] (KAFKA-9298) Reuse of a mapped stream causes an Invalid Topology

2020-04-04 Thread Bill Bejeck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17075592#comment-17075592 ] Bill Bejeck edited comment on KAFKA-9298 at 4/5/20, 2:49 AM: -

[jira] [Commented] (KAFKA-9298) Reuse of a mapped stream causes an Invalid Topology

2020-04-04 Thread Bill Bejeck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17075592#comment-17075592 ] Bill Bejeck commented on KAFKA-9298: The test method should not be {{optimizerIsEager

[jira] [Comment Edited] (KAFKA-9298) Reuse of a mapped stream causes an Invalid Topology

2020-04-04 Thread Bill Bejeck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17075592#comment-17075592 ] Bill Bejeck edited comment on KAFKA-9298 at 4/5/20, 2:48 AM: -

[jira] [Commented] (KAFKA-9761) kafka-consumer-groups tool overrides admin client defaults with a short 5 s timeout

2020-04-04 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17075562#comment-17075562 ] ASF GitHub Bot commented on KAFKA-9761: --- MikeSchlosser16 commented on pull request

[jira] [Updated] (KAFKA-9810) Document Connect Root REST API on /

2020-04-04 Thread Konstantine Karantasis (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-9810: -- Fix Version/s: 2.4.2 2.3.2 2.5.0

[jira] [Resolved] (KAFKA-9810) Document Connect Root REST API on /

2020-04-04 Thread Konstantine Karantasis (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis resolved KAFKA-9810. --- Resolution: Fixed > Document Connect Root REST API on / > -

[jira] [Commented] (KAFKA-9761) kafka-consumer-groups tool overrides admin client defaults with a short 5 s timeout

2020-04-04 Thread Mike Schlosser (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17075265#comment-17075265 ] Mike Schlosser commented on KAFKA-9761: --- Hi [~cmccabe] - I see you are assigned to

[jira] [Commented] (KAFKA-9821) Partition may skip assignment with static members and incremental rebalances

2020-04-04 Thread Guozhang Wang (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17075220#comment-17075220 ] Guozhang Wang commented on KAFKA-9821: -- Yup I totally agree with the logging improve

[jira] [Updated] (KAFKA-9820) validateMessagesAndAssignOffsetsCompressed allocates batch iterator which is not used

2020-04-04 Thread Ismael Juma (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9820?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-9820: --- Fix Version/s: 2.6.0 > validateMessagesAndAssignOffsetsCompressed allocates batch iterator which is

[jira] [Resolved] (KAFKA-9820) validateMessagesAndAssignOffsetsCompressed allocates batch iterator which is not used

2020-04-04 Thread Ismael Juma (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9820?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-9820. Resolution: Fixed > validateMessagesAndAssignOffsetsCompressed allocates batch iterator which is >

[jira] [Commented] (KAFKA-9820) validateMessagesAndAssignOffsetsCompressed allocates batch iterator which is not used

2020-04-04 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17075212#comment-17075212 ] ASF GitHub Bot commented on KAFKA-9820: --- ijuma commented on pull request #8422: KAF

[jira] [Updated] (KAFKA-9739) StreamsBuilder.build fails with StreamsException "Found a null keyChangingChild node for OptimizableRepartitionNode"

2020-04-04 Thread Bill Bejeck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-9739: --- Fix Version/s: 2.2.3 > StreamsBuilder.build fails with StreamsException "Found a null > keyChangingC

[jira] [Updated] (KAFKA-9739) StreamsBuilder.build fails with StreamsException "Found a null keyChangingChild node for OptimizableRepartitionNode"

2020-04-04 Thread Bill Bejeck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-9739: --- Affects Version/s: 2.2.0 2.2.1 2.2.2 > StreamsBuilder.b

[jira] [Comment Edited] (KAFKA-9739) StreamsBuilder.build fails with StreamsException "Found a null keyChangingChild node for OptimizableRepartitionNode"

2020-04-04 Thread Bill Bejeck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17075185#comment-17075185 ] Bill Bejeck edited comment on KAFKA-9739 at 4/4/20, 3:56 PM: -

[jira] [Updated] (KAFKA-9739) StreamsBuilder.build fails with StreamsException "Found a null keyChangingChild node for OptimizableRepartitionNode"

2020-04-04 Thread Bill Bejeck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-9739: --- Affects Version/s: 2.3.1 > StreamsBuilder.build fails with StreamsException "Found a null > keyChang

[jira] [Commented] (KAFKA-9739) StreamsBuilder.build fails with StreamsException "Found a null keyChangingChild node for OptimizableRepartitionNode"

2020-04-04 Thread Bill Bejeck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17075185#comment-17075185 ] Bill Bejeck commented on KAFKA-9739: merged to 2.3 via [https://github.com/apache/kaf

[jira] [Comment Edited] (KAFKA-9739) StreamsBuilder.build fails with StreamsException "Found a null keyChangingChild node for OptimizableRepartitionNode"

2020-04-04 Thread Bill Bejeck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17074836#comment-17074836 ] Bill Bejeck edited comment on KAFKA-9739 at 4/4/20, 3:47 PM: -

[jira] [Commented] (KAFKA-7965) Flaky Test ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup

2020-04-04 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17075184#comment-17075184 ] Matthias J. Sax commented on KAFKA-7965: [https://builds.apache.org/job/kafka-pr-

[jira] [Commented] (KAFKA-9739) StreamsBuilder.build fails with StreamsException "Found a null keyChangingChild node for OptimizableRepartitionNode"

2020-04-04 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17075183#comment-17075183 ] ASF GitHub Bot commented on KAFKA-9739: --- bbejeck commented on pull request #8419: K

[jira] [Comment Edited] (KAFKA-6529) Broker leaks memory and file descriptors after sudden client disconnects

2020-04-04 Thread zhangzhanchang (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-6529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17075166#comment-17075166 ] zhangzhanchang edited comment on KAFKA-6529 at 4/4/20, 3:10 PM: ---

[jira] [Comment Edited] (KAFKA-6529) Broker leaks memory and file descriptors after sudden client disconnects

2020-04-04 Thread zhangzhanchang (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-6529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17075166#comment-17075166 ] zhangzhanchang edited comment on KAFKA-6529 at 4/4/20, 3:09 PM: ---

[jira] [Comment Edited] (KAFKA-6529) Broker leaks memory and file descriptors after sudden client disconnects

2020-04-04 Thread zhangzhanchang (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-6529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17075166#comment-17075166 ] zhangzhanchang edited comment on KAFKA-6529 at 4/4/20, 3:06 PM: ---

[jira] [Commented] (KAFKA-6529) Broker leaks memory and file descriptors after sudden client disconnects

2020-04-04 Thread zhangzhanchang (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-6529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17075166#comment-17075166 ] zhangzhanchang commented on KAFKA-6529: --- Thanks for you comment. When I run /usr/sb