[jira] [Commented] (KAFKA-17397) Ensure ClassicKafkaConsumer sends leave request on close even if interrupted

2024-10-11 Thread Peter Lee (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1724#comment-1724 ] Peter Lee commented on KAFKA-17397: --- [~goyarpit] Is there any progress on this issue,

[jira] [Commented] (KAFKA-17780) Heartbeat interval is not configured in the heartbeatrequest manager

2024-10-11 Thread Arpit Goyal (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1723#comment-1723 ] Arpit Goyal commented on KAFKA-17780: - As per my understanding, It is being set afte

[jira] [Updated] (KAFKA-17780) Heartbeat interval is not configured in the heartbeatrequest manager

2024-10-11 Thread Arpit Goyal (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arpit Goyal updated KAFKA-17780: Component/s: kip > Heartbeat interval is not configured in the heartbeatrequest manager >

[jira] [Created] (KAFKA-17780) Heartbeat interval is not configured in the heartbeatrequest manager

2024-10-11 Thread Arpit Goyal (Jira)
Arpit Goyal created KAFKA-17780: --- Summary: Heartbeat interval is not configured in the heartbeatrequest manager Key: KAFKA-17780 URL: https://issues.apache.org/jira/browse/KAFKA-17780 Project: Kafka

[jira] [Commented] (KAFKA-17464) Flaky test: org.apache.kafka.clients.consumer.internals.AbstractCoordinatorTest.testWakeupAfterSyncGroupSentExternalCompletion

2024-10-11 Thread Peter Lee (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1722#comment-1722 ] Peter Lee commented on KAFKA-17464: --- I ran the tests for 100 times with {code:java} I=

[jira] [Updated] (KAFKA-17464) Flaky test: org.apache.kafka.clients.consumer.internals.AbstractCoordinatorTest.testWakeupAfterSyncGroupSentExternalCompletion

2024-10-11 Thread Peter Lee (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Peter Lee updated KAFKA-17464: -- Attachment: test_result > Flaky test: > org.apache.kafka.clients.consumer.internals.AbstractCoordinat

[jira] [Commented] (KAFKA-17462) Removes intermediateTopicsOption from StreamsResetter

2024-10-11 Thread Peter Lee (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17462?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1719#comment-1719 ] Peter Lee commented on KAFKA-17462: --- Hi [~ardada2468], May I take this ticket? > Remo

[PR] KAFKA-17768: Update protobuf and commons-io dependencies in 3.7.2 [kafka]

2024-10-11 Thread via GitHub
frankvicky opened a new pull request, #17477: URL: https://github.com/apache/kafka/pull/17477 JIRA: KAFKA-17768(https://issues.apache.org/jira/browse/KAFKA-17768) Update protobuf and Apache commons-io because earlier versions are vulnerable. protobuf: [CVE-2024-7254](https://github.com

Re: [PR] Use pre-calculated value in trace message [kafka]

2024-10-11 Thread via GitHub
github-actions[bot] commented on PR #1883: URL: https://github.com/apache/kafka/pull/1883#issuecomment-2408333938 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel free to r

Re: [PR] Use pre-calculated value in trace message [kafka]

2024-10-11 Thread via GitHub
github-actions[bot] closed pull request #1883: Use pre-calculated value in trace message URL: https://github.com/apache/kafka/pull/1883 -- 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 c

Re: [PR] [KAFKA-4185] Abstract out password verifier in SaslServer as an injec… [kafka]

2024-10-11 Thread via GitHub
github-actions[bot] closed pull request #1870: [KAFKA-4185] Abstract out password verifier in SaslServer as an injec… URL: https://github.com/apache/kafka/pull/1870 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

Re: [PR] KAFKA-4126: Log a server-side warning when a record is sent to a missing topic with auto create disabled [kafka]

2024-10-11 Thread via GitHub
github-actions[bot] closed pull request #1863: KAFKA-4126: Log a server-side warning when a record is sent to a missing topic with auto create disabled URL: https://github.com/apache/kafka/pull/1863 -- This is an automated message from the Apache Git Service. To respond to the message, please

Re: [PR] KAFKA-1194: New config to specify memory mapped file update capability for underlying OS [kafka]

2024-10-11 Thread via GitHub
github-actions[bot] closed pull request #1624: KAFKA-1194: New config to specify memory mapped file update capability for underlying OS URL: https://github.com/apache/kafka/pull/1624 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHu

Re: [PR] MINOR: Set additivity false for kafkaAppender (log4j.properties) [kafka]

2024-10-11 Thread via GitHub
github-actions[bot] closed pull request #1608: MINOR: Set additivity false for kafkaAppender (log4j.properties) URL: https://github.com/apache/kafka/pull/1608 -- 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

Re: [PR] KAFKA-1194: New config to specify memory mapped file update capability for underlying OS [kafka]

2024-10-11 Thread via GitHub
github-actions[bot] commented on PR #1624: URL: https://github.com/apache/kafka/pull/1624#issuecomment-2408333850 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel free to r

Re: [PR] MINOR: Set additivity false for kafkaAppender (log4j.properties) [kafka]

2024-10-11 Thread via GitHub
github-actions[bot] commented on PR #1608: URL: https://github.com/apache/kafka/pull/1608#issuecomment-2408333833 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel free to r

Re: [PR] KAFKA-3947: Add dumping current assignment capability to kafka-reassign-partitions.sh [kafka]

2024-10-11 Thread via GitHub
github-actions[bot] closed pull request #1606: KAFKA-3947: Add dumping current assignment capability to kafka-reassign-partitions.sh URL: https://github.com/apache/kafka/pull/1606 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub a

Re: [PR] KAFKA-1543: Change replication factor during partition map generation [kafka]

2024-10-11 Thread via GitHub
github-actions[bot] closed pull request #1596: KAFKA-1543: Change replication factor during partition map generation URL: https://github.com/apache/kafka/pull/1596 -- 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

Re: [PR] KAFKA-3910 [WIP]: Cyclic schema support in ConnectSchema and SchemaBuilder [kafka]

2024-10-11 Thread via GitHub
github-actions[bot] closed pull request #1582: KAFKA-3910 [WIP]: Cyclic schema support in ConnectSchema and SchemaBuilder URL: https://github.com/apache/kafka/pull/1582 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

Re: [PR] KAFKA-1543: Change replication factor during partition map generation [kafka]

2024-10-11 Thread via GitHub
github-actions[bot] commented on PR #1596: URL: https://github.com/apache/kafka/pull/1596#issuecomment-2408333814 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel free to r

Re: [PR] KAFKA-3910 [WIP]: Cyclic schema support in ConnectSchema and SchemaBuilder [kafka]

2024-10-11 Thread via GitHub
github-actions[bot] commented on PR #1582: URL: https://github.com/apache/kafka/pull/1582#issuecomment-2408333796 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel free to r

Re: [PR] KAFKA-3866; KerberosLogin refresh time bug and other improvements [kafka]

2024-10-11 Thread via GitHub
github-actions[bot] commented on PR #1522: URL: https://github.com/apache/kafka/pull/1522#issuecomment-2408333787 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel free to r

Re: [PR] KAFKA-3866; KerberosLogin refresh time bug and other improvements [kafka]

2024-10-11 Thread via GitHub
github-actions[bot] closed pull request #1522: KAFKA-3866; KerberosLogin refresh time bug and other improvements URL: https://github.com/apache/kafka/pull/1522 -- 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

Re: [PR] KAFKA-3837: Report the thread name of the blocking thread when throwing ConcurrentModificationException [kafka]

2024-10-11 Thread via GitHub
github-actions[bot] commented on PR #1516: URL: https://github.com/apache/kafka/pull/1516#issuecomment-2408333780 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel free to r

Re: [PR] KAFKA-3792: Fix log spam in clients for unknown topics [kafka]

2024-10-11 Thread via GitHub
github-actions[bot] commented on PR #1473: URL: https://github.com/apache/kafka/pull/1473#issuecomment-2408333770 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel free to r

Re: [PR] KAFKA-3554 Improve ProducerPerformance test [kafka]

2024-10-11 Thread via GitHub
github-actions[bot] closed pull request #1399: KAFKA-3554 Improve ProducerPerformance test URL: https://github.com/apache/kafka/pull/1399 -- 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

Re: [PR] KAFKA-3494: add metric id to client mbeans [kafka]

2024-10-11 Thread via GitHub
github-actions[bot] commented on PR #1323: URL: https://github.com/apache/kafka/pull/1323#issuecomment-2408333735 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel free to r

Re: [PR] WIP - KAFKA-1880: Add support for checking binary/source compatibility [kafka]

2024-10-11 Thread via GitHub
github-actions[bot] closed pull request #1291: WIP - KAFKA-1880: Add support for checking binary/source compatibility URL: https://github.com/apache/kafka/pull/1291 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

Re: [PR] WIP - KAFKA-1880: Add support for checking binary/source compatibility [kafka]

2024-10-11 Thread via GitHub
github-actions[bot] commented on PR #1291: URL: https://github.com/apache/kafka/pull/1291#issuecomment-2408333726 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel free to r

Re: [PR] KAFKA-1614: Partition log directory name and segments information exposed via JMX [kafka]

2024-10-11 Thread via GitHub
github-actions[bot] commented on PR #1196: URL: https://github.com/apache/kafka/pull/1196#issuecomment-2408333716 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel free to r

Re: [PR] KAFKA-2607: Review `Time` interface and its usage [kafka]

2024-10-11 Thread via GitHub
github-actions[bot] closed pull request #837: KAFKA-2607: Review `Time` interface and its usage URL: https://github.com/apache/kafka/pull/837 -- 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 spec

Re: [PR] KAFKA-2607: Review `Time` interface and its usage [kafka]

2024-10-11 Thread via GitHub
github-actions[bot] commented on PR #837: URL: https://github.com/apache/kafka/pull/837#issuecomment-2408333706 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel free to re-

Re: [PR] [KAFKA-4185] Abstract out password verifier in SaslServer as an injec… [kafka]

2024-10-11 Thread via GitHub
github-actions[bot] commented on PR #1870: URL: https://github.com/apache/kafka/pull/1870#issuecomment-2408333925 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel free to r

Re: [PR] KAFKA-4126: Log a server-side warning when a record is sent to a missing topic with auto create disabled [kafka]

2024-10-11 Thread via GitHub
github-actions[bot] commented on PR #1863: URL: https://github.com/apache/kafka/pull/1863#issuecomment-2408333914 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel free to r

Re: [PR] KAFKA-2170: Fixes for Windows [kafka]

2024-10-11 Thread via GitHub
github-actions[bot] closed pull request #1757: KAFKA-2170: Fixes for Windows URL: https://github.com/apache/kafka/pull/1757 -- 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 u

Re: [PR] KAFKA-2170: Fixes for Windows [kafka]

2024-10-11 Thread via GitHub
github-actions[bot] commented on PR #1757: URL: https://github.com/apache/kafka/pull/1757#issuecomment-2408333895 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel free to r

Re: [PR] MINOR: Add more verbose logging for offset map building [kafka]

2024-10-11 Thread via GitHub
github-actions[bot] closed pull request #1741: MINOR: Add more verbose logging for offset map building URL: https://github.com/apache/kafka/pull/1741 -- 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

Re: [PR] MINOR: Add more verbose logging for offset map building [kafka]

2024-10-11 Thread via GitHub
github-actions[bot] commented on PR #1741: URL: https://github.com/apache/kafka/pull/1741#issuecomment-2408333877 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel free to r

Re: [PR] [KAFKA-3968] Call fsync for parent directory first time when we flush… [kafka]

2024-10-11 Thread via GitHub
github-actions[bot] closed pull request #1626: [KAFKA-3968] Call fsync for parent directory first time when we flush… URL: https://github.com/apache/kafka/pull/1626 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

Re: [PR] [KAFKA-3968] Call fsync for parent directory first time when we flush… [kafka]

2024-10-11 Thread via GitHub
github-actions[bot] commented on PR #1626: URL: https://github.com/apache/kafka/pull/1626#issuecomment-2408333863 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel free to r

Re: [PR] KAFKA-3947: Add dumping current assignment capability to kafka-reassign-partitions.sh [kafka]

2024-10-11 Thread via GitHub
github-actions[bot] commented on PR #1606: URL: https://github.com/apache/kafka/pull/1606#issuecomment-2408333823 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel free to r

Re: [PR] KAFKA-3837: Report the thread name of the blocking thread when throwing ConcurrentModificationException [kafka]

2024-10-11 Thread via GitHub
github-actions[bot] closed pull request #1516: KAFKA-3837: Report the thread name of the blocking thread when throwing ConcurrentModificationException URL: https://github.com/apache/kafka/pull/1516 -- This is an automated message from the Apache Git Service. To respond to the message, please

Re: [PR] KAFKA-3792: Fix log spam in clients for unknown topics [kafka]

2024-10-11 Thread via GitHub
github-actions[bot] closed pull request #1473: KAFKA-3792: Fix log spam in clients for unknown topics URL: https://github.com/apache/kafka/pull/1473 -- 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 t

Re: [PR] KAFKA-3554 Improve ProducerPerformance test [kafka]

2024-10-11 Thread via GitHub
github-actions[bot] commented on PR #1399: URL: https://github.com/apache/kafka/pull/1399#issuecomment-2408333756 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel free to r

Re: [PR] KAFKA-1489: Global threshold on data retention size [kafka]

2024-10-11 Thread via GitHub
github-actions[bot] closed pull request #1348: KAFKA-1489: Global threshold on data retention size URL: https://github.com/apache/kafka/pull/1348 -- 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

Re: [PR] KAFKA-1489: Global threshold on data retention size [kafka]

2024-10-11 Thread via GitHub
github-actions[bot] commented on PR #1348: URL: https://github.com/apache/kafka/pull/1348#issuecomment-2408333746 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel free to r

Re: [PR] KAFKA-3494: add metric id to client mbeans [kafka]

2024-10-11 Thread via GitHub
github-actions[bot] closed pull request #1323: KAFKA-3494: add metric id to client mbeans URL: https://github.com/apache/kafka/pull/1323 -- 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

Re: [PR] KAFKA-1614: Partition log directory name and segments information exposed via JMX [kafka]

2024-10-11 Thread via GitHub
github-actions[bot] closed pull request #1196: KAFKA-1614: Partition log directory name and segments information exposed via JMX URL: https://github.com/apache/kafka/pull/1196 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and u

[jira] [Comment Edited] (KAFKA-17779) Fix flaky RemoteLogManagerTest#testFetchOffsetByTimestampWithTieredStorageDoesNotFetchIndexWhenExistsLocally

2024-10-11 Thread Mingdao Yang (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1713#comment-1713 ] Mingdao Yang edited comment on KAFKA-17779 at 10/12/24 3:26 AM: --

[jira] [Commented] (KAFKA-17779) Fix flaky RemoteLogManagerTest#testFetchOffsetByTimestampWithTieredStorageDoesNotFetchIndexWhenExistsLocally

2024-10-11 Thread Mingdao Yang (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1713#comment-1713 ] Mingdao Yang commented on KAFKA-17779: -- Hi, I noticed this open issue. Mind if I ha

Re: [PR] MINOR: clean up GHA names [kafka]

2024-10-11 Thread via GitHub
chia7712 commented on PR #17470: URL: https://github.com/apache/kafka/pull/17470#issuecomment-2408328375 see https://github.com/apache/kafka/pull/17476/checks and the name LGTM -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub a

[PR] MINOR: Fix transactionPartitionVerificationEnable return type [kafka]

2024-10-11 Thread via GitHub
clarkwtc opened a new pull request, #17476: URL: https://github.com/apache/kafka/pull/17476 *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 testin

[jira] [Commented] (KAFKA-17768) Update protobuf and commons-io dependencies in 3.7.2

2024-10-11 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1709#comment-1709 ] Chia-Ping Tsai commented on KAFKA-17768: [~frankvicky] 3.8 branch has the fix, s

[jira] [Assigned] (KAFKA-17768) Update protobuf and commons-io dependencies in 3.7.2

2024-10-11 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai reassigned KAFKA-17768: -- Assignee: TengYao Chi > Update protobuf and commons-io dependencies in 3.7.2 > --

[jira] [Commented] (KAFKA-17768) Update protobuf and commons-io dependencies in 3.7.2

2024-10-11 Thread TengYao Chi (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1708#comment-1708 ] TengYao Chi commented on KAFKA-17768: - Hi [~cmccabe]  I would like to handle this is

[jira] [Updated] (KAFKA-17753) Update protobuf and commons-io dependencies

2024-10-11 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai updated KAFKA-17753: --- Fix Version/s: 3.8.1 > Update protobuf and commons-io dependencies > ---

Re: [PR] KAFKA-17753: Update protobuf and commons-io dependencies [kafka]

2024-10-11 Thread via GitHub
chia7712 merged PR #17453: URL: https://github.com/apache/kafka/pull/17453 -- 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 unsubscribe, e-mail: jira-unsubscr...@kafka.apache

Re: [PR] MINOR: clean up GHA names [kafka]

2024-10-11 Thread via GitHub
chia7712 merged PR #17470: URL: https://github.com/apache/kafka/pull/17470 -- 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 unsubscribe, e-mail: jira-unsubscr...@kafka.apache

Re: [PR] KAFKA-17746 Replace JavaConverters with CollectionConverters [kafka]

2024-10-11 Thread via GitHub
Linsiyuan9 commented on code in PR #17451: URL: https://github.com/apache/kafka/pull/17451#discussion_r1797530783 ## core/src/test/java/kafka/test/api/ShareConsumerTest.java: ## @@ -1635,7 +1636,7 @@ private KafkaShareConsumer createShareConsumer(Deserializer keyD private

[jira] [Updated] (KAFKA-17713) Ensure snapshots are aligned to batch boundaries

2024-10-11 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai updated KAFKA-17713: --- Fix Version/s: 4.0.0 > Ensure snapshots are aligned to batch boundaries > --

[jira] [Resolved] (KAFKA-17199) add unit tests for TransactionLogConfig and TransactionStateManagerConfig

2024-10-11 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-17199. Fix Version/s: 4.0.0 Resolution: Fixed > add unit tests for TransactionLogConfig an

Re: [PR] KAFKA-17199: Add UT for TransactionLogConfig and TransactionStateManagerConfig [kafka]

2024-10-11 Thread via GitHub
chia7712 merged PR #17442: URL: https://github.com/apache/kafka/pull/17442 -- 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 unsubscribe, e-mail: jira-unsubscr...@kafka.apache

Re: [PR] KAFKA-17741: cleanup code base for JDK 11 [kafka]

2024-10-11 Thread via GitHub
chia7712 commented on code in PR #17441: URL: https://github.com/apache/kafka/pull/17441#discussion_r1797523298 ## clients/src/main/java/org/apache/kafka/common/utils/ByteBufferUnmapper.java: ## @@ -87,10 +87,7 @@ public static void unmap(String resourceDescription, ByteBuffer

Re: [PR] KAFKA-17746 Replace JavaConverters with CollectionConverters [kafka]

2024-10-11 Thread via GitHub
chia7712 commented on code in PR #17451: URL: https://github.com/apache/kafka/pull/17451#discussion_r1797521277 ## core/src/test/java/kafka/test/api/ShareConsumerTest.java: ## @@ -1635,7 +1636,7 @@ private KafkaShareConsumer createShareConsumer(Deserializer keyD private v

Re: [PR] KAFKA-17407: Fix flaky ShareGroupHeartbeatRequestTest.testPartitionAssignmentWithChangingTopics [kafka]

2024-10-11 Thread via GitHub
m1a2st commented on PR #16994: URL: https://github.com/apache/kafka/pull/16994#issuecomment-2408279705 @chia7712, @AndrewJSchofield Thanks for your review, it seens pass the ci, and flaky anymore. -- This is an automated message from the Apache Git Service. To respond to the message, plea

Re: [PR] Adjust maximum value of group.share.record.lock.duration.ms [kafka]

2024-10-11 Thread via GitHub
chia7712 merged PR #17472: URL: https://github.com/apache/kafka/pull/17472 -- 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 unsubscribe, e-mail: jira-unsubscr...@kafka.apache

[PR] KAFKA-17099: Print the origin processor node in logs for processing exceptions [kafka]

2024-10-11 Thread via GitHub
loicgreffier opened a new pull request, #17475: URL: https://github.com/apache/kafka/pull/17475 This PR leverages the updates brought by [KIP-1033](https://cwiki.apache.org/confluence/display/KAFKA/KIP-1033%3A+Add+Kafka+Streams+exception+handler+for+exceptions+occurring+during+processing) t

Re: [PR] MINOR: fix some GHA `run` syntax [kafka]

2024-10-11 Thread via GitHub
chia7712 merged PR #17471: URL: https://github.com/apache/kafka/pull/17471 -- 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 unsubscribe, e-mail: jira-unsubscr...@kafka.apache

[jira] [Created] (KAFKA-17779) Fix flaky RemoteLogManagerTest#testFetchOffsetByTimestampWithTieredStorageDoesNotFetchIndexWhenExistsLocally

2024-10-11 Thread Chia-Ping Tsai (Jira)
Chia-Ping Tsai created KAFKA-17779: -- Summary: Fix flaky RemoteLogManagerTest#testFetchOffsetByTimestampWithTieredStorageDoesNotFetchIndexWhenExistsLocally Key: KAFKA-17779 URL: https://issues.apache.org/jira/brow

[jira] [Resolved] (KAFKA-17775) Remove Java#IS_JAVA9_COMPATIBLE property

2024-10-11 Thread Jira
[ https://issues.apache.org/jira/browse/KAFKA-17775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 黃竣陽 resolved KAFKA-17775. - Resolution: Duplicate > Remove Java#IS_JAVA9_COMPATIBLE property > > >

Re: [PR] KAFKA-17778: Add listener to remove client instances on connection disconnect [kafka]

2024-10-11 Thread via GitHub
apoorvmittal10 commented on PR #17474: URL: https://github.com/apache/kafka/pull/17474#issuecomment-2408242643 Build will pass once this PR is rebased over dependent PR: https://github.com/apache/kafka/pull/17473 -- This is an automated message from the Apache Git Service. To respond to t

[PR] KAFKA-17778: Add listener to remove client instances on connection disconnect [kafka]

2024-10-11 Thread via GitHub
apoorvmittal10 opened a new pull request, #17474: URL: https://github.com/apache/kafka/pull/17474 The PR uses the capability added in PR: https://github.com/apache/kafka/pull/17473, which allows to attach listener for client instances cleanup on client disconnection. The ClientsMetri

[jira] [Created] (KAFKA-17778) Clean up client instance cache on connection close

2024-10-11 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-17778: - Summary: Clean up client instance cache on connection close Key: KAFKA-17778 URL: https://issues.apache.org/jira/browse/KAFKA-17778 Project: Kafka Issue Ty

[PR] KAFKA-17776: Capability for connection disconnect listeners in socket server [kafka]

2024-10-11 Thread via GitHub
apoorvmittal10 opened a new pull request, #17473: URL: https://github.com/apache/kafka/pull/17473 As of now, there isn't any way that resources can be cleaned in Kafka when client disconnects the connections. Generally time bound clean up happens which keep the resources occupied. Th

[jira] [Commented] (KAFKA-17777) Flaky KafkaConsumerTest testReturnRecordsDuringRebalance

2024-10-11 Thread Lianet Magrans (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-1?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17888792#comment-17888792 ] Lianet Magrans commented on KAFKA-1: Sure, let me know if I can help with re

[jira] [Assigned] (KAFKA-17777) Flaky KafkaConsumerTest testReturnRecordsDuringRebalance

2024-10-11 Thread Lianet Magrans (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-1?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lianet Magrans reassigned KAFKA-1: -- Assignee: TengYao Chi > Flaky KafkaConsumerTest testReturnRecordsDuringRebalance > --

[jira] [Commented] (KAFKA-17777) Flaky KafkaConsumerTest testReturnRecordsDuringRebalance

2024-10-11 Thread TengYao Chi (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-1?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17888788#comment-17888788 ] TengYao Chi commented on KAFKA-1: - Hi [~lianetm]  I would like to investigate t

[jira] [Comment Edited] (KAFKA-15485) Support building with Java 21 (LTS release)

2024-10-11 Thread Sergio Troiano (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17888516#comment-17888516 ] Sergio Troiano edited comment on KAFKA-15485 at 10/11/24 10:05 PM: ---

[jira] [Updated] (KAFKA-17777) Flaky KafkaConsumerTest testReturnRecordsDuringRebalance

2024-10-11 Thread Lianet Magrans (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-1?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lianet Magrans updated KAFKA-1: --- Component/s: consumer > Flaky KafkaConsumerTest testReturnRecordsDuringRebalance > -

[jira] [Created] (KAFKA-17777) Flaky KafkaConsumerTest testReturnRecordsDuringRebalance

2024-10-11 Thread Lianet Magrans (Jira)
Lianet Magrans created KAFKA-1: -- Summary: Flaky KafkaConsumerTest testReturnRecordsDuringRebalance Key: KAFKA-1 URL: https://issues.apache.org/jira/browse/KAFKA-1 Project: Kafka

[jira] [Updated] (KAFKA-17776) Add connection disconnect listener in socket server

2024-10-11 Thread Apoorv Mittal (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal updated KAFKA-17776: -- Component/s: core > Add connection disconnect listener in socket server >

[jira] [Updated] (KAFKA-17776) Add connection disconnect listener in socket server

2024-10-11 Thread Apoorv Mittal (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal updated KAFKA-17776: -- Fix Version/s: 4.0.0 > Add connection disconnect listener in socket server > -

[jira] [Updated] (KAFKA-17776) Add connection disconnect listener in socket server

2024-10-11 Thread Apoorv Mittal (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal updated KAFKA-17776: -- Affects Version/s: 4.0.0 > Add connection disconnect listener in socket server > -

Re: [PR] KAFKA-17536: Ensure clear error message when new consumer used with incompatible cluster [kafka]

2024-10-11 Thread via GitHub
lianetm commented on PR #17411: URL: https://github.com/apache/kafka/pull/17411#issuecomment-2407977107 Hey folks, aligned with @dajac 's comment on the approach, I think we should keep the solution scoped to the client and the HB RPC specifically (which is what will fail in this scenario w

Re: [PR] KAFKA-10551: Add topic id support to produce request and response [kafka]

2024-10-11 Thread via GitHub
junrao commented on code in PR #15968: URL: https://github.com/apache/kafka/pull/15968#discussion_r1785440699 ## core/src/test/scala/integration/kafka/api/ProducerSendWhileDeletionTest.scala: ## @@ -84,4 +84,94 @@ class ProducerSendWhileDeletionTest extends IntegrationTestHarne

[jira] [Created] (KAFKA-17776) Add connection disconnect listener in socket server

2024-10-11 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-17776: - Summary: Add connection disconnect listener in socket server Key: KAFKA-17776 URL: https://issues.apache.org/jira/browse/KAFKA-17776 Project: Kafka Issue T

[jira] [Updated] (KAFKA-17775) Remove Java#IS_JAVA9_COMPATIBLE property

2024-10-11 Thread Jira
[ https://issues.apache.org/jira/browse/KAFKA-17775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 黃竣陽 updated KAFKA-17775: Parent: KAFKA-17757 Issue Type: Sub-task (was: Improvement) > Remove Java#IS_JAVA9_COMPATIBLE property >

[jira] [Created] (KAFKA-17775) Remove Java#IS_JAVA9_COMPATIBLE property

2024-10-11 Thread Jira
黃竣陽 created KAFKA-17775: --- Summary: Remove Java#IS_JAVA9_COMPATIBLE property Key: KAFKA-17775 URL: https://issues.apache.org/jira/browse/KAFKA-17775 Project: Kafka Issue Type: Improvement Re

Re: [PR] Enable pending reassignments cancellation/rollback [kafka]

2024-10-11 Thread via GitHub
georgeli-roblox commented on PR #6296: URL: https://github.com/apache/kafka/pull/6296#issuecomment-2407866659 > Any progress ? @sql888 oh, the new reassignment (since version`2.8.2`) supports Adding/Removing replicas in the topic metadata, so it's easy to rollback. -- This is

[PR] Adjust maximum value of group.share.record.lock.duration.ms [kafka]

2024-10-11 Thread via GitHub
AndrewJSchofield opened a new pull request, #17472: URL: https://github.com/apache/kafka/pull/17472 As discussed in https://github.com/apache/kafka/pull/17331#discussion_r1795008371, people were confused that the broker config `group.sh.record.lock.duration.ms` had a maximum value less tha

Re: [PR] KAFKA-17767 Extract test catalog from JUnit output [1/n] [kafka]

2024-10-11 Thread via GitHub
mumrah commented on PR #17397: URL: https://github.com/apache/kafka/pull/17397#issuecomment-2407829283 With latest changes, the files in the test catalog: ``` ./clients ./clients/tests.yaml ./tools ./tools/tests.yaml ./tools/tools-api ./tools/tools-api/tests.yaml .

Re: [PR] KAFKA-17532-2: Moved ShareGroupConfig and added share.record.lock.duration.ms to dynamic configs [kafka]

2024-10-11 Thread via GitHub
AndrewJSchofield commented on code in PR #17331: URL: https://github.com/apache/kafka/pull/17331#discussion_r1797213556 ## group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupConfig.java: ## @@ -57,13 +62,20 @@ public class GroupConfig extends AbstractConfig

Re: [PR] KAFKA-17600: Add nextOffsets to the ConsumerRecords [kafka]

2024-10-11 Thread via GitHub
AndrewJSchofield commented on code in PR #17414: URL: https://github.com/apache/kafka/pull/17414#discussion_r1797182983 ## clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerRecords.java: ## @@ -32,12 +32,19 @@ * partition returned by a {@link Consumer#poll(java.t

Re: [PR] KAFKA-17715 remove force_use_zk_connection from e2e [kafka]

2024-10-11 Thread via GitHub
mimaison commented on code in PR #17465: URL: https://github.com/apache/kafka/pull/17465#discussion_r1797199822 ## tests/kafkatest/services/kafka/kafka.py: ## @@ -1010,84 +1010,68 @@ def kafka_metadata_quorum_cmd(self, node, kafka_security_protocol=None, use_cont kafka

[PR] MINOR: fix some run syntax [kafka]

2024-10-11 Thread via GitHub
mumrah opened a new pull request, #17471: URL: https://github.com/apache/kafka/pull/17471 This fixes some of our `run` steps in our workflows to follow best practices. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use th

[PR] MINOR: clean up job names [kafka]

2024-10-11 Thread via GitHub
mumrah opened a new pull request, #17470: URL: https://github.com/apache/kafka/pull/17470 *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

Re: [PR] KAFKA-17741: cleanup code base for JDK 11 [kafka]

2024-10-11 Thread via GitHub
frankvicky commented on PR #17441: URL: https://github.com/apache/kafka/pull/17441#issuecomment-2407687562 Hi @chia7712 I have fixed the conflicts, PTAL -- 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

Re: [PR] KAFKA-17724: Move SubscriptionState changes to background thread [kafka]

2024-10-11 Thread via GitHub
AndrewJSchofield commented on code in PR #17418: URL: https://github.com/apache/kafka/pull/17418#discussion_r1797137085 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/ShareSubscriptionChangeEvent.java: ## @@ -17,14 +17,31 @@ package org.apache.kaf

Re: [PR] KAFKA-17767 Extract test catalog from JUnit output [1/n] [kafka]

2024-10-11 Thread via GitHub
chia7712 commented on code in PR #17397: URL: https://github.com/apache/kafka/pull/17397#discussion_r1797031847 ## build.gradle: ## @@ -503,7 +518,8 @@ subprojects { // were not run, but instead were restored via FROM-CACHE. See KAFKA-17479 for more details. doLast {

Re: [PR] KAFKA-17724: Move SubscriptionState changes to background thread [kafka]

2024-10-11 Thread via GitHub
lianetm commented on code in PR #17418: URL: https://github.com/apache/kafka/pull/17418#discussion_r1797021034 ## clients/src/test/java/org/apache/kafka/clients/consumer/internals/ShareConsumerImplTest.java: ## @@ -306,32 +344,49 @@ public void testCompleteQuietly() { @Te

  1   2   >