[jira] [Commented] (KAFKA-8579) Expose RocksDB Metrics to JMX

[ https://issues.apache.org/jira/browse/KAFKA-8579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16906939#comment-16906939 ] ASF GitHub Bot commented on KAFKA-8579: --- cadonna commented on pull request #7209: K

[jira] [Commented] (KAFKA-8792) Default ZK configuration to disable AdminServer

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

[jira] [Resolved] (KAFKA-8792) Default ZK configuration to disable AdminServer

[ https://issues.apache.org/jira/browse/KAFKA-8792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira resolved KAFKA-8792. - Resolution: Fixed Reviewer: Ismael Juma Fix Version/s: 2.4.0 > Default ZK configu

[jira] [Resolved] (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 resolved KAFKA-8695. -- Resolution: Duplicate De-duplicating in favor of  [KAFKA-4680|http://issues.apache.org/

[jira] [Updated] (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:all-tabpanel ] Matthias J. Sax updated KAFKA-6556: --- Labels: needs-kip (was: kip) > allow to attach callbacks in kafka streams, to be triggered w

[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&focusedCommentId=16906914#comment-16906914 ] Matthias J. Sax commented on KAFKA-6556: This feature is not schedule atm and I d

[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 inco

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

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

[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&focusedCommentId=16906786#comment-16906786 ] ASF GitHub Bot commented on KAFKA-8791: --- mjsax commented on pull request #7201: KAF

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

Matthias J. Sax created KAFKA-8800: -- Summary: Flaky Test SaslScramSslEndToEndAuthorizationTest#testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl Key: KAFKA-8800 URL: https://issues.apache.org/jira/browse/KAFK

[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&focusedCommentId=16906784#comment-16906784 ] Matthias J. Sax commented on KAFKA-7937: [https://builds.apache.org/job/kafka-pr-

[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&focusedCommentId=16906782#comment-16906782 ] Matthias J. Sax commented on KAFKA-7937: [https://builds.apache.org/job/kafka-pr-

[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&focusedCommentId=16906692#comment-16906692 ] Richard Yu edited comment on KAFKA-8769 at 8/13/19 10:50 PM: -

[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&focusedCommentId=16906692#comment-16906692 ] Richard Yu commented on KAFKA-8769: --- Notably, a problem with this approach is that keys

[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&focusedCommentId=16906674#comment-16906674 ] Richard Yu edited comment on KAFKA-8769 at 8/13/19 10:29 PM: -

[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&focusedCommentId=16906674#comment-16906674 ] Richard Yu commented on KAFKA-8769: --- [~vvcephei] On the issue regarding low traffic: wo

[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&focusedCommentId=16906664#comment-16906664 ] Bill Bejeck commented on KAFKA-8736: Cherry-picked [https://github.com/apache/kafka/p

[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&focusedCommentId=16906651#comment-16906651 ] ASF GitHub Bot commented on KAFKA-8736: --- bbejeck commented on pull request #7177: K

[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&focusedCommentId=16906627#comment-16906627 ] Vinoth Chandar commented on KAFKA-8799: --- [~guozhang] filed this for the longer term

[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: Kafk

[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 RebalanceSourceConnectorsIntegrationTe

[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&focusedCommentId=16906530#comment-16906530 ] Lital Eldan commented on KAFKA-6556: [~mjsax] i don't see the issue in the plan for r

[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&focusedCommentId=16906525#comment-16906525 ] ASF GitHub Bot commented on KAFKA-8412: --- cpettitt-confluent commented on pull reque

[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&focusedCommentId=16906487#comment-16906487 ] ASF GitHub Bot commented on KAFKA-8391: --- gwenshap commented on pull request #7019:

[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&focusedCommentId=16906485#comment-16906485 ] Matthias J. Sax commented on KAFKA-6461: Different tests failed (all with caching

[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&focusedCommentId=16906484#comment-16906484 ] Matthias J. Sax commented on KAFKA-8078: Different tests failed (all with caching

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

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

[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&focusedCommentId=16906478#comment-16906478 ] Matthias J. Sax commented on KAFKA-8686: [https://builds.apache.org/job/kafka-pr-

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

[ https://issues.apache.org/jira/browse/KAFKA-8672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16906469#comment-16906469 ] Gwen Shapira commented on KAFKA-8672: - https://builds.apache.org/job/kafka-pr-jdk8-sc

[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&focusedCommentId=16906464#comment-16906464 ] Oleg Kuznetsov commented on KAFKA-7263: --- [~mjsax] Do you happen to have a workaroun

[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&focusedCommentId=16906456#comment-16906456 ] Gwen Shapira commented on KAFKA-8555: - https://builds.apache.org/job/kafka-pr-jdk11-s

[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&focusedCommentId=16906455#comment-16906455 ] Gwen Shapira commented on KAFKA-8686: - https://builds.apache.org/job/kafka-pr-jdk11-s

[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: https://builds.apache.org/job/kafka-pr-jdk11-scala2.12/6947/testReport/

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

[ https://issues.apache.org/jira/browse/KAFKA-8672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16906450#comment-16906450 ] Gwen Shapira commented on KAFKA-8672: - https://builds.apache.org/job/kafka-pr-jdk11-s

[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&focusedCommentId=16906399#comment-16906399 ] Ismael Juma commented on KAFKA-8797: Cc [~bchen225242] > BufferUnderflowException: E

[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&focusedCommentId=16906306#comment-16906306 ] ASF GitHub Bot commented on KAFKA-7941: --- rhauch commented on pull request #6283: KA

[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 se

[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&focusedCommentId=16906275#comment-16906275 ] ASF GitHub Bot commented on KAFKA-8774: --- rhauch commented on pull request #7197: KA

[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: kafka

[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&focusedCommentId=16906247#comment-16906247 ] ASF GitHub Bot commented on KAFKA-8789: --- dongjinleekr commented on pull request #72

[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 old

[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&focusedCommentId=16906147#comment-16906147 ] abdessamad commented on KAFKA-8699: --- Any feed back would be greatly appreciated > rack

[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 tar

[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&focusedCommentId=16905910#comment-16905910 ] Boquan Tang commented on KAFKA-3917: [~panpan.liu] This issue is solved in KAFKA-8335

[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&focusedCommentId=16905899#comment-16905899 ] panpan.liu commented on KAFKA-3917: --- [~boquan]  I met the same issue, version 2.0.1  B

[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 C