[GitHub] [kafka] ijuma commented on pull request #11295: KAFKA-13270: Set JUTE_MAXBUFFER to 4 MB by default

2021-09-05 Thread GitBox
ijuma commented on pull request #11295: URL: https://github.com/apache/kafka/pull/11295#issuecomment-913389764 @omkreddy if you have cycles, this is a 3.0 blocker. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the U

[GitHub] [kafka] ijuma commented on pull request #11296: KAFKA-13273: Add support for Java 17

2021-09-05 Thread GitBox
ijuma commented on pull request #11296: URL: https://github.com/apache/kafka/pull/11296#issuecomment-913379778 And we have a green build. :) -- 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 s

[GitHub] [kafka] satishd commented on pull request #11058: KAFKA-12802 Added a file based cache for consumed remote log metadata for each partition to avoid consuming again incase of broker restarts.

2021-09-05 Thread GitBox
satishd commented on pull request #11058: URL: https://github.com/apache/kafka/pull/11058#issuecomment-913321617 @junrao gentle reminder to review the changes. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL a

[GitHub] [kafka] satishd commented on pull request #11033: KAFKA-12988 Asynchronous API support for RemoteLogMetadataManager add/update methods.

2021-09-05 Thread GitBox
satishd commented on pull request #11033: URL: https://github.com/apache/kafka/pull/11033#issuecomment-913321448 Thanks @junrao for your comment. Addressed the review comment with the latest commit. -- This is an automated message from the Apache Git Service. To respond to the message, p

[GitHub] [kafka] satishd commented on a change in pull request #11033: KAFKA-12988 Asynchronous API support for RemoteLogMetadataManager add/update methods.

2021-09-05 Thread GitBox
satishd commented on a change in pull request #11033: URL: https://github.com/apache/kafka/pull/11033#discussion_r702548933 ## File path: storage/api/src/main/java/org/apache/kafka/server/log/remote/storage/RemoteLogMetadataManager.java ## @@ -62,16 +63,17 @@ * @param re

[GitHub] [kafka] jasonyanwenl commented on pull request #11297: KAFKA-10038: Supports default client.id for ConsoleConsumer, ProducerPerformance, ConsumerPerformance

2021-09-05 Thread GitBox
jasonyanwenl commented on pull request #11297: URL: https://github.com/apache/kafka/pull/11297#issuecomment-913314815 Hi @guozhangwang, I saw you are assigned as the reviewer of the ticket [KAFKA-10038](https://issues.apache.org/jira/browse/KAFKA-10038), please help take a look at this PR

[jira] [Commented] (KAFKA-5666) Need feedback to user if consumption fails due to offsets.topic.replication.factor=3

2021-09-05 Thread Yanwen Lin (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-5666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17410351#comment-17410351 ] Yanwen Lin commented on KAFKA-5666: --- Hi [~yevabyzek], [~apurva], is this still an issue

[GitHub] [kafka] ijuma commented on a change in pull request #11296: KAFKA-13273: Add support for Java 17

2021-09-05 Thread GitBox
ijuma commented on a change in pull request #11296: URL: https://github.com/apache/kafka/pull/11296#discussion_r702529338 ## File path: raft/src/test/java/org/apache/kafka/raft/KafkaRaftClientTest.java ## @@ -2799,4 +2779,11 @@ public void testObserverFetchWithNoLocalId() throw

[jira] [Commented] (KAFKA-9366) Upgrade log4j to log4j2

2021-09-05 Thread Dongjin Lee (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17410283#comment-17410283 ] Dongjin Lee commented on KAFKA-9366: ALL // Sorry for being late. This KIP was origin

[GitHub] [kafka] lbradstreet opened a new pull request #11298: MINOR: "partition" typos and method doc arg fix

2021-09-05 Thread GitBox
lbradstreet opened a new pull request #11298: URL: https://github.com/apache/kafka/pull/11298 Some minor typos that have annoyed me along with a fix to a docstring. -- 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] lbradstreet commented on a change in pull request #10914: [KAFKA-8522] Streamline tombstone and transaction marker removal

2021-09-05 Thread GitBox
lbradstreet commented on a change in pull request #10914: URL: https://github.com/apache/kafka/pull/10914#discussion_r702508503 ## File path: core/src/main/scala/kafka/log/LogCleanerManager.scala ## @@ -198,8 +199,23 @@ private[log] class LogCleanerManager(val logDirs: Seq[Fil

[GitHub] [kafka] lbradstreet commented on a change in pull request #10914: [KAFKA-8522] Streamline tombstone and transaction marker removal

2021-09-05 Thread GitBox
lbradstreet commented on a change in pull request #10914: URL: https://github.com/apache/kafka/pull/10914#discussion_r702503828 ## File path: core/src/main/scala/kafka/log/LogCleanerManager.scala ## @@ -198,13 +204,28 @@ private[log] class LogCleanerManager(val logDirs: Seq[Fi

[GitHub] [kafka] lbradstreet commented on a change in pull request #10914: [KAFKA-8522] Streamline tombstone and transaction marker removal

2021-09-05 Thread GitBox
lbradstreet commented on a change in pull request #10914: URL: https://github.com/apache/kafka/pull/10914#discussion_r702503726 ## File path: core/src/main/scala/kafka/log/LogCleanerManager.scala ## @@ -163,17 +168,18 @@ private[log] class LogCleanerManager(val logDirs: Seq[Fi

[jira] [Commented] (KAFKA-13261) KTable to KTable foreign key join loose events when using several partitions

2021-09-05 Thread Tomas Forsman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17410256#comment-17410256 ] Tomas Forsman commented on KAFKA-13261: --- I've added a test that seem to verify a p

[GitHub] [kafka] gunnarmorling commented on a change in pull request #11296: KAFKA-13273: Add support for Java 17

2021-09-05 Thread GitBox
gunnarmorling commented on a change in pull request #11296: URL: https://github.com/apache/kafka/pull/11296#discussion_r702474291 ## File path: raft/src/test/java/org/apache/kafka/raft/KafkaRaftClientTest.java ## @@ -2799,4 +2779,11 @@ public void testObserverFetchWithNoLocalId

[GitHub] [kafka] ijuma commented on pull request #11296: KAFKA-13273: Add support for Java 17

2021-09-05 Thread GitBox
ijuma commented on pull request #11296: URL: https://github.com/apache/kafka/pull/11296#issuecomment-913214595 @chia7712 @omkreddy Any of you have the cycles to review this? Thanks! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to Gi

[GitHub] [kafka] ijuma edited a comment on pull request #11296: KAFKA-13273: Add support for Java 17

2021-09-05 Thread GitBox
ijuma edited a comment on pull request #11296: URL: https://github.com/apache/kafka/pull/11296#issuecomment-913214267 Build 6 (including Java 16) passed: https://ci-builds.apache.org/job/Kafka/job/kafka-pr/job/PR-11296/6/ I will now remove Java 16 from Jenkinsfile. -- This is an a

[GitHub] [kafka] ijuma commented on pull request #11296: KAFKA-13273: Add support for Java 17

2021-09-05 Thread GitBox
ijuma commented on pull request #11296: URL: https://github.com/apache/kafka/pull/11296#issuecomment-913214267 Build #6 passed: https://ci-builds.apache.org/job/Kafka/job/kafka-pr/job/PR-11296/6/ -- This is an automated message from the Apache Git Service. To respond to the message, plea

[jira] [Updated] (KAFKA-13275) Remove --add-opens from build.gradle (where possible)

2021-09-05 Thread Ismael Juma (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-13275: Description: We added several `--add-opens` to make a number of tests pass with Java 17 (via KAFK

[jira] [Updated] (KAFKA-13275) Remove --add-opens from build.gradle (where possible)

2021-09-05 Thread Ismael Juma (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-13275: Description: We added several `--add-opens` to make a number of tests pass with Java 17 (via KAFK

[jira] [Created] (KAFKA-13275) Remove --add-opens from build.gradle (where possible)

2021-09-05 Thread Ismael Juma (Jira)
Ismael Juma created KAFKA-13275: --- Summary: Remove --add-opens from build.gradle (where possible) Key: KAFKA-13275 URL: https://issues.apache.org/jira/browse/KAFKA-13275 Project: Kafka Issue Typ

[jira] [Issue Comment Deleted] (KAFKA-13273) Add support for Java 17

2021-09-05 Thread Ismael Juma (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-13273: Comment: was deleted (was: PR: https://github.com/apache/kafka/pull/11296) > Add support for Java

[jira] [Created] (KAFKA-13274) Ensure system tests run successfully with Java 17

2021-09-05 Thread Ismael Juma (Jira)
Ismael Juma created KAFKA-13274: --- Summary: Ensure system tests run successfully with Java 17 Key: KAFKA-13274 URL: https://issues.apache.org/jira/browse/KAFKA-13274 Project: Kafka Issue Type: I

[GitHub] [kafka] ijuma commented on a change in pull request #11296: KAFKA-13273: Add support for Java 17

2021-09-05 Thread GitBox
ijuma commented on a change in pull request #11296: URL: https://github.com/apache/kafka/pull/11296#discussion_r702460031 ## File path: build.gradle ## @@ -37,7 +37,7 @@ plugins { id 'org.owasp.dependencycheck' version '6.1.6' id 'org.nosphere.apache.rat' version "0.7.0"

[GitHub] [kafka] ijuma commented on a change in pull request #11296: KAFKA-13273: Add support for Java 17

2021-09-05 Thread GitBox
ijuma commented on a change in pull request #11296: URL: https://github.com/apache/kafka/pull/11296#discussion_r702450561 ## File path: build.gradle ## @@ -37,7 +37,7 @@ plugins { id 'org.owasp.dependencycheck' version '6.1.6' id 'org.nosphere.apache.rat' version "0.7.0"

[GitHub] [kafka] ijuma commented on a change in pull request #11296: KAFKA-13273: Add support for Java 17

2021-09-05 Thread GitBox
ijuma commented on a change in pull request #11296: URL: https://github.com/apache/kafka/pull/11296#discussion_r702450437 ## File path: gradle/wrapper/gradle-wrapper.properties ## @@ -1,6 +1,5 @@ distributionBase=GRADLE_USER_HOME distributionPath=wrapper/dists -distributionSh

[jira] [Updated] (KAFKA-13273) Add support for Java 17

2021-09-05 Thread Ismael Juma (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-13273: Description: Java 17 is at release candidate stage and it will be a LTS release once it's out (pre

[jira] [Created] (KAFKA-13273) Add support for Java 17

2021-09-05 Thread Ismael Juma (Jira)
Ismael Juma created KAFKA-13273: --- Summary: Add support for Java 17 Key: KAFKA-13273 URL: https://issues.apache.org/jira/browse/KAFKA-13273 Project: Kafka Issue Type: Improvement Rep

[jira] [Commented] (KAFKA-13273) Add support for Java 17

2021-09-05 Thread Ismael Juma (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17410206#comment-17410206 ] Ismael Juma commented on KAFKA-13273: - PR: https://github.com/apache/kafka/pull/1129

[GitHub] [kafka] satishd commented on a change in pull request #11058: KAFKA-12802 Added a file based cache for consumed remote log metadata for each partition to avoid consuming again incase of broke

2021-09-05 Thread GitBox
satishd commented on a change in pull request #11058: URL: https://github.com/apache/kafka/pull/11058#discussion_r702422832 ## File path: storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/CommittedOffsetsFile.java ## @@ -0,0 +1,86 @@ +/* + * Licensed to

[jira] [Assigned] (KAFKA-9886) Validate segment range before reading in `Log.read`

2021-09-05 Thread HaiyuanZhao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] HaiyuanZhao reassigned KAFKA-9886: -- Assignee: HaiyuanZhao > Validate segment range before reading in `Log.read` >