Re: [PR] MINOR: simplify ensure topic exists condition [kafka]

2024-03-02 Thread via GitHub
FrankYang0529 commented on code in PR #15458: URL: https://github.com/apache/kafka/pull/15458#discussion_r1510195954 ## tools/src/main/java/org/apache/kafka/tools/TopicCommand.java: ## @@ -210,7 +210,7 @@ private static Integer getReplicationFactor(TopicPartitionInfo tpi, Parti

Re: [PR] KAFKA-16246: Cleanups in ConsoleConsumer [kafka]

2024-03-02 Thread via GitHub
wernerdv commented on PR #15457: URL: https://github.com/apache/kafka/pull/15457#issuecomment-1975051194 Hello, @mimaison @OmniaGM Please, take a look. -- 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 t

Re: [PR] MINOR: simplify ensure topic exists condition [kafka]

2024-03-02 Thread via GitHub
chia7712 commented on code in PR #15458: URL: https://github.com/apache/kafka/pull/15458#discussion_r1510162458 ## tools/src/main/java/org/apache/kafka/tools/TopicCommand.java: ## @@ -210,7 +210,7 @@ private static Integer getReplicationFactor(TopicPartitionInfo tpi, PartitionR

Re: [PR] MINOR: simplify ensure topic exists condition [kafka]

2024-03-02 Thread via GitHub
FrankYang0529 commented on code in PR #15458: URL: https://github.com/apache/kafka/pull/15458#discussion_r1510158945 ## tools/src/main/java/org/apache/kafka/tools/TopicCommand.java: ## @@ -210,7 +210,7 @@ private static Integer getReplicationFactor(TopicPartitionInfo tpi, Parti

[PR] MINOR: fix link for ListTransactionsOptions#filterOnDuration [kafka]

2024-03-02 Thread via GitHub
FrankYang0529 opened a new pull request, #15459: URL: https://github.com/apache/kafka/pull/15459 *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 t

[jira] [Assigned] (KAFKA-12187) replace assertTrue(obj instanceof X) by assertInstanceOf when we update to JUnit 5.8

2024-03-02 Thread Kuan-Po Tseng (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kuan-Po Tseng reassigned KAFKA-12187: - Assignee: Kuan-Po Tseng (was: Chia-Ping Tsai) > replace assertTrue(obj instanceof X) b

Re: [PR] MINOR: simplify ensure topic exists condition [kafka]

2024-03-02 Thread via GitHub
chia7712 commented on code in PR #15458: URL: https://github.com/apache/kafka/pull/15458#discussion_r1510157302 ## tools/src/main/java/org/apache/kafka/tools/TopicCommand.java: ## @@ -210,7 +210,7 @@ private static Integer getReplicationFactor(TopicPartitionInfo tpi, PartitionR

[jira] [Resolved] (KAFKA-12218) Upgrade Junit to 5.8+

2024-03-02 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-12218. Resolution: Duplicate this was resolved by https://github.com/apache/kafka/pull/15404 > U

[PR] MINOR: simplify ensure topic exists condition [kafka]

2024-03-02 Thread via GitHub
FrankYang0529 opened a new pull request, #15458: URL: https://github.com/apache/kafka/pull/15458 Originally, `requestedTopic.isEmpty()` is before `!Optional.ofNullable(requestedTopic).isPresent()`. If `requestedTopic` is null, we get error from `requestedTopic.isEmpty()`. Simpl

Re: [PR] MINOR: Upgrade jqwik to version 1.8.2 [kafka]

2024-03-02 Thread via GitHub
chia7712 commented on PR #14365: URL: https://github.com/apache/kafka/pull/14365#issuecomment-1974982326 ``` [2024-03-02T21:51:02.002Z] kafka.api.PlaintextAdminIntegrationTest.testElectPreferredLeaders(String)[2] failed, log available in /home/jenkins/workspace/Kafka_kafka-pr_PR-14365/c

[jira] [Updated] (KAFKA-16246) Cleanups in ConsoleConsumer

2024-03-02 Thread Dmitry Werner (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dmitry Werner updated KAFKA-16246: -- Fix Version/s: 3.8.0 > Cleanups in ConsoleConsumer > --- > >

[PR] KAFKA-16246: Cleanups in ConsoleConsumer [kafka]

2024-03-02 Thread via GitHub
wernerdv opened a new pull request, #15457: URL: https://github.com/apache/kafka/pull/15457 Removed Optional where it makes sense and removed the argument checking logic that duplicates existing in ConsoleConsumerOptions#checkRequiredArgs(). ### Committer Checklist (excluded from comm

Re: [PR] MINOR: Upgrade jqwik to version 1.8.2 [kafka]

2024-03-02 Thread via GitHub
bmscomp commented on PR #14365: URL: https://github.com/apache/kafka/pull/14365#issuecomment-1974904749 @chia7712 Jqwik version is updated to 1.8.3 and conflicts are resolved -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHu

[jira] [Assigned] (KAFKA-16246) Cleanups in ConsoleConsumer

2024-03-02 Thread Dmitry Werner (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dmitry Werner reassigned KAFKA-16246: - Assignee: Dmitry Werner > Cleanups in ConsoleConsumer > --- > >

Re: [PR] MINOR: Upgrade jqwik to version 1.8.2 [kafka]

2024-03-02 Thread via GitHub
chia7712 commented on PR #14365: URL: https://github.com/apache/kafka/pull/14365#issuecomment-1974864320 the last version of `jqwik` is 1.8.3. Maybe we should rebase the code with 1.8.3, and then merge it if there is no related failure. -- This is an automated message from the Apache Git

Re: [PR] KAFKA-15154: proper StampedLock synchronization added [kafka]

2024-03-02 Thread via GitHub
mstepan closed pull request #14837: KAFKA-15154: proper StampedLock synchronization added URL: https://github.com/apache/kafka/pull/14837 -- 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

[jira] [Commented] (KAFKA-16298) Ensure user callbacks exceptions are propagated to the user on consumer poll

2024-03-02 Thread Chia Chuan Yu (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17822804#comment-17822804 ] Chia Chuan Yu commented on KAFKA-16298: --- Hi, [~lianetm]  I'm a new contributor an

Re: [PR] KAFKA-16209 : fetchSnapshot might return null if topic is created before v2.8 [kafka]

2024-03-02 Thread via GitHub
chiacyu commented on PR #15444: URL: https://github.com/apache/kafka/pull/15444#issuecomment-1974768078 Hi, @showuon Just add a unit test for the condition of the empty snapshot. Thanks! -- This is an automated message from the Apache Git Service. To respond to the message, please