[jira] [Resolved] (KAFKA-8837) Several integration tests incorrectly use verifyNonDaemonThreadsStatus

2019-08-27 Thread Ismael Juma (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-8837. Fix Version/s: 2.4.0 Resolution: Fixed > Several integration tests incorrectly use verifyNon

[jira] [Commented] (KAFKA-8837) Several integration tests incorrectly use verifyNonDaemonThreadsStatus

2019-08-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8837?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16917425#comment-16917425 ] ASF GitHub Bot commented on KAFKA-8837: --- ijuma commented on pull request #7255: KAF

[jira] [Comment Edited] (KAFKA-8828) [BC Break] Global store returns a TimestampedKeyValueStore in 2.3

2019-08-27 Thread Marcos Passos (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16917321#comment-16917321 ] Marcos Passos edited comment on KAFKA-8828 at 8/28/19 2:02 AM:

[jira] [Comment Edited] (KAFKA-8828) [BC Break] Global store returns a TimestampedKeyValueStore in 2.3

2019-08-27 Thread Marcos Passos (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16917321#comment-16917321 ] Marcos Passos edited comment on KAFKA-8828 at 8/28/19 2:01 AM:

[jira] [Commented] (KAFKA-8828) [BC Break] Global store returns a TimestampedKeyValueStore in 2.3

2019-08-27 Thread Marcos Passos (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16917321#comment-16917321 ] Marcos Passos commented on KAFKA-8828: -- Matthias, I think you get me wrong. I'm not

[jira] [Commented] (KAFKA-8828) [BC Break] Global store returns a TimestampedKeyValueStore in 2.3

2019-08-27 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16917315#comment-16917315 ] Matthias J. Sax commented on KAFKA-8828: [~johannz], [~marcospassos]: thanks for

[jira] [Created] (KAFKA-8841) Optimize Partition.maybeIncrementLeaderHW

2019-08-27 Thread Jason Gustafson (Jira)
Jason Gustafson created KAFKA-8841: -- Summary: Optimize Partition.maybeIncrementLeaderHW Key: KAFKA-8841 URL: https://issues.apache.org/jira/browse/KAFKA-8841 Project: Kafka Issue Type: Impro

[jira] [Commented] (KAFKA-6460) Add mocks for state stores used in Streams unit testing

2019-08-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-6460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16917215#comment-16917215 ] ASF GitHub Bot commented on KAFKA-6460: --- shunge commented on pull request #7261: KA

[jira] [Commented] (KAFKA-8840) Fix bug where ClientCompatibilityFeaturesTest fails when running multiple iterations

2019-08-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16917202#comment-16917202 ] ASF GitHub Bot commented on KAFKA-8840: --- cmccabe commented on pull request #7260: K

[jira] [Commented] (KAFKA-7711) Add a bounded flush() API to Kafka Producer

2019-08-27 Thread kun du (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16917197#comment-16917197 ] kun du commented on KAFKA-7711: --- Created a KIP for this  [https://cwiki.apache.org/confluen

[jira] [Created] (KAFKA-8840) Fix bug where ClientCompatibilityFeaturesTest fails when running multiple iterations

2019-08-27 Thread Colin P. McCabe (Jira)
Colin P. McCabe created KAFKA-8840: -- Summary: Fix bug where ClientCompatibilityFeaturesTest fails when running multiple iterations Key: KAFKA-8840 URL: https://issues.apache.org/jira/browse/KAFKA-8840

[jira] [Commented] (KAFKA-8839) Improve logging in Kafka Streams around debugging task lifecycle

2019-08-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8839?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16917150#comment-16917150 ] ASF GitHub Bot commented on KAFKA-8839: --- vinothchandar commented on pull request #7

[jira] [Resolved] (KAFKA-8494) Refactor Consumer#StickyAssignor and add CooperativeStickyAssignor (part 4)

2019-08-27 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman resolved KAFKA-8494. Resolution: Fixed > Refactor Consumer#StickyAssignor and add CooperativeStickyAssig

[jira] [Commented] (KAFKA-8179) Incremental Rebalance Protocol for Kafka Consumer

2019-08-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16917131#comment-16917131 ] ASF GitHub Bot commented on KAFKA-8179: --- guozhangwang commented on pull request #71

[jira] [Assigned] (KAFKA-8839) Improve logging in Kafka Streams around debugging task lifecycle

2019-08-27 Thread Vinoth Chandar (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vinoth Chandar reassigned KAFKA-8839: - Assignee: Vinoth Chandar > Improve logging in Kafka Streams around debugging task lifecy

[jira] [Created] (KAFKA-8839) Improve logging in Kafka Streams around debugging task lifecycle

2019-08-27 Thread Vinoth Chandar (Jira)
Vinoth Chandar created KAFKA-8839: - Summary: Improve logging in Kafka Streams around debugging task lifecycle Key: KAFKA-8839 URL: https://issues.apache.org/jira/browse/KAFKA-8839 Project: Kafka

[jira] [Commented] (KAFKA-8724) log cleaner thread dies when attempting to clean a __consumer_offsets partition after upgrade from 2.0->2.3

2019-08-27 Thread Jason Gustafson (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8724?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16917085#comment-16917085 ] Jason Gustafson commented on KAFKA-8724: There is a race condition here, but I'm

[jira] [Assigned] (KAFKA-8724) log cleaner thread dies when attempting to clean a __consumer_offsets partition after upgrade from 2.0->2.3

2019-08-27 Thread Jason Gustafson (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reassigned KAFKA-8724: -- Assignee: Jason Gustafson > log cleaner thread dies when attempting to clean a __consu

[jira] [Commented] (KAFKA-8745) DumpLogSegments doesn't show keys, when the message is null

2019-08-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16917074#comment-16917074 ] ASF GitHub Bot commented on KAFKA-8745: --- guozhangwang commented on pull request #71

[jira] [Updated] (KAFKA-8837) Several integration tests incorrectly use verifyNonDaemonThreadsStatus

2019-08-27 Thread Anna Povzner (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anna Povzner updated KAFKA-8837: Description: @After method in KafkaMetricReporterClusterIdTest calls  `TestUtils.verifyNonDaemonTh

[jira] [Commented] (KAFKA-8810) Add mechanism to detect topology mismatch between streams instances

2019-08-27 Thread Vinoth Chandar (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16916881#comment-16916881 ] Vinoth Chandar commented on KAFKA-8810: --- Great points [~vvcephei] . I have not cons

[jira] [Commented] (KAFKA-7878) Connect Task already exists in this worker when failed to create consumer

2019-08-27 Thread Echo Xu (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16916779#comment-16916779 ] Echo Xu commented on KAFKA-7878: We encountered the exact same issue. > Connect Task alr

[jira] [Created] (KAFKA-8838) Allow consumer group tool to work with non-existing consumer groups

2019-08-27 Thread Patrik Kleindl (Jira)
Patrik Kleindl created KAFKA-8838: - Summary: Allow consumer group tool to work with non-existing consumer groups Key: KAFKA-8838 URL: https://issues.apache.org/jira/browse/KAFKA-8838 Project: Kafka

[jira] [Updated] (KAFKA-8766) Allow a custom offset policy for Kafka Streams applications

2019-08-27 Thread Patrik Kleindl (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Patrik Kleindl updated KAFKA-8766: -- Description: Currently when starting a new streams application (= new consumer group) you can

[jira] [Commented] (KAFKA-8562) SASL_SSL still performs reverse DNS lookup despite KAFKA-5051

2019-08-27 Thread Rajini Sivaram (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16916481#comment-16916481 ] Rajini Sivaram commented on KAFKA-8562: --- This is a duplicate of https://issues.apac

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

2019-08-27 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-8579. -- Resolution: Fixed > Expose RocksDB Metrics to JMX > - > >