[jira] [Updated] (KAFKA-8695) Metrics UnderReplicated and UnderMinIsr are diverging when configuration is inconsistent

[ https://issues.apache.org/jira/browse/KAFKA-8695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexandre Dupriez updated KAFKA-8695: - Summary: Metrics UnderReplicated and UnderMinIsr are diverging when configuration is

[jira] [Commented] (KAFKA-8765) Remove "unstable" annotations

[ https://issues.apache.org/jira/browse/KAFKA-8765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16906892#comment-16906892 ] ASF GitHub Bot commented on KAFKA-8765: --- mjsax commented on pull request #7174: KAFKA-8765: Remove

[jira] [Commented] (KAFKA-8791) RocksDBTimestampedStore should open in regular mode for new stores

[ https://issues.apache.org/jira/browse/KAFKA-8791?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16906786#comment-16906786 ] ASF GitHub Bot commented on KAFKA-8791: --- mjsax commented on pull request #7201: KAFKA-8791:

[jira] [Created] (KAFKA-8800) Flaky Test SaslScramSslEndToEndAuthorizationTest#testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl

Matthias J. Sax created KAFKA-8800: -- Summary: Flaky Test SaslScramSslEndToEndAuthorizationTest#testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl Key: KAFKA-8800 URL:

[jira] [Commented] (KAFKA-7937) Flaky Test ResetConsumerGroupOffsetTest.testResetOffsetsNotExistingGroup

[ https://issues.apache.org/jira/browse/KAFKA-7937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16906784#comment-16906784 ] Matthias J. Sax commented on KAFKA-7937:

[jira] [Commented] (KAFKA-7937) Flaky Test ResetConsumerGroupOffsetTest.testResetOffsetsNotExistingGroup

[ https://issues.apache.org/jira/browse/KAFKA-7937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16906782#comment-16906782 ] Matthias J. Sax commented on KAFKA-7937:

[jira] [Comment Edited] (KAFKA-8769) Consider computing stream time independently per key

[ https://issues.apache.org/jira/browse/KAFKA-8769?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16906692#comment-16906692 ] Richard Yu edited comment on KAFKA-8769 at 8/13/19 10:50 PM: - Notably, a

[jira] [Commented] (KAFKA-8769) Consider computing stream time independently per key

[ https://issues.apache.org/jira/browse/KAFKA-8769?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16906692#comment-16906692 ] Richard Yu commented on KAFKA-8769: --- Notably, a problem with this approach is that keys which are

[jira] [Comment Edited] (KAFKA-8769) Consider computing stream time independently per key

[ https://issues.apache.org/jira/browse/KAFKA-8769?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16906674#comment-16906674 ] Richard Yu edited comment on KAFKA-8769 at 8/13/19 10:29 PM: - [~vvcephei] On

[jira] [Commented] (KAFKA-8769) Consider computing stream time independently per key

[ https://issues.apache.org/jira/browse/KAFKA-8769?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16906674#comment-16906674 ] Richard Yu commented on KAFKA-8769: --- [~vvcephei] On the issue regarding low traffic: would this

[jira] [Resolved] (KAFKA-7941) Connect KafkaBasedLog work thread terminates when getting offsets fails because broker is unavailable

[ https://issues.apache.org/jira/browse/KAFKA-7941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch resolved KAFKA-7941. -- Resolution: Fixed Reviewer: Randall Hauch Fix Version/s: 2.3.1

[jira] [Commented] (KAFKA-8736) Performance: ThreadCache uses size() for empty cache check

[ https://issues.apache.org/jira/browse/KAFKA-8736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16906664#comment-16906664 ] Bill Bejeck commented on KAFKA-8736: Cherry-picked [https://github.com/apache/kafka/pull/7177] into

[jira] [Commented] (KAFKA-8736) Performance: ThreadCache uses size() for empty cache check

[ https://issues.apache.org/jira/browse/KAFKA-8736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16906651#comment-16906651 ] ASF GitHub Bot commented on KAFKA-8736: --- bbejeck commented on pull request #7177: KAFKA-8736: Track

[jira] [Commented] (KAFKA-8799) Support ability to pass global user data to consumers during Assignment

[ https://issues.apache.org/jira/browse/KAFKA-8799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16906627#comment-16906627 ] Vinoth Chandar commented on KAFKA-8799: --- [~guozhang] filed this for the longer term fix. >

[jira] [Created] (KAFKA-8799) Support ability to pass global user data to consumers during Assignment

Vinoth Chandar created KAFKA-8799: - Summary: Support ability to pass global user data to consumers during Assignment Key: KAFKA-8799 URL: https://issues.apache.org/jira/browse/KAFKA-8799 Project:

[jira] [Updated] (KAFKA-8391) Flaky Test RebalanceSourceConnectorsIntegrationTest#testDeleteConnector

[ https://issues.apache.org/jira/browse/KAFKA-8391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-8391: - Fix Version/s: 2.2.2 2.1.2 > Flaky Test

[jira] [Commented] (KAFKA-6556) allow to attach callbacks in kafka streams, to be triggered when a window is expired

[ https://issues.apache.org/jira/browse/KAFKA-6556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16906530#comment-16906530 ] Lital Eldan commented on KAFKA-6556: [~mjsax] i don't see the issue in the plan for release 2.3.1 ,

[jira] [Commented] (KAFKA-8412) Still a nullpointer exception thrown on shutdown while flushing before closing producers

[ https://issues.apache.org/jira/browse/KAFKA-8412?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16906525#comment-16906525 ] ASF GitHub Bot commented on KAFKA-8412: --- cpettitt-confluent commented on pull request #7207:

[jira] [Commented] (KAFKA-8391) Flaky Test RebalanceSourceConnectorsIntegrationTest#testDeleteConnector

[ https://issues.apache.org/jira/browse/KAFKA-8391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16906487#comment-16906487 ] ASF GitHub Bot commented on KAFKA-8391: --- gwenshap commented on pull request #7019: KAFKA-8391:

[jira] [Commented] (KAFKA-6461) TableTableJoinIntegrationTest is unstable if caching is enabled

[ https://issues.apache.org/jira/browse/KAFKA-6461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16906485#comment-16906485 ] Matthias J. Sax commented on KAFKA-6461: Different tests failed (all with caching enabled – cf.

[jira] [Commented] (KAFKA-8078) Flaky Test TableTableJoinIntegrationTest#testInnerInner

[ https://issues.apache.org/jira/browse/KAFKA-8078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16906484#comment-16906484 ] Matthias J. Sax commented on KAFKA-8078: Different tests failed (all with caching enabled – cf.

[jira] [Commented] (KAFKA-8672) RebalanceSourceConnectorsIntegrationTest#testReconfigConnector

[ https://issues.apache.org/jira/browse/KAFKA-8672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16906480#comment-16906480 ] Matthias J. Sax commented on KAFKA-8672:

[jira] [Commented] (KAFKA-8686) Flakey test ExampleConnectIntegrationTest#testSinkConnector

[ https://issues.apache.org/jira/browse/KAFKA-8686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16906478#comment-16906478 ] Matthias J. Sax commented on KAFKA-8686:

[jira] [Commented] (KAFKA-8672) RebalanceSourceConnectorsIntegrationTest#testReconfigConnector

[ https://issues.apache.org/jira/browse/KAFKA-8672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16906469#comment-16906469 ] Gwen Shapira commented on KAFKA-8672: -

[jira] [Commented] (KAFKA-7263) Container exception java.lang.IllegalStateException: Coordinator selected invalid assignment protocol: null

[ https://issues.apache.org/jira/browse/KAFKA-7263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16906464#comment-16906464 ] Oleg Kuznetsov commented on KAFKA-7263: --- [~mjsax] Do you happen to have a workaround for this in

[jira] [Commented] (KAFKA-8555) Flaky test ExampleConnectIntegrationTest#testSourceConnector

[ https://issues.apache.org/jira/browse/KAFKA-8555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16906456#comment-16906456 ] Gwen Shapira commented on KAFKA-8555: -

[jira] [Commented] (KAFKA-8686) Flakey test ExampleConnectIntegrationTest#testSinkConnector

[ https://issues.apache.org/jira/browse/KAFKA-8686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16906455#comment-16906455 ] Gwen Shapira commented on KAFKA-8686: -

[jira] [Issue Comment Deleted] (KAFKA-8672) RebalanceSourceConnectorsIntegrationTest#testReconfigConnector

[ https://issues.apache.org/jira/browse/KAFKA-8672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-8672: Comment: was deleted (was:

[jira] [Commented] (KAFKA-8672) RebalanceSourceConnectorsIntegrationTest#testReconfigConnector

[ https://issues.apache.org/jira/browse/KAFKA-8672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16906450#comment-16906450 ] Gwen Shapira commented on KAFKA-8672: -

[jira] [Created] (KAFKA-8798) SaslOAuthBearerSslEndToEndAuthorizationTest.testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl

Gwen Shapira created KAFKA-8798: --- Summary: SaslOAuthBearerSslEndToEndAuthorizationTest.testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl Key: KAFKA-8798 URL: https://issues.apache.org/jira/browse/KAFKA-8798

[jira] [Commented] (KAFKA-8797) BufferUnderflowException: Error reading field 'version' from consumer

[ https://issues.apache.org/jira/browse/KAFKA-8797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16906399#comment-16906399 ] Ismael Juma commented on KAFKA-8797: Cc [~bchen225242] > BufferUnderflowException: Error reading

[jira] [Updated] (KAFKA-8797) BufferUnderflowException: Error reading field 'version' from consumer

[ https://issues.apache.org/jira/browse/KAFKA-8797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raman Gupta updated KAFKA-8797: --- Affects Version/s: 2.3.0 > BufferUnderflowException: Error reading field 'version' from consumer >

[jira] [Updated] (KAFKA-8797) BufferUnderflowException: Error reading field 'version' from consumer

[ https://issues.apache.org/jira/browse/KAFKA-8797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raman Gupta updated KAFKA-8797: --- Component/s: consumer > BufferUnderflowException: Error reading field 'version' from consumer >

[jira] [Created] (KAFKA-8797) BufferUnderflowException: Error reading field 'version' from consumer

Raman Gupta created KAFKA-8797: -- Summary: BufferUnderflowException: Error reading field 'version' from consumer Key: KAFKA-8797 URL: https://issues.apache.org/jira/browse/KAFKA-8797 Project: Kafka

[jira] [Commented] (KAFKA-7941) Connect KafkaBasedLog work thread terminates when getting offsets fails because broker is unavailable

[ https://issues.apache.org/jira/browse/KAFKA-7941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16906306#comment-16906306 ] ASF GitHub Bot commented on KAFKA-7941: --- rhauch commented on pull request #6283: KAFKA-7941: Catch

[jira] [Resolved] (KAFKA-8774) Connect REST API exposes plaintext secrets in tasks endpoint if config value contains additional characters

[ https://issues.apache.org/jira/browse/KAFKA-8774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch resolved KAFKA-8774. -- Resolution: Fixed Reviewer: Randall Hauch Fix Version/s: 2.3.1

[jira] [Assigned] (KAFKA-8774) Connect REST API exposes plaintext secrets in tasks endpoint if config value contains additional characters

[ https://issues.apache.org/jira/browse/KAFKA-8774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch reassigned KAFKA-8774: Assignee: Arjun Satish (was: Oleksandr Diachenko) > Connect REST API exposes plaintext

[jira] [Commented] (KAFKA-8774) Connect REST API exposes plaintext secrets in tasks endpoint if config value contains additional characters

[ https://issues.apache.org/jira/browse/KAFKA-8774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16906275#comment-16906275 ] ASF GitHub Bot commented on KAFKA-8774: --- rhauch commented on pull request #7197: KAFKA-8774: Regex

[jira] [Updated] (KAFKA-8789) kafka-console-consumer timeout-ms setting behaves incorrectly with newer client

[ https://issues.apache.org/jira/browse/KAFKA-8789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raman Gupta updated KAFKA-8789: --- Summary: kafka-console-consumer timeout-ms setting behaves incorrectly with newer client (was:

[jira] [Commented] (KAFKA-8789) kafka-console-consumer timeout-ms setting behaves incorrectly with older client

[ https://issues.apache.org/jira/browse/KAFKA-8789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16906247#comment-16906247 ] ASF GitHub Bot commented on KAFKA-8789: --- dongjinleekr commented on pull request #7206: KAFKA-8789:

[jira] [Assigned] (KAFKA-8789) kafka-console-consumer timeout-ms setting behaves incorrectly with older client

[ https://issues.apache.org/jira/browse/KAFKA-8789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lee Dongjin reassigned KAFKA-8789: -- Assignee: Lee Dongjin > kafka-console-consumer timeout-ms setting behaves incorrectly with

[jira] [Commented] (KAFKA-8699) rack aware replica, found rack with two replicas

[ https://issues.apache.org/jira/browse/KAFKA-8699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16906147#comment-16906147 ] abdessamad commented on KAFKA-8699: --- Any feed back would be greatly appreciated > rack aware replica,

[jira] [Updated] (KAFKA-8699) rack aware replica, found rack with two replicas

[ https://issues.apache.org/jira/browse/KAFKA-8699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] abdessamad updated KAFKA-8699: -- Priority: Critical (was: Minor) > rack aware replica, found rack with two replicas >

[jira] [Created] (KAFKA-8796) A broker joining the cluster should be able to replicate without impacting the cluster

Marouane RAJI created KAFKA-8796: Summary: A broker joining the cluster should be able to replicate without impacting the cluster Key: KAFKA-8796 URL: https://issues.apache.org/jira/browse/KAFKA-8796

[jira] [Updated] (KAFKA-8790) [kafka-connect] KafkaBaseLog.WorkThread not recoverable

[ https://issues.apache.org/jira/browse/KAFKA-8790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qinghui Xu updated KAFKA-8790: -- Description: We have a kafka (source) connector that's copying data from some kafka cluster to the

[jira] [Commented] (KAFKA-3917) Some __consumer_offsets replicas grow way too big

[ https://issues.apache.org/jira/browse/KAFKA-3917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16905910#comment-16905910 ] Boquan Tang commented on KAFKA-3917: [~panpan.liu] This issue is solved in KAFKA-8335, you can

[jira] [Commented] (KAFKA-3917) Some __consumer_offsets replicas grow way too big

[ https://issues.apache.org/jira/browse/KAFKA-3917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16905899#comment-16905899 ] panpan.liu commented on KAFKA-3917: --- [~boquan]  I met the same issue, version 2.0.1  By your

[jira] [Updated] (KAFKA-8795) Kafka - Segment deleted earlier than expected

[ https://issues.apache.org/jira/browse/KAFKA-8795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prashant updated KAFKA-8795: Component/s: core > Kafka - Segment deleted earlier than expected >

[jira] [Created] (KAFKA-8795) Kafka - Segment deleted earlier than expected

Prashant created KAFKA-8795: --- Summary: Kafka - Segment deleted earlier than expected Key: KAFKA-8795 URL: https://issues.apache.org/jira/browse/KAFKA-8795 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-8794) Provide Javadoc on DescribeLogDirsResult

[ https://issues.apache.org/jira/browse/KAFKA-8794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16905873#comment-16905873 ] ASF GitHub Bot commented on KAFKA-8794: --- dongjinleekr commented on pull request #7204: KAFKA-8794:

[jira] [Created] (KAFKA-8794) Provide Javadoc on DescribeLogDirsResult

Lee Dongjin created KAFKA-8794: -- Summary: Provide Javadoc on DescribeLogDirsResult Key: KAFKA-8794 URL: https://issues.apache.org/jira/browse/KAFKA-8794 Project: Kafka Issue Type: Improvement

[jira] [Updated] (KAFKA-8793) StickyTaskAssignor throws java.lang.ArithmeticException

[ https://issues.apache.org/jira/browse/KAFKA-8793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raman Gupta updated KAFKA-8793: --- Description: Occassionally when starting a streams consumer that uses the static consumer group

[jira] [Created] (KAFKA-8793) StickyTaskAssignor throws java.lang.ArithmeticException

Raman Gupta created KAFKA-8793: -- Summary: StickyTaskAssignor throws java.lang.ArithmeticException Key: KAFKA-8793 URL: https://issues.apache.org/jira/browse/KAFKA-8793 Project: Kafka Issue