[jira] [Updated] (KAFKA-12953) Bump Zookeeper version to 3.6.3

2021-06-16 Thread Ismael Juma (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-12953: Priority: Major (was: Minor) > Bump Zookeeper version to 3.6.3 > ---

[jira] [Comment Edited] (KAFKA-12718) SessionWindows are closed too early

2021-06-16 Thread Juan C. Gonzalez-Zurita (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17364613#comment-17364613 ] Juan C. Gonzalez-Zurita edited comment on KAFKA-12718 at 6/17/21, 2:37 AM:

[jira] [Assigned] (KAFKA-12883) Adress KIP-100 type constraints now that Java 7 support is dropped

2021-06-16 Thread Nicolas Guignard (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicolas Guignard reassigned KAFKA-12883: Assignee: Nicolas Guignard > Adress KIP-100 type constraints now that Java 7

[jira] [Comment Edited] (KAFKA-12718) SessionWindows are closed too early

2021-06-16 Thread Juan C. Gonzalez-Zurita (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17364613#comment-17364613 ] Juan C. Gonzalez-Zurita edited comment on KAFKA-12718 at 6/17/21, 12:43 AM:

[jira] [Commented] (KAFKA-12718) SessionWindows are closed too early

2021-06-16 Thread Juan C. Gonzalez-Zurita (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17364613#comment-17364613 ] Juan C. Gonzalez-Zurita commented on KAFKA-12718: - Attempting to fix the conflict at the

[jira] [Created] (KAFKA-12958) Add similation invariant for leadership and snapshot

2021-06-16 Thread Jose Armando Garcia Sancio (Jira)
Jose Armando Garcia Sancio created KAFKA-12958: -- Summary: Add similation invariant for leadership and snapshot Key: KAFKA-12958 URL: https://issues.apache.org/jira/browse/KAFKA-12958

[jira] [Resolved] (KAFKA-12955) Fix LogLoader to pass materialized view of segments for deletion

2021-06-16 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-12955. - Fix Version/s: 3.0.0 Assignee: Kowshik Prakasam Resolution: Fixed Merged the PR to

[jira] [Assigned] (KAFKA-12770) Gradle build: allow the CheckStyle version to be specified via parameter

2021-06-16 Thread Jira
[ https://issues.apache.org/jira/browse/KAFKA-12770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dejan Stojadinović reassigned KAFKA-12770: -- Assignee: Ismael Juma (was: Dejan Stojadinović) > Gradle build: allow the

[jira] [Commented] (KAFKA-12401) Flaky Test FeatureCommandTest#testUpgradeAllFeaturesSuccess

2021-06-16 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12401?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17364507#comment-17364507 ] Matthias J. Sax commented on KAFKA-12401: -

[jira] [Commented] (KAFKA-3861) Shrunk ISR before leader crash makes the partition unavailable

2021-06-16 Thread Jack Foy (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-3861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17364495#comment-17364495 ] Jack Foy commented on KAFKA-3861: - https://issues.apache.org/jira/browse/KAFKA-12241 is a duplicate of

[jira] [Commented] (KAFKA-12241) Partition offline when ISR shrinks to leader and LogDir goes offline

2021-06-16 Thread Jack Foy (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12241?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17364493#comment-17364493 ] Jack Foy commented on KAFKA-12241: -- In my opinion this is a cleaner fix than the one proposed in

[jira] [Commented] (KAFKA-8295) Optimize count() using RocksDB merge operator

2021-06-16 Thread Sagar Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17364422#comment-17364422 ] Sagar Rao commented on KAFKA-8295: -- Yeah that makes sense. I haven't looked at the count() APIs so can't

[jira] [Created] (KAFKA-12957) Refactor Streams Logical Plan Generation

2021-06-16 Thread Guozhang Wang (Jira)
Guozhang Wang created KAFKA-12957: - Summary: Refactor Streams Logical Plan Generation Key: KAFKA-12957 URL: https://issues.apache.org/jira/browse/KAFKA-12957 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-12629) Failing Test: RaftClusterTest

2021-06-16 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17364362#comment-17364362 ] Matthias J. Sax commented on KAFKA-12629: - Failed two more times -

[jira] [Commented] (KAFKA-12678) Flaky Test CustomQuotaCallbackTest.testCustomQuotaCallback

2021-06-16 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17364360#comment-17364360 ] Matthias J. Sax commented on KAFKA-12678: - Failed again:

[jira] [Commented] (KAFKA-12954) Add Support for Scala 3 in 4.0.0

2021-06-16 Thread Josep Prat (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17364310#comment-17364310 ] Josep Prat commented on KAFKA-12954: Absolutely, according to the Scala Center most of the code that

[jira] [Created] (KAFKA-12956) Validate the snapshot id when the state machine freeze a snapshot

2021-06-16 Thread Haoran Xuan (Jira)
Haoran Xuan created KAFKA-12956: --- Summary: Validate the snapshot id when the state machine freeze a snapshot Key: KAFKA-12956 URL: https://issues.apache.org/jira/browse/KAFKA-12956 Project: Kafka

[jira] [Commented] (KAFKA-12954) Add Support for Scala 3 in 4.0.0

2021-06-16 Thread Ismael Juma (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17364303#comment-17364303 ] Ismael Juma commented on KAFKA-12954: - Thanks for the ticket. One thing to evaluate is the cost of

[jira] [Assigned] (KAFKA-12883) Adress KIP-100 type constraints now that Java 7 support is dropped

2021-06-16 Thread Nicolas Guignard (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicolas Guignard reassigned KAFKA-12883: Assignee: (was: Nicolas Guignard) > Adress KIP-100 type constraints now that

[jira] [Assigned] (KAFKA-12883) Adress KIP-100 type constraints now that Java 7 support is dropped

2021-06-16 Thread Nicolas Guignard (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicolas Guignard reassigned KAFKA-12883: Assignee: Nicolas Guignard > Adress KIP-100 type constraints now that Java 7

[GitHub] [kafka] tang7526 commented on a change in pull request #10588: KAFKA-12662: add unit test for ProducerPerformance

2021-06-16 Thread GitBox
tang7526 commented on a change in pull request #10588: URL: https://github.com/apache/kafka/pull/10588#discussion_r652487133 ## File path: tools/src/main/java/org/apache/kafka/tools/ProducerPerformance.java ## @@ -190,8 +159,66 @@ public static void main(String[] args) throws

[GitHub] [kafka] tang7526 commented on a change in pull request #10588: KAFKA-12662: add unit test for ProducerPerformance

2021-06-16 Thread GitBox
tang7526 commented on a change in pull request #10588: URL: https://github.com/apache/kafka/pull/10588#discussion_r652487057 ## File path: tools/src/test/java/org/apache/kafka/tools/ProducerPerformanceTest.java ## @@ -0,0 +1,152 @@ +/* + * Licensed to the Apache Software

[GitHub] [kafka] lkokhreidze commented on pull request #10851: KAFKA-6718 / Rack aware standby task assignor

2021-06-16 Thread GitBox
lkokhreidze commented on pull request #10851: URL: https://github.com/apache/kafka/pull/10851#issuecomment-862166415 gentle nudge @cadonna @vvcephei @ableegoldman -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[GitHub] [kafka] kowshik commented on pull request #10888: KAFKA-12955: Fix LogLoader to pass materialized view of segments for deletion

2021-06-16 Thread GitBox
kowshik commented on pull request #10888: URL: https://github.com/apache/kafka/pull/10888#issuecomment-862144734 cc @junrao @dhruvilshah3 @ccding for review -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[jira] [Updated] (KAFKA-12955) Fix LogLoader to pass materialized view of segments for deletion

2021-06-16 Thread Kowshik Prakasam (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kowshik Prakasam updated KAFKA-12955: - Summary: Fix LogLoader to pass materialized view of segments for deletion (was: Fix

[GitHub] [kafka] kowshik opened a new pull request #10888: KAFKA-12955: Fix LogLoader to pass materialized view of segments for deletion

2021-06-16 Thread GitBox
kowshik opened a new pull request #10888: URL: https://github.com/apache/kafka/pull/10888 Within `LogLoader.removeAndDeleteSegmentsAsync()`, we should force materialization of the `segmentsToDelete` iterable, to make sure the results of the iteration remain valid and deterministic. We

[jira] [Updated] (KAFKA-12955) Fix LogLoader to pass materialized list of segments for deletion

2021-06-16 Thread Kowshik Prakasam (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kowshik Prakasam updated KAFKA-12955: - Description: Within {{LogLoader.removeAndDeleteSegmentsAsync()}}, we should force

[jira] [Created] (KAFKA-12955) Fix LogLoader to pass materialized list of segments for deletion

2021-06-16 Thread Kowshik Prakasam (Jira)
Kowshik Prakasam created KAFKA-12955: Summary: Fix LogLoader to pass materialized list of segments for deletion Key: KAFKA-12955 URL: https://issues.apache.org/jira/browse/KAFKA-12955 Project:

[jira] [Assigned] (KAFKA-12954) Add Support for Scala 3 in 4.0.0

2021-06-16 Thread Josep Prat (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Josep Prat reassigned KAFKA-12954: -- Assignee: Josep Prat > Add Support for Scala 3 in 4.0.0 > >

[jira] [Created] (KAFKA-12954) Add Support for Scala 3 in 4.0.0

2021-06-16 Thread Josep Prat (Jira)
Josep Prat created KAFKA-12954: -- Summary: Add Support for Scala 3 in 4.0.0 Key: KAFKA-12954 URL: https://issues.apache.org/jira/browse/KAFKA-12954 Project: Kafka Issue Type: Improvement

[jira] [Updated] (KAFKA-12951) Infinite loop while restoring a GlobalKTable

2021-06-16 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-12951: Description: We encountered an issue a few time in some of our Kafka Streams application.

[jira] [Updated] (KAFKA-12951) Infinite loop while restoring a GlobalKTable

2021-06-16 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-12951: Description: We encountered an issue a few time in some of our Kafka Streams application.

[jira] [Updated] (KAFKA-12951) Infinite loop while restoring a GlobalKTable

2021-06-16 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-12951: Affects Version/s: 2.8.0 2.7.1 > Infinite loop while restoring a

[GitHub] [kafka] dongjinleekr commented on a change in pull request #10826: KAFKA-7632: Support Compression Level

2021-06-16 Thread GitBox
dongjinleekr commented on a change in pull request #10826: URL: https://github.com/apache/kafka/pull/10826#discussion_r652405099 ## File path: clients/src/main/java/org/apache/kafka/common/record/CompressionConfig.java ## @@ -0,0 +1,70 @@ +/* + * Licensed to the Apache

[GitHub] [kafka] dongjinleekr commented on pull request #10827: [WIP] KAFKA-12899: Support --bootstrap-server in ReplicaVerificationTool

2021-06-16 Thread GitBox
dongjinleekr commented on pull request #10827: URL: https://github.com/apache/kafka/pull/10827#issuecomment-862070027 @tombentley Could you kindly have a look when you are free? :bowing_man: -- This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [kafka] dongjinleekr commented on a change in pull request #10827: [WIP] KAFKA-12899: Support --bootstrap-server in ReplicaVerificationTool

2021-06-16 Thread GitBox
dongjinleekr commented on a change in pull request #10827: URL: https://github.com/apache/kafka/pull/10827#discussion_r652375109 ## File path: core/src/main/scala/kafka/tools/ReplicaVerificationTool.scala ## @@ -116,7 +121,13 @@ object ReplicaVerificationTool extends Logging {

[GitHub] [kafka] dongjinleekr commented on pull request #10827: [WIP] KAFKA-12899: Support --bootstrap-server in ReplicaVerificationTool

2021-06-16 Thread GitBox
dongjinleekr commented on pull request #10827: URL: https://github.com/apache/kafka/pull/10827#issuecomment-862069060 Here it is. With rebasing onto the lastest trunk, I added unit tests that verify the command line parsing. Also, for this KIP is not passed yet (+2 bindings), I

[GitHub] [kafka] dongjinleekr commented on a change in pull request #10827: KAFKA-12899: Support --bootstrap-server in ReplicaVerificationTool

2021-06-16 Thread GitBox
dongjinleekr commented on a change in pull request #10827: URL: https://github.com/apache/kafka/pull/10827#discussion_r652374413 ## File path: core/src/main/scala/kafka/tools/ReplicaVerificationTool.scala ## @@ -116,7 +121,13 @@ object ReplicaVerificationTool extends Logging {