[jira] [Commented] (KAFKA-15491) RackId doesn't exist error while running WordCountDemo

2023-09-23 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17768343#comment-17768343 ] Luke Chen commented on KAFKA-15491: --- [~lihaosky][~mjsax], FYI > RackId doesn't exist

[jira] [Updated] (KAFKA-15491) RackId doesn't exist error while running WordCountDemo

2023-09-23 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen updated KAFKA-15491: -- Summary: RackId doesn't exist error while running WordCountDemo (was: RackId doesn't exist while runn

[jira] [Created] (KAFKA-15491) RackId doesn't exist while running WordCountDemo

2023-09-23 Thread Luke Chen (Jira)
Luke Chen created KAFKA-15491: - Summary: RackId doesn't exist while running WordCountDemo Key: KAFKA-15491 URL: https://issues.apache.org/jira/browse/KAFKA-15491 Project: Kafka Issue Type: Bug

[GitHub] [kafka] ijuma commented on pull request #14430: MINOR: Update to Scala 2.13.12

2023-09-23 Thread via GitHub
ijuma commented on PR #14430: URL: https://github.com/apache/kafka/pull/14430#issuecomment-1732465145 JDK 17 and Scala 2.13 build passed on retry. -- 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

[GitHub] [kafka] ijuma commented on pull request #14430: MINOR: Update to Scala 2.13.12

2023-09-23 Thread via GitHub
ijuma commented on PR #14430: URL: https://github.com/apache/kafka/pull/14430#issuecomment-1732423957 Unrelated flakes again: > Build / JDK 8 and Scala 2.12 / kafka.api.DelegationTokenEndToEndAuthorizationWithOwnerTest.testCreateTokenForOtherUserFails(String).quorum=kraft Build / J

[GitHub] [kafka] ijuma commented on pull request #14427: KAFKA-15485: Fix "this-escape" compiler warnings introduced by JDK 21 (1/N)

2023-09-23 Thread via GitHub
ijuma commented on PR #14427: URL: https://github.com/apache/kafka/pull/14427#issuecomment-1732423752 JDK 8 build passed, the rest had unrelated flaky failures: > Build / JDK 11 and Scala 2.13 / kafka.api.TransactionsTest.testBumpTransactionalEpoch(String).quorum=kraft > Build / JD

[GitHub] [kafka] ijuma opened a new pull request, #14431: MINOR: Upgrade gradle, plugins and test libraries

2023-09-23 Thread via GitHub
ijuma opened a new pull request, #14431: URL: https://github.com/apache/kafka/pull/14431 ### Committer Checklist (excluded from commit message) - [ ] Verify design and implementation - [ ] Verify test coverage and CI build status - [ ] Verify documentation (including upgrade

[GitHub] [kafka] ijuma commented on a diff in pull request #14427: KAFKA-15485: Fix "this-escape" compiler warnings introduced by JDK 21 (1/N)

2023-09-23 Thread via GitHub
ijuma commented on code in PR #14427: URL: https://github.com/apache/kafka/pull/14427#discussion_r1335061842 ## connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerConnector.java: ## @@ -381,15 +381,15 @@ private void doTransitionTo(TargetState targetState) thr

[GitHub] [kafka] ijuma commented on a diff in pull request #14427: KAFKA-15485: Fix "this-escape" compiler warnings introduced by JDK 21 (1/N)

2023-09-23 Thread via GitHub
ijuma commented on code in PR #14427: URL: https://github.com/apache/kafka/pull/14427#discussion_r1335061735 ## storage/src/main/java/org/apache/kafka/storage/internals/log/TimeIndex.java: ## @@ -60,6 +60,7 @@ public TimeIndex(File file, long baseOffset, int maxIndexSize) throw

[GitHub] [kafka] ijuma commented on a diff in pull request #14427: KAFKA-15485: Fix "this-escape" compiler warnings introduced by JDK 21 (1/N)

2023-09-23 Thread via GitHub
ijuma commented on code in PR #14427: URL: https://github.com/apache/kafka/pull/14427#discussion_r1335061735 ## storage/src/main/java/org/apache/kafka/storage/internals/log/TimeIndex.java: ## @@ -60,6 +60,7 @@ public TimeIndex(File file, long baseOffset, int maxIndexSize) throw

[GitHub] [kafka] ijuma commented on a diff in pull request #14427: KAFKA-15485: Fix "this-escape" compiler warnings introduced by JDK 21 (1/N)

2023-09-23 Thread via GitHub
ijuma commented on code in PR #14427: URL: https://github.com/apache/kafka/pull/14427#discussion_r1335059135 ## storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/serialization/RemoteLogMetadataSerde.java: ## @@ -50,6 +50,7 @@ public class RemoteLogMetadat

[GitHub] [kafka] ijuma commented on pull request #14427: KAFKA-15485: Fix "this-escape" compiler warnings introduced by JDK 21 (1/N)

2023-09-23 Thread via GitHub
ijuma commented on PR #14427: URL: https://github.com/apache/kafka/pull/14427#issuecomment-1732392148 JDK 20 build passed, the others failed due to flaky tests. -- 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] ijuma commented on pull request #14430: MINOR: Update to Scala 2.13.12

2023-09-23 Thread via GitHub
ijuma commented on PR #14430: URL: https://github.com/apache/kafka/pull/14430#issuecomment-1732391581 The build failures don't seem related. I restarted the build to get more signal. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to G

[GitHub] [kafka] hgeraldino commented on pull request #14093: KAFKA-15248 Add BooleanConverter

2023-09-23 Thread via GitHub
hgeraldino commented on PR #14093: URL: https://github.com/apache/kafka/pull/14093#issuecomment-1732369824 > @hgeraldino the Connect integration tests are failing with errors like: Thanks @yashmayya, adding entries for the new converter to the metadata fixed the build issues 👍 --

[GitHub] [kafka] ijuma opened a new pull request, #14430: MINOR: Update to Scala 2.13.12

2023-09-23 Thread via GitHub
ijuma opened a new pull request, #14430: URL: https://github.com/apache/kafka/pull/14430 It offers a quickfix action for certain errors, includes a number of bug fixes and it introduces a new warning by default (https://github.com/scala/scala/pull/10462). In addition to the scala

[jira] [Commented] (KAFKA-15463) StreamsException: Accessing from an unknown node

2023-09-23 Thread Yevgeny (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17768288#comment-17768288 ] Yevgeny commented on KAFKA-15463: - [~ableegoldman]  will try to do this (once near stati

[jira] [Updated] (KAFKA-14127) KIP-858: Handle JBOD broker disk failure in KRaft

2023-09-23 Thread Igor Soarez (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Igor Soarez updated KAFKA-14127: Fix Version/s: 3.7.0 > KIP-858: Handle JBOD broker disk failure in KRaft > ---

[GitHub] [kafka] dajac opened a new pull request, #14429: ignore

2023-09-23 Thread via GitHub
dajac opened a new pull request, #14429: URL: https://github.com/apache/kafka/pull/14429 *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

[jira] [Updated] (KAFKA-15489) split brain in KRaft cluster

2023-09-23 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen updated KAFKA-15489: -- Description: I found in the current KRaft implementation, when network partition happened between the

[GitHub] [kafka] satishd commented on pull request #14428: KAFKA-15489: resign leadership when no fetch from majority voters

2023-09-23 Thread via GitHub
satishd commented on PR #14428: URL: https://github.com/apache/kafka/pull/14428#issuecomment-1732284491 cc @mumrah -- 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 specific comment. To unsub

[GitHub] [kafka] satishd commented on a diff in pull request #14427: KAFKA-15485: Fix "this-escape" compiler warnings introduced by JDK 21 (1/N)

2023-09-23 Thread via GitHub
satishd commented on code in PR #14427: URL: https://github.com/apache/kafka/pull/14427#discussion_r1334967466 ## storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/serialization/RemoteLogMetadataSerde.java: ## @@ -50,6 +50,7 @@ public class RemoteLogMetad

[jira] [Updated] (KAFKA-15490) Invalid path provided to the log failure channel upon I/O error when writing broker metadata checkpoint

2023-09-23 Thread Alexandre Dupriez (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexandre Dupriez updated KAFKA-15490: -- Description: There is a small bug/typo in the handling of I/O error when writing broke

[jira] [Updated] (KAFKA-15490) Invalid path provided to the log failure channel upon I/O error when writing broker metadata checkpoint

2023-09-23 Thread Alexandre Dupriez (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexandre Dupriez updated KAFKA-15490: -- Description: There is a small bug/typo in the handling of I/O error when writing broke

[jira] [Assigned] (KAFKA-15490) Invalid path provided to the log failure channel upon I/O error when writing broker metadata checkpoint

2023-09-23 Thread Alexandre Dupriez (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexandre Dupriez reassigned KAFKA-15490: - Assignee: Alexandre Dupriez > Invalid path provided to the log failure channel

[jira] [Updated] (KAFKA-15490) Invalid path provided to the log failure channel upon I/O error when writing broker metadata checkpoint

2023-09-23 Thread Alexandre Dupriez (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexandre Dupriez updated KAFKA-15490: -- Affects Version/s: 3.5.1 > Invalid path provided to the log failure channel upon I/O e

[jira] [Updated] (KAFKA-15490) Invalid path provided to the log failure channel upon I/O error when writing broker metadata checkpoint

2023-09-23 Thread Alexandre Dupriez (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexandre Dupriez updated KAFKA-15490: -- Description: There is a small bug/typo in the handling of I/O error when writing broke

[jira] [Updated] (KAFKA-15490) Invalid path provided to the log failure channel upon I/O error when writing broker metadata checkpoint

2023-09-23 Thread Alexandre Dupriez (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexandre Dupriez updated KAFKA-15490: -- Description: There is a small bug/typo in the handling of I/O error when writing broke

[jira] [Created] (KAFKA-15490) Invalid path provided to the log failure channel upon I/O error when writing broker metadata checkpoint

2023-09-23 Thread Alexandre Dupriez (Jira)
Alexandre Dupriez created KAFKA-15490: - Summary: Invalid path provided to the log failure channel upon I/O error when writing broker metadata checkpoint Key: KAFKA-15490 URL: https://issues.apache.org/jira/bro

[jira] [Commented] (KAFKA-6020) Broker side filtering

2023-09-23 Thread Vincent Bernardi (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-6020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17768258#comment-17768258 ] Vincent Bernardi commented on KAFKA-6020: - My company is currently wasting a non-

[GitHub] [kafka] showuon commented on pull request #14428: KAFKA-15489: resign leadership when no fetch from majority voters

2023-09-23 Thread via GitHub
showuon commented on PR #14428: URL: https://github.com/apache/kafka/pull/14428#issuecomment-1732271440 @hachikuji @cmccabe @jsancio , call for review. Thanks. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL ab

[GitHub] [kafka] showuon opened a new pull request, #14428: KAFKA-15489: resign leadership when no fetch from majority voters

2023-09-23 Thread via GitHub
showuon opened a new pull request, #14428: URL: https://github.com/apache/kafka/pull/14428 In [KIP-595](https://cwiki.apache.org/confluence/display/KAFKA/KIP-595%3A+A+Raft+Protocol+for+the+Metadata+Quorum#KIP595:ARaftProtocolfortheMetadataQuorum-LeaderProgressTimeout), we expect to piggy-ba

[jira] [Created] (KAFKA-15489) split brain in KRaft cluster

2023-09-23 Thread Luke Chen (Jira)
Luke Chen created KAFKA-15489: - Summary: split brain in KRaft cluster Key: KAFKA-15489 URL: https://issues.apache.org/jira/browse/KAFKA-15489 Project: Kafka Issue Type: Bug Components:

[jira] [Commented] (KAFKA-6020) Broker side filtering

2023-09-23 Thread Fiachra Corcoran (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-6020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17768241#comment-17768241 ] Fiachra Corcoran commented on KAFKA-6020: - Looking to revive this topic to gauge