[jira] [Resolved] (KAFKA-8193) Flaky Test MetricsIntegrationTest#testStreamMetricOfWindowStore

[ https://issues.apache.org/jira/browse/KAFKA-8193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-8193. Resolution: Duplicate > Flaky Test MetricsIntegrationTest#testStreamMetricOfWindowStore > -

[jira] [Updated] (KAFKA-8193) Flaky Test MetricsIntegrationTest#testStreamMetricOfWindowStore

[ https://issues.apache.org/jira/browse/KAFKA-8193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8193: --- Fix Version/s: (was: 2.4.0) > Flaky Test MetricsIntegrationTest#testStreamMetricOfWindowS

[jira] [Commented] (KAFKA-8263) Flaky Test MetricsIntegrationTest#testStreamMetricOfWindowStore

[ https://issues.apache.org/jira/browse/KAFKA-8263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16860599#comment-16860599 ] Matthias J. Sax commented on KAFKA-8263: [https://builds.apache.org/blue/organiza

[jira] [Updated] (KAFKA-8418) Connect System tests are not waiting for REST resources to be registered

[ https://issues.apache.org/jira/browse/KAFKA-8418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8418: --- Fix Version/s: (was: 2.3) > Connect System tests are not waiting for REST resources to be

[jira] [Updated] (KAFKA-8265) Connect Client Config Override policy

[ https://issues.apache.org/jira/browse/KAFKA-8265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8265: --- Fix Version/s: (was: 2.3) 2.3.0 > Connect Client Config Override polic

[jira] [Updated] (KAFKA-8473) Adjust Connect system tests for incremental cooperative rebalancing and enable them for both eager and incremental cooperative rebalancing

[ https://issues.apache.org/jira/browse/KAFKA-8473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8473: --- Affects Version/s: (was: 2.3) 2.3.0 > Adjust Connect system tests

[jira] [Updated] (KAFKA-8475) Temporarily restore SslFactory.sslContext() helper

[ https://issues.apache.org/jira/browse/KAFKA-8475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8475: --- Fix Version/s: (was: 2.3) 2.3.0 > Temporarily restore SslFactory.sslCo

[jira] [Updated] (KAFKA-8473) Adjust Connect system tests for incremental cooperative rebalancing and enable them for both eager and incremental cooperative rebalancing

[ https://issues.apache.org/jira/browse/KAFKA-8473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8473: --- Fix Version/s: (was: 2.3) 2.3.0 > Adjust Connect system tests for incr

[jira] [Commented] (KAFKA-7988) Flaky Test DynamicBrokerReconfigurationTest#testThreadPoolResize

[ https://issues.apache.org/jira/browse/KAFKA-7988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16860597#comment-16860597 ] Matthias J. Sax commented on KAFKA-7988: Failed in 2.3:  [https://builds.apache.o

[jira] [Updated] (KAFKA-7988) Flaky Test DynamicBrokerReconfigurationTest#testThreadPoolResize

[ https://issues.apache.org/jira/browse/KAFKA-7988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7988: --- Affects Version/s: 2.3.0 > Flaky Test DynamicBrokerReconfigurationTest#testThreadPoolResize >

[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=16860596#comment-16860596 ] Matthias J. Sax commented on KAFKA-8078: Failed again with timeout:  [https://bui

[jira] [Commented] (KAFKA-8041) Flaky Test LogDirFailureTest#testIOExceptionDuringLogRoll

[ https://issues.apache.org/jira/browse/KAFKA-8041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16860594#comment-16860594 ] Matthias J. Sax commented on KAFKA-8041: Failed again:  [https://builds.apache.or

[jira] [Comment Edited] (KAFKA-8516) Consider allowing all replicas to have read/write permissions

[ https://issues.apache.org/jira/browse/KAFKA-8516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16860591#comment-16860591 ] Richard Yu edited comment on KAFKA-8516 at 6/11/19 6:16 AM: W

[jira] [Comment Edited] (KAFKA-8516) Consider allowing all replicas to have read/write permissions

[ https://issues.apache.org/jira/browse/KAFKA-8516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16860591#comment-16860591 ] Richard Yu edited comment on KAFKA-8516 at 6/11/19 6:15 AM: W

[jira] [Commented] (KAFKA-8516) Consider allowing all replicas to have read/write permissions

[ https://issues.apache.org/jira/browse/KAFKA-8516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16860591#comment-16860591 ] Richard Yu commented on KAFKA-8516: --- Well, this is when we start straying into an area

[jira] [Commented] (KAFKA-8450) Augment processed in MockProcessor as KeyValueAndTimestamp

[ https://issues.apache.org/jira/browse/KAFKA-8450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16860589#comment-16860589 ] Matthias J. Sax commented on KAFKA-8450: Yes. Instead of calling `makeRecord` tha

[jira] [Commented] (KAFKA-8513) Add kafka-streams-application-reset.bat for Windows platform

[ https://issues.apache.org/jira/browse/KAFKA-8513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16860588#comment-16860588 ] Matthias J. Sax commented on KAFKA-8513: Ack. Fine with me. The PR looks good in

[jira] [Commented] (KAFKA-8516) Consider allowing all replicas to have read/write permissions

[ https://issues.apache.org/jira/browse/KAFKA-8516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16860587#comment-16860587 ] Matthias J. Sax commented on KAFKA-8516: Agreed. In fact, I am not even sure if

[jira] [Created] (KAFKA-8522) Tombstones can survive forever

Evelyn Bayes created KAFKA-8522: --- Summary: Tombstones can survive forever Key: KAFKA-8522 URL: https://issues.apache.org/jira/browse/KAFKA-8522 Project: Kafka Issue Type: Bug Componen

[jira] [Resolved] (KAFKA-8349) Add Windows batch files corresponding to kafka-delete-records.sh and kafka-log-dirs.sh

[ https://issues.apache.org/jira/browse/KAFKA-8349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kengo Seki resolved KAFKA-8349. --- Resolution: Fixed Closing this since it's been already merged. Thanks [~hachikuji]! > Add Windows ba

[jira] [Commented] (KAFKA-8513) Add kafka-streams-application-reset.bat for Windows platform

[ https://issues.apache.org/jira/browse/KAFKA-8513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16860483#comment-16860483 ] Kengo Seki commented on KAFKA-8513: --- Thank you for the comments [~mjsax] and [~guozhang

[jira] [Resolved] (KAFKA-8333) Load high watermark checkpoint only once when handling LeaderAndIsr requests

[ https://issues.apache.org/jira/browse/KAFKA-8333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-8333. Resolution: Fixed Fix Version/s: 2.4.0 > Load high watermark checkpoint only once wh

[jira] [Updated] (KAFKA-8333) Load high watermark checkpoint only once when handling LeaderAndIsr requests

[ https://issues.apache.org/jira/browse/KAFKA-8333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-8333: --- Issue Type: Improvement (was: Bug) > Load high watermark checkpoint only once when handling

[jira] [Commented] (KAFKA-8333) Load high watermark checkpoint only once when handling LeaderAndIsr requests

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

[jira] [Commented] (KAFKA-8513) Add kafka-streams-application-reset.bat for Windows platform

[ https://issues.apache.org/jira/browse/KAFKA-8513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16860465#comment-16860465 ] Guozhang Wang commented on KAFKA-8513: -- I think this is not worth discussing with a

[jira] [Commented] (KAFKA-8519) Trogdor should support network degradation

[ https://issues.apache.org/jira/browse/KAFKA-8519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16860371#comment-16860371 ] ASF GitHub Bot commented on KAFKA-8519: --- mumrah commented on pull request #6912: KA

[jira] [Updated] (KAFKA-8516) Consider allowing all replicas to have read/write permissions

[ https://issues.apache.org/jira/browse/KAFKA-8516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Richard Yu updated KAFKA-8516: -- Description: Currently, in Kafka internals, a leader is responsible for all the read and write operati

[jira] [Updated] (KAFKA-8516) Consider allowing all replicas to have read/write permissions

[ https://issues.apache.org/jira/browse/KAFKA-8516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Richard Yu updated KAFKA-8516: -- Description: Currently, in Kafka internals, a leader is responsible for all the read and write operati

[jira] [Commented] (KAFKA-8516) Consider allowing all replicas to have read/write permissions

[ https://issues.apache.org/jira/browse/KAFKA-8516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16860350#comment-16860350 ] Richard Yu commented on KAFKA-8516: --- Thanks for the heads up! Will add the link to issu

[jira] [Created] (KAFKA-8521) Client unable to get a complete transaction set of messages using a single poll call

Boris Rybalkin created KAFKA-8521: - Summary: Client unable to get a complete transaction set of messages using a single poll call Key: KAFKA-8521 URL: https://issues.apache.org/jira/browse/KAFKA-8521

[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=16860318#comment-16860318 ] Matthias J. Sax commented on KAFKA-7937: Another failure in trunk:  [https://buil

[jira] [Created] (KAFKA-8520) TimeoutException in client side doesn't have stack trace

Shixiong Zhu created KAFKA-8520: --- Summary: TimeoutException in client side doesn't have stack trace Key: KAFKA-8520 URL: https://issues.apache.org/jira/browse/KAFKA-8520 Project: Kafka Issue Ty

[jira] [Updated] (KAFKA-8487) Consumer should not resetGeneration upon REBALANCE_IN_PROGRESS in commit response handler

[ https://issues.apache.org/jira/browse/KAFKA-8487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-8487: --- Affects Version/s: 2.3 > Consumer should not resetGeneration upon REBALANCE_IN_PROGRESS in commit >

[jira] [Updated] (KAFKA-8487) Consumer should not resetGeneration upon REBALANCE_IN_PROGRESS in commit response handler

[ https://issues.apache.org/jira/browse/KAFKA-8487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-8487: --- Component/s: streams > Consumer should not resetGeneration upon REBALANCE_IN_PROGRESS in commit > re

[jira] [Updated] (KAFKA-8500) member.id should always update upon static member rejoin despite of group state

[ https://issues.apache.org/jira/browse/KAFKA-8500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-8500: --- Issue Type: Bug (was: Improvement) > member.id should always update upon static member rejoin despit

[jira] [Commented] (KAFKA-7760) Add broker configuration to set minimum value for segment.bytes and segment.ms

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

[jira] [Assigned] (KAFKA-8519) Trogdor should support network degradation

[ https://issues.apache.org/jira/browse/KAFKA-8519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Arthur reassigned KAFKA-8519: --- Assignee: David Arthur > Trogdor should support network degradation > --

[jira] [Created] (KAFKA-8519) Trogdor should support network degradation

David Arthur created KAFKA-8519: --- Summary: Trogdor should support network degradation Key: KAFKA-8519 URL: https://issues.apache.org/jira/browse/KAFKA-8519 Project: Kafka Issue Type: Improvemen

[jira] [Commented] (KAFKA-8514) Kafka clients should not include Scala's Java 8 compatibility lib

[ https://issues.apache.org/jira/browse/KAFKA-8514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16860241#comment-16860241 ] Almog Gavra commented on KAFKA-8514: [https://github.com/apache/kafka/pull/6910] - ev

[jira] [Commented] (KAFKA-8514) Kafka clients should not include Scala's Java 8 compatibility lib

[ https://issues.apache.org/jira/browse/KAFKA-8514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16860240#comment-16860240 ] ASF GitHub Bot commented on KAFKA-8514: --- agavra commented on pull request #6910: KA

[jira] [Commented] (KAFKA-8516) Consider allowing all replicas to have read/write permissions

[ https://issues.apache.org/jira/browse/KAFKA-8516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16860225#comment-16860225 ] Matthias J. Sax commented on KAFKA-8516: [~Yohan123] Are you aware of  [https://c

[jira] [Resolved] (KAFKA-7315) Streams serialization docs contain a broken link for Avro

[ https://issues.apache.org/jira/browse/KAFKA-7315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-7315. Resolution: Fixed > Streams serialization docs contain a broken link for Avro > ---

[jira] [Commented] (KAFKA-7315) Streams serialization docs contain a broken link for Avro

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

[jira] [Commented] (KAFKA-7315) Streams serialization docs contain a broken link for Avro

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

[jira] [Updated] (KAFKA-8504) Update Docs to explain how to use suppress() in more details

[ https://issues.apache.org/jira/browse/KAFKA-8504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8504: --- Summary: Update Docs to explain how to use suppress() in more details (was: Suppressed do no

[jira] [Updated] (KAFKA-8504) Suppressed do not emit with TimeWindows

[ https://issues.apache.org/jira/browse/KAFKA-8504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8504: --- Labels: newbie (was: ) > Suppressed do not emit with TimeWindows > -

[jira] [Commented] (KAFKA-8514) Kafka clients should not include Scala's Java 8 compatibility lib

[ https://issues.apache.org/jira/browse/KAFKA-8514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16860099#comment-16860099 ] Almog Gavra commented on KAFKA-8514: ack. thanks for pointing this out [~ennru]! I'll

[jira] [Assigned] (KAFKA-8514) Kafka clients should not include Scala's Java 8 compatibility lib

[ https://issues.apache.org/jira/browse/KAFKA-8514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Almog Gavra reassigned KAFKA-8514: -- Assignee: Almog Gavra > Kafka clients should not include Scala's Java 8 compatibility lib > --

[jira] [Created] (KAFKA-8518) Update GitHub repo description to make it obvious that it is not a "mirror" anymore

Etienne Neveu created KAFKA-8518: Summary: Update GitHub repo description to make it obvious that it is not a "mirror" anymore Key: KAFKA-8518 URL: https://issues.apache.org/jira/browse/KAFKA-8518 Pro

[jira] [Commented] (KAFKA-8450) Augment processed in MockProcessor as KeyValueAndTimestamp

[ https://issues.apache.org/jira/browse/KAFKA-8450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16859958#comment-16859958 ] SuryaTeja Duggi commented on KAFKA-8450: [~guozhang] [~mjsax] Can some one commen

[jira] [Commented] (KAFKA-5876) IQ should throw different exceptions for different errors

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

[jira] [Created] (KAFKA-8517) A lot of WARN messages in kafka log "Received a PartitionLeaderEpoch assignment for an epoch < latestEpoch:

Jacek Żoch created KAFKA-8517: - Summary: A lot of WARN messages in kafka log "Received a PartitionLeaderEpoch assignment for an epoch < latestEpoch: Key: KAFKA-8517 URL: https://issues.apache.org/jira/browse/KAFKA-85

[jira] [Commented] (KAFKA-8504) Suppressed do not emit with TimeWindows

[ https://issues.apache.org/jira/browse/KAFKA-8504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16859804#comment-16859804 ] Simone commented on KAFKA-8504: --- Yeah, I understand that due to backward compatibility is n