[GitHub] [kafka] dajac commented on pull request #9430: KAFKA-5235: GetOffsetShell: support for multiple topics and consumer configuration override

2020-10-20 Thread GitBox
dajac commented on pull request #9430: URL: https://github.com/apache/kafka/pull/9430#issuecomment-712640555 @urbandan Thanks for the PR. I haven't looked at it yet but I have already noticed that there are no unit/integration tests. We need some. You can look at how other commands are tes

[jira] [Commented] (KAFKA-9763) Recent changes to Connect's InsertField will fail to inject field on key of tombstone record

2020-10-20 Thread SeaAndHill (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17217364#comment-17217364 ] SeaAndHill commented on KAFKA-9763: --- [~rhauch] where can i down load  [1.0.3|https://is

[jira] [Commented] (KAFKA-8602) StreamThread Dies Because Restore Consumer is not Subscribed to Any Topic

2020-10-20 Thread SeaAndHill (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17217365#comment-17217365 ] SeaAndHill commented on KAFKA-8602: --- [~cadonna] where can i down  [1.0.3|https://issues

[GitHub] [kafka] dongjinleekr opened a new pull request #9457: MINOR: Trivial Cleanups

2020-10-20 Thread GitBox
dongjinleekr opened a new pull request #9457: URL: https://github.com/apache/kafka/pull/9457 Remove unused variables, methods, parameters, unthrown exceptions, and fixing typos. ### Committer Checklist (excluded from commit message) - [ ] Verify design and implementation - [ ]

[GitHub] [kafka] dongjinleekr commented on pull request #9457: MINOR: Trivial Cleanups

2020-10-20 Thread GitBox
dongjinleekr commented on pull request #9457: URL: https://github.com/apache/kafka/pull/9457#issuecomment-712677576 Here is some explanation about the last commit. `ProducerRunnable#shutdown` method is never called, and the variable with the same name also not changed from its defaul

[GitHub] [kafka] dongjinleekr commented on pull request #9421: MINOR: Change deprecated 'scala.collection.JavaConverters' to 'scala.jdk.CollectionConverters'

2020-10-20 Thread GitBox
dongjinleekr commented on pull request #9421: URL: https://github.com/apache/kafka/pull/9421#issuecomment-712678668 Hi @chia7712, I separated the other commits into this PR: https://github.com/apache/kafka/pull/9457 +1. Congratulations on becoming a committer. :smile: --

[GitHub] [kafka] rajinisivaram commented on pull request #9450: MINOR: Use `PartitionResponse.errorMessage` in exceptions in KafkaProducer

2020-10-20 Thread GitBox
rajinisivaram commented on pull request #9450: URL: https://github.com/apache/kafka/pull/9450#issuecomment-712711945 Test failures not related, merging to trunk and 2.7 This is an automated message from the Apache Git Service

[GitHub] [kafka] rajinisivaram merged pull request #9450: MINOR: Use `PartitionResponse.errorMessage` in exceptions in KafkaProducer

2020-10-20 Thread GitBox
rajinisivaram merged pull request #9450: URL: https://github.com/apache/kafka/pull/9450 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go

[jira] [Commented] (KAFKA-10043) Some parameters will be overwritten which was configured in consumer.config where running "ConsumerPerformance.scala"

2020-10-20 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17217456#comment-17217456 ] Luke Chen commented on KAFKA-10043: --- Thanks, [~chia7712] ! [~tigertan], I can take ov

[jira] [Created] (KAFKA-10620) Ensure Topic Metadata loaded just after create KafkaProducer

2020-10-20 Thread Luis Ashurei (Jira)
Luis Ashurei created KAFKA-10620: Summary: Ensure Topic Metadata loaded just after create KafkaProducer Key: KAFKA-10620 URL: https://issues.apache.org/jira/browse/KAFKA-10620 Project: Kafka

[GitHub] [kafka] tombentley commented on pull request #9433: KAFKA-10607: Consistent behaviour for response errorCounts()

2020-10-20 Thread GitBox
tombentley commented on pull request #9433: URL: https://github.com/apache/kafka/pull/9433#issuecomment-712750465 @dongjinleekr I did a review of all the subclasses. This is an automated message from the Apache Git Service. T

[GitHub] [kafka] thake commented on a change in pull request #9338: KAFKA-10515: Properly initialize nullable Serdes with default values

2020-10-20 Thread GitBox
thake commented on a change in pull request #9338: URL: https://github.com/apache/kafka/pull/9338#discussion_r508392317 ## File path: streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredWindowStore.java ## @@ -112,28 +120,26 @@ private void registerMetrics()

[GitHub] [kafka] thake commented on a change in pull request #9338: KAFKA-10515: Properly initialize nullable Serdes with default values

2020-10-20 Thread GitBox
thake commented on a change in pull request #9338: URL: https://github.com/apache/kafka/pull/9338#discussion_r508392735 ## File path: streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredWindowStore.java ## @@ -103,6 +104,13 @@ public void init(final StateStor

[GitHub] [kafka] rajinisivaram commented on a change in pull request #9454: KAFKA-10618: Add UUID class, use in protocols

2020-10-20 Thread GitBox
rajinisivaram commented on a change in pull request #9454: URL: https://github.com/apache/kafka/pull/9454#discussion_r508396130 ## File path: clients/src/main/java/org/apache/kafka/common/protocol/types/Type.java ## @@ -331,14 +331,14 @@ public String documentation() { pu

[GitHub] [kafka] rondagostino opened a new pull request #9458: MINOR: fix system tests sending ACLs through ZooKeeper

2020-10-20 Thread GitBox
rondagostino opened a new pull request #9458: URL: https://github.com/apache/kafka/pull/9458 http://confluent-kafka-branch-builder-system-test-results.s3-us-west-2.amazonaws.com/2020-10-20--001.1603165159--rondagostino--minor_another_acl_system_test_fix--e4506f309/report.html Tes

[GitHub] [kafka] rajinisivaram commented on pull request #9458: MINOR: fix system tests sending ACLs through ZooKeeper

2020-10-20 Thread GitBox
rajinisivaram commented on pull request #9458: URL: https://github.com/apache/kafka/pull/9458#issuecomment-712805894 Changes are only in system tests, so merging without waiting for build. This is an automated message from th

[GitHub] [kafka] rajinisivaram merged pull request #9458: MINOR: fix system tests sending ACLs through ZooKeeper

2020-10-20 Thread GitBox
rajinisivaram merged pull request #9458: URL: https://github.com/apache/kafka/pull/9458 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go

[GitHub] [kafka] dajac commented on a change in pull request #9406: KAFKA-10520; Ensure transactional producers poll if leastLoadedNode not available with max.in.flight=1

2020-10-20 Thread GitBox
dajac commented on a change in pull request #9406: URL: https://github.com/apache/kafka/pull/9406#discussion_r508473537 ## File path: clients/src/main/java/org/apache/kafka/clients/producer/internals/Sender.java ## @@ -444,10 +444,20 @@ private boolean maybeSendAndPollTransact

[GitHub] [kafka] tombentley opened a new pull request #9459: MINOR: Add some class javadoc to Admin client

2020-10-20 Thread GitBox
tombentley opened a new pull request #9459: URL: https://github.com/apache/kafka/pull/9459 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to

[GitHub] [kafka] tombentley commented on pull request #9459: MINOR: Add some class javadoc to Admin client

2020-10-20 Thread GitBox
tombentley commented on pull request #9459: URL: https://github.com/apache/kafka/pull/9459#issuecomment-712841664 @chia7712 following your merge of #9397 perhaps you could review this? Very strictly speaking this is changing the javadoc of a public API, so it could be argued that it

[GitHub] [kafka] ijuma merged pull request #9305: MINOR: Backport fixes to ClientUtils.resolve tests to 2.5

2020-10-20 Thread GitBox
ijuma merged pull request #9305: URL: https://github.com/apache/kafka/pull/9305 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

[jira] [Commented] (KAFKA-10470) zstd decompression with small batches is slow and causes excessive GC

2020-10-20 Thread Robert Wagner (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10470?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17217623#comment-17217623 ] Robert Wagner commented on KAFKA-10470: --- [zstd-jni version 1.4.5-7|https://githu

[GitHub] [kafka] chia7712 commented on a change in pull request #9459: MINOR: Add some class javadoc to Admin client

2020-10-20 Thread GitBox
chia7712 commented on a change in pull request #9459: URL: https://github.com/apache/kafka/pull/9459#discussion_r508503577 ## File path: clients/src/main/java/org/apache/kafka/clients/admin/Admin.java ## @@ -45,15 +45,75 @@ /** * The administrative client for Kafka, which su

[jira] [Commented] (KAFKA-10470) zstd decompression with small batches is slow and causes excessive GC

2020-10-20 Thread James Yuzawa (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10470?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17217626#comment-17217626 ] James Yuzawa commented on KAFKA-10470: -- The maintainer of zstd-jni seems to be back

[GitHub] [kafka] rhauch merged pull request #9429: KAFKA-10572 mirror-maker config changes for KIP-629

2020-10-20 Thread GitBox
rhauch merged pull request #9429: URL: https://github.com/apache/kafka/pull/9429 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

[GitHub] [kafka] chia7712 commented on pull request #5645: docs: Fix upgrade.mode references

2020-10-20 Thread GitBox
chia7712 commented on pull request #5645: URL: https://github.com/apache/kafka/pull/5645#issuecomment-712886750 @hasegeli Thanks for contribution! This is an automated message from the Apache Git Service. To respond to the me

[GitHub] [kafka] chia7712 merged pull request #5645: docs: Fix upgrade.mode references

2020-10-20 Thread GitBox
chia7712 merged pull request #5645: URL: https://github.com/apache/kafka/pull/5645 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to t

[GitHub] [kafka] chia7712 closed pull request #917: Properly quote $JAVA in order to avoid failure due to space char in PATH

2020-10-20 Thread GitBox
chia7712 closed pull request #917: URL: https://github.com/apache/kafka/pull/917 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

[GitHub] [kafka] chia7712 commented on pull request #917: Properly quote $JAVA in order to avoid failure due to space char in PATH

2020-10-20 Thread GitBox
chia7712 commented on pull request #917: URL: https://github.com/apache/kafka/pull/917#issuecomment-712892429 @pbaille sorry that I'm going to close this PR since the issue was resolved by https://github.com/apache/kafka/commit/c34f3d066ead40d8c0bca0cf92d4226d2d6416c6 ---

[GitHub] [kafka] ijuma commented on pull request #9421: MINOR: Change deprecated 'scala.collection.JavaConverters' to 'scala.jdk.CollectionConverters'

2020-10-20 Thread GitBox
ijuma commented on pull request #9421: URL: https://github.com/apache/kafka/pull/9421#issuecomment-712893208 I don't think this PR will work with Scala 2.12. See https://github.com/scala/scala-collection-compat/issues/346 Th

[GitHub] [kafka] ijuma opened a new pull request #9460: MINOR: Fix JDK8 compatibility issue in Snappy

2020-10-20 Thread GitBox
ijuma opened a new pull request #9460: URL: https://github.com/apache/kafka/pull/9460 See https://github.com/xerial/snappy-java/releases/tag/1.1.7.7 for more details. ### Committer Checklist (excluded from commit message) - [ ] Verify design and implementation - [ ] Verify tes

[GitHub] [kafka] ijuma commented on pull request #9460: MINOR: Fix JDK8 compatibility issue in Snappy

2020-10-20 Thread GitBox
ijuma commented on pull request #9460: URL: https://github.com/apache/kafka/pull/9460#issuecomment-712899794 This needs to be cherry-picked to the 2.7 branch. This is an automated message from the Apache Git Service. To respo

[GitHub] [kafka] rhauch commented on a change in pull request #9359: kafka-10273 Connect Converters should produce actionable error messages

2020-10-20 Thread GitBox
rhauch commented on a change in pull request #9359: URL: https://github.com/apache/kafka/pull/9359#discussion_r508557355 ## File path: connect/api/src/main/java/org/apache/kafka/connect/storage/StringConverter.java ## @@ -79,7 +79,7 @@ public void configure(Map configs, boolea

[jira] [Resolved] (KAFKA-10572) Rename MirrorMaker 2 blacklist configs for KIP-629

2020-10-20 Thread Randall Hauch (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10572?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch resolved KAFKA-10572. --- Fix Version/s: 2.7.0 Reviewer: Randall Hauch Resolution: Fixed Merged to the

[GitHub] [kafka] rajinisivaram commented on a change in pull request #9406: KAFKA-10520; Ensure transactional producers poll if leastLoadedNode not available with max.in.flight=1

2020-10-20 Thread GitBox
rajinisivaram commented on a change in pull request #9406: URL: https://github.com/apache/kafka/pull/9406#discussion_r508583528 ## File path: clients/src/main/java/org/apache/kafka/clients/producer/internals/Sender.java ## @@ -444,10 +444,20 @@ private boolean maybeSendAndPoll

[GitHub] [kafka] bbejeck opened a new pull request #9461: MINOR: Clean-up streams javadoc warnings

2020-10-20 Thread GitBox
bbejeck opened a new pull request #9461: URL: https://github.com/apache/kafka/pull/9461 *Summary of testing strategy (including rationale) for the feature or bug fix. Unit and/or integration tests are expected for any behaviour change and system tests should be considered fo

[GitHub] [kafka] bbejeck commented on pull request #9461: MINOR: Clean-up streams javadoc warnings

2020-10-20 Thread GitBox
bbejeck commented on pull request #9461: URL: https://github.com/apache/kafka/pull/9461#issuecomment-712922842 ok to test This is an automated message from the Apache Git Service. To respond to the message, please log on to G

[GitHub] [kafka] bbejeck commented on pull request #9461: MINOR: Clean-up streams javadoc warnings

2020-10-20 Thread GitBox
bbejeck commented on pull request #9461: URL: https://github.com/apache/kafka/pull/9461#issuecomment-712924272 ping one of @abbccdda, @ableegoldman, @mjsax, @vvcephei for review This is an automated message from the Apache G

[GitHub] [kafka] jolshan commented on a change in pull request #9454: KAFKA-10618: Add UUID class, use in protocols

2020-10-20 Thread GitBox
jolshan commented on a change in pull request #9454: URL: https://github.com/apache/kafka/pull/9454#discussion_r508597656 ## File path: clients/src/test/java/org/apache/kafka/common/UUIDTest.java ## @@ -0,0 +1,60 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under

[GitHub] [kafka] dajac commented on a change in pull request #9406: KAFKA-10520; Ensure transactional producers poll if leastLoadedNode not available with max.in.flight=1

2020-10-20 Thread GitBox
dajac commented on a change in pull request #9406: URL: https://github.com/apache/kafka/pull/9406#discussion_r508626975 ## File path: clients/src/main/java/org/apache/kafka/clients/producer/internals/Sender.java ## @@ -444,10 +444,20 @@ private boolean maybeSendAndPollTransact

[GitHub] [kafka] jolshan commented on a change in pull request #9454: KAFKA-10618: Add UUID class, use in protocols

2020-10-20 Thread GitBox
jolshan commented on a change in pull request #9454: URL: https://github.com/apache/kafka/pull/9454#discussion_r508631712 ## File path: clients/src/main/java/org/apache/kafka/common/protocol/types/Type.java ## @@ -331,14 +331,14 @@ public String documentation() { public s

[GitHub] [kafka] Fleshgrinder commented on a change in pull request #9369: KAFKA-4715: Ignore case of CompressionType and OffsetResetStrategy

2020-10-20 Thread GitBox
Fleshgrinder commented on a change in pull request #9369: URL: https://github.com/apache/kafka/pull/9369#discussion_r508639180 ## File path: clients/src/main/java/org/apache/kafka/clients/consumer/OffsetResetStrategy.java ## @@ -16,6 +16,40 @@ */ package org.apache.kafka.cl

[GitHub] [kafka] Fleshgrinder commented on a change in pull request #9369: KAFKA-4715: Ignore case of CompressionType and OffsetResetStrategy

2020-10-20 Thread GitBox
Fleshgrinder commented on a change in pull request #9369: URL: https://github.com/apache/kafka/pull/9369#discussion_r508641877 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java ## @@ -361,7 +363,7 @@ public static StreamThread c

[GitHub] [kafka] dajac opened a new pull request #9462: MINOR; Fix UpdateMetadataRequestTest.testVersionLogic's assertions

2020-10-20 Thread GitBox
dajac opened a new pull request #9462: URL: https://github.com/apache/kafka/pull/9462 `UpdateMetadataRequestTest.testVersionLogic`'s assertions must verify the deserialized request. ### Committer Checklist (excluded from commit message) - [ ] Verify design and implementation -

[GitHub] [kafka] junrao merged pull request #9456: MINOR: Check for active controller in UpdateFeatures request processing logic

2020-10-20 Thread GitBox
junrao merged pull request #9456: URL: https://github.com/apache/kafka/pull/9456 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

[GitHub] [kafka] dajac commented on pull request #9462: MINOR; Fix UpdateMetadataRequestTest.testVersionLogic's assertions

2020-10-20 Thread GitBox
dajac commented on pull request #9462: URL: https://github.com/apache/kafka/pull/9462#issuecomment-712957528 @chia7712 Could you take a look at this one please? This is an automated message from the Apache Git Service. To res

[GitHub] [kafka] junrao merged pull request #9455: KAFKA-10599: Implement basic CLI tool for feature versioning system

2020-10-20 Thread GitBox
junrao merged pull request #9455: URL: https://github.com/apache/kafka/pull/9455 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

[GitHub] [kafka] bbejeck opened a new pull request #9463: MINOR: Clean-up client javadoc warnings

2020-10-20 Thread GitBox
bbejeck opened a new pull request #9463: URL: https://github.com/apache/kafka/pull/9463 *More detailed description of your change, if necessary. The PR title and PR message become the squashed commit message, so use a separate comment to ping reviewers.* *Summary of testing s

[GitHub] [kafka] kkonstantine merged pull request #9431: KAFKA-10426: Deadlock on session key update.

2020-10-20 Thread GitBox
kkonstantine merged pull request #9431: URL: https://github.com/apache/kafka/pull/9431 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go

[GitHub] [kafka] vvcephei commented on a change in pull request #9446: MINOR: distinguish between missing source topics and internal assignment errors

2020-10-20 Thread GitBox
vvcephei commented on a change in pull request #9446: URL: https://github.com/apache/kafka/pull/9446#discussion_r508657808 ## File path: streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignorTest.java ## @@ -1899,14 +1973,18 @@ public void

[jira] [Commented] (KAFKA-9975) KIP-611: Improved Handling of Abandoned Connectors and Tasks

2020-10-20 Thread Bill Bejeck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17217725#comment-17217725 ] Bill Bejeck commented on KAFKA-9975: As part of the 2.7.0 release process, I'm cleari

[jira] [Updated] (KAFKA-9975) KIP-611: Improved Handling of Abandoned Connectors and Tasks

2020-10-20 Thread Bill Bejeck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-9975: --- Fix Version/s: (was: 2.7.0) > KIP-611: Improved Handling of Abandoned Connectors and Tasks >

[jira] [Commented] (KAFKA-9145) AbstractCoordinator should respect retry backoff between rebalances

2020-10-20 Thread Bill Bejeck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17217726#comment-17217726 ] Bill Bejeck commented on KAFKA-9145: As part of the 2.7.0 release process, I'm cleari

[jira] [Updated] (KAFKA-9145) AbstractCoordinator should respect retry backoff between rebalances

2020-10-20 Thread Bill Bejeck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-9145: --- Fix Version/s: (was: 2.7.0) > AbstractCoordinator should respect retry backoff between rebalances

[jira] [Updated] (KAFKA-8597) Give access to the Dead Letter Queue APIs to Kafka Connect Developers

2020-10-20 Thread Bill Bejeck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-8597: --- Fix Version/s: (was: 2.7.0) > Give access to the Dead Letter Queue APIs to Kafka Connect Develope

[jira] [Commented] (KAFKA-8597) Give access to the Dead Letter Queue APIs to Kafka Connect Developers

2020-10-20 Thread Bill Bejeck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17217727#comment-17217727 ] Bill Bejeck commented on KAFKA-8597: As part of the 2.7.0 release process, I'm cleari

[jira] [Updated] (KAFKA-9510) Quotas may resolve to incorrect value if user is empty

2020-10-20 Thread Bill Bejeck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-9510: --- Fix Version/s: (was: 2.7.0) > Quotas may resolve to incorrect value if user is empty > --

[jira] [Commented] (KAFKA-9510) Quotas may resolve to incorrect value if user is empty

2020-10-20 Thread Bill Bejeck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17217728#comment-17217728 ] Bill Bejeck commented on KAFKA-9510: As part of the 2.7.0 release process, I'm cleari

[jira] [Commented] (KAFKA-9520) Deprecate ZooKeeper access for kafka-reassign-partitions.sh

2020-10-20 Thread Bill Bejeck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17217730#comment-17217730 ] Bill Bejeck commented on KAFKA-9520: As part of the 2.7.0 release process, I'm cleari

[jira] [Updated] (KAFKA-9520) Deprecate ZooKeeper access for kafka-reassign-partitions.sh

2020-10-20 Thread Bill Bejeck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-9520: --- Fix Version/s: (was: 2.7.0) > Deprecate ZooKeeper access for kafka-reassign-partitions.sh > -

[jira] [Updated] (KAFKA-9592) Safely abort Producer transactions during application shutdown

2020-10-20 Thread Bill Bejeck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-9592: --- Fix Version/s: (was: 2.7.0) > Safely abort Producer transactions during application shutdown > --

[jira] [Commented] (KAFKA-9592) Safely abort Producer transactions during application shutdown

2020-10-20 Thread Bill Bejeck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17217731#comment-17217731 ] Bill Bejeck commented on KAFKA-9592: As part of the 2.7.0 release process, I'm cleari

[jira] [Updated] (KAFKA-10053) Update Document for new feature that Allow HTTP Response Headers to be Configured for Kafka Connect

2020-10-20 Thread Bill Bejeck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-10053: Fix Version/s: (was: 2.7.0) > Update Document for new feature that Allow HTTP Response Headers

[jira] [Commented] (KAFKA-10053) Update Document for new feature that Allow HTTP Response Headers to be Configured for Kafka Connect

2020-10-20 Thread Bill Bejeck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17217732#comment-17217732 ] Bill Bejeck commented on KAFKA-10053: - As part of the 2.7.0 release process, I'm cle

[GitHub] [kafka] feyman2016 commented on a change in pull request #9270: KAFKA-10284: Group membership update due to static member rejoin should be persisted

2020-10-20 Thread GitBox
feyman2016 commented on a change in pull request #9270: URL: https://github.com/apache/kafka/pull/9270#discussion_r508668288 ## File path: core/src/main/scala/kafka/coordinator/group/GroupCoordinator.scala ## @@ -1037,24 +1037,52 @@ class GroupCoordinator(val brokerId: Int,

[GitHub] [kafka] feyman2016 commented on pull request #9270: KAFKA-10284: Group membership update due to static member rejoin should be persisted

2020-10-20 Thread GitBox
feyman2016 commented on pull request #9270: URL: https://github.com/apache/kafka/pull/9270#issuecomment-712978606 @abbccdda @vvcephei Updated the PR, thanks! This is an automated message from the Apache Git Service. To respon

[jira] [Commented] (KAFKA-10470) zstd decompression with small batches is slow and causes excessive GC

2020-10-20 Thread Robert Wagner (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10470?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17217734#comment-17217734 ] Robert Wagner commented on KAFKA-10470: --- I have run a test with the zstd streams w

[jira] [Assigned] (KAFKA-9975) KIP-611: Improved Handling of Abandoned Connectors and Tasks

2020-10-20 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton reassigned KAFKA-9975: Assignee: (was: Chris Egerton) > KIP-611: Improved Handling of Abandoned Connectors an

[jira] [Commented] (KAFKA-10563) Make sure task directories don't remain locked by dead threads

2020-10-20 Thread Bill Bejeck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17217736#comment-17217736 ] Bill Bejeck commented on KAFKA-10563: - [~ableegoldman] I'm going to set the fix vers

[jira] [Comment Edited] (KAFKA-10470) zstd decompression with small batches is slow and causes excessive GC

2020-10-20 Thread Robert Wagner (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10470?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17217734#comment-17217734 ] Robert Wagner edited comment on KAFKA-10470 at 10/20/20, 4:29 PM:

[jira] [Updated] (KAFKA-10563) Make sure task directories don't remain locked by dead threads

2020-10-20 Thread Bill Bejeck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-10563: Fix Version/s: (was: 2.7.0) 2.8.0 > Make sure task directories don't remain

[jira] [Commented] (KAFKA-7493) Rewrite test_broker_type_bounce_at_start

2020-10-20 Thread Bill Bejeck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17217743#comment-17217743 ] Bill Bejeck commented on KAFKA-7493: As part of the 2.7.0 release process, I'm going

[jira] [Updated] (KAFKA-7493) Rewrite test_broker_type_bounce_at_start

2020-10-20 Thread Bill Bejeck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-7493: --- Fix Version/s: (was: 2.7.0) 2.8.0 > Rewrite test_broker_type_bounce_at_start >

[jira] [Comment Edited] (KAFKA-10470) zstd decompression with small batches is slow and causes excessive GC

2020-10-20 Thread Robert Wagner (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10470?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17217734#comment-17217734 ] Robert Wagner edited comment on KAFKA-10470 at 10/20/20, 4:46 PM:

[jira] [Updated] (KAFKA-10038) ConsumerPerformance.scala supports the setting of client.id

2020-10-20 Thread Bill Bejeck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-10038: Fix Version/s: (was: 2.7.0) > ConsumerPerformance.scala supports the setting of client.id > --

[jira] [Commented] (KAFKA-10038) ConsumerPerformance.scala supports the setting of client.id

2020-10-20 Thread Bill Bejeck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17217751#comment-17217751 ] Bill Bejeck commented on KAFKA-10038: - As part of the 2.7.0 release process, I'm cle

[jira] [Updated] (KAFKA-8929) MM2 system tests

2020-10-20 Thread Bill Bejeck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-8929: --- Fix Version/s: (was: 2.7.0) > MM2 system tests > > > Key: KAFKA-

[jira] [Commented] (KAFKA-8929) MM2 system tests

2020-10-20 Thread Bill Bejeck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17217752#comment-17217752 ] Bill Bejeck commented on KAFKA-8929: As part of the 2.7.0 release process, I'm cleari

[jira] [Commented] (KAFKA-9958) Expose Kafka Metrics in Authorizer

2020-10-20 Thread Bill Bejeck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9958?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17217754#comment-17217754 ] Bill Bejeck commented on KAFKA-9958: As part of the 2.7.0 release process, I'm cleari

[jira] [Commented] (KAFKA-9747) No tasks created for a connector

2020-10-20 Thread Randall Hauch (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17217753#comment-17217753 ] Randall Hauch commented on KAFKA-9747: -- If anyone has this problem and [~pawel.wilcz

[jira] [Updated] (KAFKA-9958) Expose Kafka Metrics in Authorizer

2020-10-20 Thread Bill Bejeck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-9958: --- Fix Version/s: (was: 2.7.0) > Expose Kafka Metrics in Authorizer > --

[jira] [Updated] (KAFKA-9624) test_throttled_reassignment as EndToEndTest

2020-10-20 Thread Bill Bejeck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-9624: --- Fix Version/s: (was: 2.7.0) > test_throttled_reassignment as EndToEndTest > -

[jira] [Commented] (KAFKA-9624) test_throttled_reassignment as EndToEndTest

2020-10-20 Thread Bill Bejeck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17217759#comment-17217759 ] Bill Bejeck commented on KAFKA-9624: As part of the 2.7.0 release process, I'm cleari

[jira] [Commented] (KAFKA-9861) Process Simplification - Community Validation of Kafka Release Candidates

2020-10-20 Thread Bill Bejeck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17217764#comment-17217764 ] Bill Bejeck commented on KAFKA-9861: Hi [~iekpo], As part of the 2.7.0 release proces

[jira] [Updated] (KAFKA-9861) Process Simplification - Community Validation of Kafka Release Candidates

2020-10-20 Thread Bill Bejeck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-9861: --- Fix Version/s: (was: 2.7.0) 2.8.0 > Process Simplification - Community Validat

[jira] [Updated] (KAFKA-8930) MM2 documentation

2020-10-20 Thread Bill Bejeck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8930?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-8930: --- Fix Version/s: (was: 2.7.0) > MM2 documentation > - > > Key: KAFK

[jira] [Commented] (KAFKA-8930) MM2 documentation

2020-10-20 Thread Bill Bejeck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17217765#comment-17217765 ] Bill Bejeck commented on KAFKA-8930: As part of the 2.7.0 release process, I'm cleari

[jira] [Commented] (KAFKA-9096) Validate config inter-dependencies for KafkaConfig only after dynamic configs are loaded

2020-10-20 Thread Bill Bejeck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17217770#comment-17217770 ] Bill Bejeck commented on KAFKA-9096: As part of the 2.7.0 release process, I'm cleari

[jira] [Updated] (KAFKA-9096) Validate config inter-dependencies for KafkaConfig only after dynamic configs are loaded

2020-10-20 Thread Bill Bejeck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-9096: --- Fix Version/s: (was: 2.7.0) > Validate config inter-dependencies for KafkaConfig only after dynam

[jira] [Updated] (KAFKA-9397) Deprecate Direct Zookeeper access in Kafka Administrative Tools

2020-10-20 Thread Bill Bejeck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-9397: --- Fix Version/s: (was: 2.7.0) > Deprecate Direct Zookeeper access in Kafka Administrative Tools > -

[jira] [Commented] (KAFKA-9397) Deprecate Direct Zookeeper access in Kafka Administrative Tools

2020-10-20 Thread Bill Bejeck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17217773#comment-17217773 ] Bill Bejeck commented on KAFKA-9397: As part of the 2.7.0 release process, I'm cleari

[jira] [Commented] (KAFKA-9621) AdminClient listOffsets operation does not respect retries and backoff

2020-10-20 Thread Bill Bejeck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17217775#comment-17217775 ] Bill Bejeck commented on KAFKA-9621: As part of the 2.7.0 release process, I'm cleari

[jira] [Updated] (KAFKA-9621) AdminClient listOffsets operation does not respect retries and backoff

2020-10-20 Thread Bill Bejeck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-9621: --- Fix Version/s: (was: 2.7.0) > AdminClient listOffsets operation does not respect retries and back

[jira] [Comment Edited] (KAFKA-8602) StreamThread Dies Because Restore Consumer is not Subscribed to Any Topic

2020-10-20 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17217776#comment-17217776 ] Matthias J. Sax edited comment on KAFKA-8602 at 10/20/20, 5:02 PM:

[jira] [Commented] (KAFKA-8602) StreamThread Dies Because Restore Consumer is not Subscribed to Any Topic

2020-10-20 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17217776#comment-17217776 ] Matthias J. Sax commented on KAFKA-8602: Version 1.0.3 was never released. All av

[GitHub] [kafka] abbccdda commented on pull request #9103: KAFKA-10181: Use Envelope RPC to do redirection for (Incremental)AlterConfig, AlterClientQuota and CreateTopics

2020-10-20 Thread GitBox
abbccdda commented on pull request #9103: URL: https://github.com/apache/kafka/pull/9103#issuecomment-713007022 retest this please This is an automated message from the Apache Git Service. To respond to the message, please lo

[jira] [Commented] (KAFKA-10470) zstd decompression with small batches is slow and causes excessive GC

2020-10-20 Thread James Yuzawa (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10470?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17217786#comment-17217786 ] James Yuzawa commented on KAFKA-10470: -- Ok, I'm still going to attempt to add some

[GitHub] [kafka] mjsax commented on a change in pull request #9461: MINOR: Clean-up streams javadoc warnings

2020-10-20 Thread GitBox
mjsax commented on a change in pull request #9461: URL: https://github.com/apache/kafka/pull/9461#discussion_r508705351 ## File path: streams/src/main/java/org/apache/kafka/streams/kstream/CogroupedKStream.java ## @@ -184,9 +184,9 @@ * * KafkaStreams streams = ...

[jira] [Commented] (KAFKA-10616) StreamThread killed by "IllegalStateException: The processor is already closed"

2020-10-20 Thread Guozhang Wang (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10616?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17217813#comment-17217813 ] Guozhang Wang commented on KAFKA-10616: --- I think this is a long lurking bug caused

[GitHub] [kafka] mjsax commented on pull request #9000: KAFKA-10036 Improve handling and documentation of Suppliers

2020-10-20 Thread GitBox
mjsax commented on pull request #9000: URL: https://github.com/apache/kafka/pull/9000#issuecomment-713022002 @soarez Thanks for the update. It seems that `TopologyTestDriverTest.shouldCloseProcessor` is broken. Can you fix it and update the PR? ---

  1   2   >