[jira] [Commented] (KAFKA-7481) Consider options for safer upgrade of offset commit value schema

[ https://issues.apache.org/jira/browse/KAFKA-7481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16656051#comment-16656051 ] Ismael Juma commented on KAFKA-7481: In the past we did a major bump whenever we chan

[jira] [Commented] (KAFKA-7481) Consider options for safer upgrade of offset commit value schema

[ https://issues.apache.org/jira/browse/KAFKA-7481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16656026#comment-16656026 ] Dong Lin commented on KAFKA-7481: - Thanks for the detailed explanation [~hachikuji]. I ag

[jira] [Commented] (KAFKA-7519) Transactional Ids Left in Pending State by TransactionStateManager During Transactional Id Expiration Are Unusable

[ https://issues.apache.org/jira/browse/KAFKA-7519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16655973#comment-16655973 ] Bridger Howell commented on KAFKA-7519: --- [~dhruvilshah], [~hachikuji] thanks for lo

[jira] [Updated] (KAFKA-7464) Fail to shutdown ReplicaManager during broker cleaned shutdown

[ https://issues.apache.org/jira/browse/KAFKA-7464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-7464: Fix Version/s: (was: 2.0.1) > Fail to shutdown ReplicaManager during broker cleaned shutdown >

[jira] [Resolved] (KAFKA-7464) Fail to shutdown ReplicaManager during broker cleaned shutdown

[ https://issues.apache.org/jira/browse/KAFKA-7464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin resolved KAFKA-7464. - Resolution: Fixed > Fail to shutdown ReplicaManager during broker cleaned shutdown >

[jira] [Assigned] (KAFKA-7519) Transactional Ids Left in Pending State by TransactionStateManager During Transactional Id Expiration Are Unusable

[ https://issues.apache.org/jira/browse/KAFKA-7519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dhruvil Shah reassigned KAFKA-7519: --- Assignee: Dhruvil Shah > Transactional Ids Left in Pending State by TransactionStateManager

[jira] [Commented] (KAFKA-7519) Transactional Ids Left in Pending State by TransactionStateManager During Transactional Id Expiration Are Unusable

[ https://issues.apache.org/jira/browse/KAFKA-7519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16655934#comment-16655934 ] Jason Gustafson commented on KAFKA-7519: Good find and thanks for the investigati

[jira] [Commented] (KAFKA-7510) KStreams RecordCollectorImpl leaks data to logs on error

[ https://issues.apache.org/jira/browse/KAFKA-7510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16655830#comment-16655830 ] Ewen Cheslack-Postava commented on KAFKA-7510: -- [~mjsax] We should be consis

[jira] [Updated] (KAFKA-7519) Transactional Ids Left in Pending State by TransactionStateManager During Transactional Id Expiration Are Unusable

[ https://issues.apache.org/jira/browse/KAFKA-7519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bridger Howell updated KAFKA-7519: -- Description:   After digging into a case where an exactly-once streams process was bizarrely

[jira] [Updated] (KAFKA-7519) Transactional Ids Left in Pending State by TransactionStateManager During Transactional Id Expiration Are Unusable

[ https://issues.apache.org/jira/browse/KAFKA-7519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bridger Howell updated KAFKA-7519: -- Description:   After digging into a case where an exactly-once streams process was bizarrely

[jira] [Created] (KAFKA-7519) Transactional Ids Left in Pending State by TransactionStateManager During Transactional Id Expiration Are Unusable

Bridger Howell created KAFKA-7519: - Summary: Transactional Ids Left in Pending State by TransactionStateManager During Transactional Id Expiration Are Unusable Key: KAFKA-7519 URL: https://issues.apache.org/jira/b

[jira] [Commented] (KAFKA-7510) KStreams RecordCollectorImpl leaks data to logs on error

[ https://issues.apache.org/jira/browse/KAFKA-7510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16655748#comment-16655748 ] Matthias J. Sax commented on KAFKA-7510: [~guozhang] [~ijuma] [~ewencp] What is o

[jira] [Updated] (KAFKA-7510) KStreams RecordCollectorImpl leaks data to logs on error

[ https://issues.apache.org/jira/browse/KAFKA-7510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7510: --- Issue Type: Improvement (was: Bug) > KStreams RecordCollectorImpl leaks data to logs on erro

[jira] [Commented] (KAFKA-7464) Fail to shutdown ReplicaManager during broker cleaned shutdown

[ https://issues.apache.org/jira/browse/KAFKA-7464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16655709#comment-16655709 ] ASF GitHub Bot commented on KAFKA-7464: --- lindong28 closed pull request #5808: KAFKA

[jira] [Commented] (KAFKA-7481) Consider options for safer upgrade of offset commit value schema

[ https://issues.apache.org/jira/browse/KAFKA-7481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16655701#comment-16655701 ] Jason Gustafson commented on KAFKA-7481: [~ijuma] [~lindong] Thanks for the respo

[jira] [Updated] (KAFKA-7516) Client (Producer and/or Consumer) crashes during initialization on Android

[ https://issues.apache.org/jira/browse/KAFKA-7516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar updated KAFKA-7516: - Fix Version/s: (was: 2.0.1) 2.2.0 > Client (Producer and/or Consumer) crashes duri

[jira] [Updated] (KAFKA-7518) FutureRecordMetadata.get deadline calculation from timeout is not using timeunit

[ https://issues.apache.org/jira/browse/KAFKA-7518?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andras Katona updated KAFKA-7518: - Description: Code below assumes that timeout is in milliseconds when calculating deadline. {code

[jira] [Commented] (KAFKA-6746) Allow ZK Znode configurable for Kafka broker

[ https://issues.apache.org/jira/browse/KAFKA-6746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16655425#comment-16655425 ] ASF GitHub Bot commented on KAFKA-6746: --- omkreddy closed pull request #4828: KAFKA-

[jira] [Commented] (KAFKA-5529) ConsoleProducer uses deprecated BaseProducer

[ https://issues.apache.org/jira/browse/KAFKA-5529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16655393#comment-16655393 ] ASF GitHub Bot commented on KAFKA-5529: --- omkreddy closed pull request #3450: KAFKA-

[jira] [Commented] (KAFKA-4754) Correctly parse '=' characters in command line overrides

[ https://issues.apache.org/jira/browse/KAFKA-4754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16655373#comment-16655373 ] ASF GitHub Bot commented on KAFKA-4754: --- omkreddy closed pull request #2529: KAFKA-

[jira] [Commented] (KAFKA-3665) Default ssl.endpoint.identification.algorithm should be https

[ https://issues.apache.org/jira/browse/KAFKA-3665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16655370#comment-16655370 ] ASF GitHub Bot commented on KAFKA-3665: --- omkreddy closed pull request #1330: KAFKA-

[jira] [Commented] (KAFKA-3932) Consumer fails to consume in a round robin fashion

[ https://issues.apache.org/jira/browse/KAFKA-3932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16655279#comment-16655279 ] CHIENHSING WU commented on KAFKA-3932: -- I encountered the same issue as well. Upon s

[jira] [Resolved] (KAFKA-7505) Flaky test: SslTransportLayerTest.testListenerConfigOverride

[ https://issues.apache.org/jira/browse/KAFKA-7505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-7505. --- Resolution: Fixed Reviewer: Ismael Juma Fix Version/s: 2.1.0 > Flaky test: Ss

[jira] [Commented] (KAFKA-7505) Flaky test: SslTransportLayerTest.testListenerConfigOverride

[ https://issues.apache.org/jira/browse/KAFKA-7505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16655266#comment-16655266 ] ASF GitHub Bot commented on KAFKA-7505: --- rajinisivaram closed pull request #5800: K

[jira] [Commented] (KAFKA-7517) Add a minimum retention.bytes config value

[ https://issues.apache.org/jira/browse/KAFKA-7517?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16655215#comment-16655215 ] ASF GitHub Bot commented on KAFKA-7517: --- stanislavkozlovski opened a new pull reque

[jira] [Commented] (KAFKA-7518) FutureRecordMetadata.get deadline calculation from timeout is not using timeunit

[ https://issues.apache.org/jira/browse/KAFKA-7518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16655039#comment-16655039 ] ASF GitHub Bot commented on KAFKA-7518: --- akatona84 opened a new pull request #5815:

[jira] [Created] (KAFKA-7518) FutureRecordMetadata.get deadline calculation from timeout is not using timeunit

Andras Katona created KAFKA-7518: Summary: FutureRecordMetadata.get deadline calculation from timeout is not using timeunit Key: KAFKA-7518 URL: https://issues.apache.org/jira/browse/KAFKA-7518 Projec

[jira] [Commented] (KAFKA-7481) Consider options for safer upgrade of offset commit value schema

[ https://issues.apache.org/jira/browse/KAFKA-7481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16654759#comment-16654759 ] Dong Lin commented on KAFKA-7481: - BTW, this is currently the only blocking issue for 2.1

[jira] [Commented] (KAFKA-7481) Consider options for safer upgrade of offset commit value schema

[ https://issues.apache.org/jira/browse/KAFKA-7481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16654757#comment-16654757 ] Dong Lin commented on KAFKA-7481: - Option 2 sounds good to me. For option 2, it is true t