adixitconfluent commented on code in PR #19261:
URL: https://github.com/apache/kafka/pull/19261#discussion_r2026286010
##
core/src/main/java/kafka/server/share/SharePartition.java:
##
@@ -2484,6 +2505,174 @@ private long startOffsetDuringInitialization(long
partitionDataStartOf
adixitconfluent commented on code in PR #19261:
URL: https://github.com/apache/kafka/pull/19261#discussion_r2026281487
##
core/src/main/java/kafka/server/share/SharePartition.java:
##
@@ -2484,6 +2505,174 @@ private long startOffsetDuringInitialization(long
partitionDataStartOf
Lucas Brutschy created KAFKA-19077:
--
Summary: Propagate shutdownRequested field
Key: KAFKA-19077
URL: https://issues.apache.org/jira/browse/KAFKA-19077
Project: Kafka
Issue Type: Sub-task
mjsax commented on code in PR #19303:
URL: https://github.com/apache/kafka/pull/19303#discussion_r2026203506
##
streams/src/test/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionSendProcessorSupplierTest.java:
##
@@ -316,6 +367,21 @@ public void innerJo
[
https://issues.apache.org/jira/browse/KAFKA-18949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai resolved KAFKA-18949.
Fix Version/s: 4.1.0
Resolution: Fixed
> fix testDeleteRecordsAfterCorruptRecords f
chia7712 merged PR #19317:
URL: https://github.com/apache/kafka/pull/19317
--
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
chia7712 commented on code in PR #19167:
URL: https://github.com/apache/kafka/pull/19167#discussion_r2026206939
##
clients/src/main/java/org/apache/kafka/common/requests/FetchResponse.java:
##
@@ -87,7 +87,7 @@ public FetchResponseData data() {
* We may also return INCONSI
mjsax closed pull request #18887: KAFKA-18713: Fix left join bug by using
DELETE_KEY_NO_PROPAGATE
URL: https://github.com/apache/kafka/pull/18887
--
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
github-actions[bot] closed pull request #17830: KAFKA-18001: Support
UpdateRaftVoterRequest in KafkaNetworkChannel (#…
URL: https://github.com/apache/kafka/pull/17830
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
UR
github-actions[bot] commented on PR #16218:
URL: https://github.com/apache/kafka/pull/16218#issuecomment-2774400154
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
[
https://issues.apache.org/jira/browse/KAFKA-19067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17940405#comment-17940405
]
PoAn Yang commented on KAFKA-19067:
---
[~chia7712] Thanks for the comment. Like we discu
[
https://issues.apache.org/jira/browse/KAFKA-19080?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17940542#comment-17940542
]
Chia-Ping Tsai commented on KAFKA-19080:
hi [~m1a2st]
[~junrao] didn't assign
github-actions[bot] closed pull request #16218: MINOR: Using rocksdb's
prefixScan in fk joins for better performances
URL: https://github.com/apache/kafka/pull/16218
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
github-actions[bot] commented on PR #17981:
URL: https://github.com/apache/kafka/pull/17981#issuecomment-2774400276
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
github-actions[bot] commented on PR #19231:
URL: https://github.com/apache/kafka/pull/19231#issuecomment-2774353320
A label of 'needs-attention' was automatically added to this PR in order to
raise the
attention of the committers. Once this issue has been triaged, the `triage`
label
s
github-actions[bot] commented on PR #19253:
URL: https://github.com/apache/kafka/pull/19253#issuecomment-2774353205
A label of 'needs-attention' was automatically added to this PR in order to
raise the
attention of the committers. Once this issue has been triaged, the `triage`
label
s
github-actions[bot] commented on PR #18811:
URL: https://github.com/apache/kafka/pull/18811#issuecomment-2774353771
A label of 'needs-attention' was automatically added to this PR in order to
raise the
attention of the committers. Once this issue has been triaged, the `triage`
label
s
github-actions[bot] commented on PR #19236:
URL: https://github.com/apache/kafka/pull/19236#issuecomment-2774353250
A label of 'needs-attention' was automatically added to this PR in order to
raise the
attention of the committers. Once this issue has been triaged, the `triage`
label
s
Tombert commented on PR #19234:
URL: https://github.com/apache/kafka/pull/19234#issuecomment-2774109863
> Thanks for the update. Think you got a few to many now. Let me clarify
further.
>
> For `kstream` package, I think it's correct (except the few too many I
mentioned on the other
junrao commented on PR #18140:
URL: https://github.com/apache/kafka/pull/18140#issuecomment-2773915601
Filed https://issues.apache.org/jira/browse/KAFKA-19080 to track this.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
k-raina opened a new pull request, #19354:
URL: https://github.com/apache/kafka/pull/19354
**Summary**
Extend ApplicationRecoverableException related exceptions
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
UR
ableegoldman commented on code in PR #19269:
URL: https://github.com/apache/kafka/pull/19269#discussion_r2025862994
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsProducer.java:
##
@@ -70,6 +70,7 @@ public class StreamsProducer {
private Produc
Tombert commented on code in PR #19234:
URL: https://github.com/apache/kafka/pull/19234#discussion_r2025863852
##
streams/src/main/java/org/apache/kafka/streams/processor/assignment/TaskAssignor.java:
##
@@ -31,6 +31,7 @@
* The implementation may also override the {@code onAss
FrankYang0529 commented on code in PR #19345:
URL: https://github.com/apache/kafka/pull/19345#discussion_r2025863364
##
core/src/test/scala/integration/kafka/admin/RemoteTopicCrudTest.scala:
##
@@ -441,7 +441,29 @@ class RemoteTopicCrudTest extends IntegrationTestHarness {
frankvicky commented on code in PR #19167:
URL: https://github.com/apache/kafka/pull/19167#discussion_r2025822378
##
clients/src/main/java/org/apache/kafka/common/requests/FetchResponse.java:
##
@@ -87,7 +87,7 @@ public FetchResponseData data() {
* We may also return INCON
frankvicky commented on code in PR #19167:
URL: https://github.com/apache/kafka/pull/19167#discussion_r2025822378
##
clients/src/main/java/org/apache/kafka/common/requests/FetchResponse.java:
##
@@ -87,7 +87,7 @@ public FetchResponseData data() {
* We may also return INCON
junrao commented on code in PR #19261:
URL: https://github.com/apache/kafka/pull/19261#discussion_r2025608562
##
core/src/main/java/kafka/server/share/SharePartition.java:
##
@@ -2484,6 +2505,174 @@ private long startOffsetDuringInitialization(long
partitionDataStartOffset) thr
apalan60 commented on PR #19342:
URL: https://github.com/apache/kafka/pull/19342#issuecomment-2773245175
> @apalan60 please fill the PR description, thanks!
@chia7712
Thanks for your review.
I have updated the PR description, and I'll make sure to include all the
necessary
Jun Rao created KAFKA-19080:
---
Summary: The constraint on segment.ms is not enforced at topic
level
Key: KAFKA-19080
URL: https://issues.apache.org/jira/browse/KAFKA-19080
Project: Kafka
Issue Type
[
https://issues.apache.org/jira/browse/KAFKA-15758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Justine Olshan updated KAFKA-15758:
---
Parent Issue: KAFKA-19079 (was: KAFKA-14402)
> Always schedule wrapped callbacks
> ---
[
https://issues.apache.org/jira/browse/KAFKA-14899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Justine Olshan updated KAFKA-14899:
---
Parent Issue: KAFKA-19079 (was: KAFKA-14402)
> Revisit Action Queue
>
[
https://issues.apache.org/jira/browse/KAFKA-14854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Justine Olshan updated KAFKA-14854:
---
Parent Issue: KAFKA-19079 (was: KAFKA-14402)
> Refactor inter broker send thread to handle
Tombert commented on code in PR #19234:
URL: https://github.com/apache/kafka/pull/19234#discussion_r2025675574
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorNodePunctuator.java:
##
@@ -19,6 +19,7 @@
import org.apache.kafka.streams.processor.Punc
akonopko opened a new pull request, #19350:
URL: https://github.com/apache/kafka/pull/19350
(no comment)
--
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-m
jolshan merged PR #19276:
URL: https://github.com/apache/kafka/pull/19276
--
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.
[
https://issues.apache.org/jira/browse/KAFKA-18826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-18826:
Affects Version/s: 4.0.0
(was: 4.1.0)
> Add Global Thread Metri
mjsax commented on code in PR #19234:
URL: https://github.com/apache/kafka/pull/19234#discussion_r2025491336
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorNodePunctuator.java:
##
@@ -19,6 +19,7 @@
import org.apache.kafka.streams.processor.Punctu
mjsax closed pull request #15740: KAFKA-10844: Add markAsPartitioned operator
URL: https://github.com/apache/kafka/pull/15740
--
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
mjsax commented on PR #18335:
URL: https://github.com/apache/kafka/pull/18335#issuecomment-2773543293
Just stumbling across this PR. Seems it was already fixed via
https://github.com/apache/kafka/pull/18881
Thanks to opening this PR -- I was not aware of it before. Sorry.
--
This i
mjsax closed pull request #18335: Fix GlobalKTable javadoc
URL: https://github.com/apache/kafka/pull/18335
--
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-mai
Tombert commented on PR #19234:
URL: https://github.com/apache/kafka/pull/19234#issuecomment-2773515074
Absolutely, I'll add it to those classes and update the PR shortly.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and u
Tombert commented on code in PR #19234:
URL: https://github.com/apache/kafka/pull/19234#discussion_r2025463642
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorNodePunctuator.java:
##
@@ -19,6 +19,7 @@
import org.apache.kafka.streams.processor.Punc
[
https://issues.apache.org/jira/browse/KAFKA-19058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-19058.
-
Fix Version/s: 4.1.0
Resolution: Fixed
> Running the streams/streams-scala module
mjsax merged PR #19324:
URL: https://github.com/apache/kafka/pull/19324
--
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.or
[
https://issues.apache.org/jira/browse/KAFKA-12679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lucas Brutschy updated KAFKA-12679:
---
Fix Version/s: 3.9.1
> Rebalancing a restoring or running task may cause directory livelocki
stanislavkozlovski commented on code in PR #19336:
URL: https://github.com/apache/kafka/pull/19336#discussion_r2025355519
##
clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerConfig.java:
##
@@ -220,7 +223,9 @@ public class ConsumerConfig extends AbstractConfig {
azhar2407 commented on code in PR #19345:
URL: https://github.com/apache/kafka/pull/19345#discussion_r2025309940
##
clients/src/main/java/org/apache/kafka/common/config/TopicConfig.java:
##
@@ -81,7 +81,8 @@ public class TopicConfig {
public static final String REMOTE_LOG
apalan60 commented on PR #19342:
URL: https://github.com/apache/kafka/pull/19342#issuecomment-2773266711
> @apalan60 Could you also remove this case? It's already covered by
`not.a.property`.
>
>
https://github.com/apache/kafka/blob/e3430fef888b504f2e5ddf35637a4057430d198f/core/src/t
apalan60 commented on code in PR #19342:
URL: https://github.com/apache/kafka/pull/19342#discussion_r2025288103
##
clients/src/main/java/org/apache/kafka/common/record/RecordVersion.java:
##
@@ -20,8 +20,7 @@
* Defines the record format versions supported by Kafka.
*
* For
stanislavkozlovski commented on code in PR #19336:
URL: https://github.com/apache/kafka/pull/19336#discussion_r2025277702
##
clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerConfig.java:
##
@@ -195,7 +195,10 @@ public class ConsumerConfig extends AbstractConfig {
ijuma commented on PR #15968:
URL: https://github.com/apache/kafka/pull/15968#issuecomment-2773182754
That's great, 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 above to go to the specific comment.
chia7712 commented on code in PR #19347:
URL: https://github.com/apache/kafka/pull/19347#discussion_r2025188219
##
tools/src/test/java/org/apache/kafka/tools/consumer/group/DeleteConsumerGroupsTest.java:
##
@@ -64,19 +70,26 @@
import static org.junit.jupiter.api.Assertions.asse
chia7712 merged PR #19226:
URL: https://github.com/apache/kafka/pull/19226
--
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
[
https://issues.apache.org/jira/browse/KAFKA-19067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17940403#comment-17940403
]
Chia-Ping Tsai commented on KAFKA-19067:
{quote}
It also passes fetch position c
gaurav-narula opened a new pull request, #19351:
URL: https://github.com/apache/kafka/pull/19351
This would potentially help debugging the error as the stacktrace would be
valuable in identifying its origin.
--
This is an automated message from the Apache Git Service.
To respond to the me
janchilling commented on code in PR #19275:
URL: https://github.com/apache/kafka/pull/19275#discussion_r2024462086
##
streams/src/test/java/org/apache/kafka/streams/processor/internals/StoreChangelogReaderTest.java:
##
@@ -407,30 +406,6 @@ public long position(final TopicPartiti
[
https://issues.apache.org/jira/browse/KAFKA-18133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17940370#comment-17940370
]
oshione gabriel esiemokhai commented on KAFKA-18133:
Hello, I hope y
frankvicky commented on code in PR #19093:
URL: https://github.com/apache/kafka/pull/19093#discussion_r2025093889
##
core/src/test/scala/integration/kafka/api/PlaintextAdminIntegrationTest.scala:
##
@@ -1901,28 +1933,77 @@ class PlaintextAdminIntegrationTest extends
BaseAdminIn
frankvicky commented on code in PR #19269:
URL: https://github.com/apache/kafka/pull/19269#discussion_r2025053083
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/ActiveTaskCreator.java:
##
@@ -119,7 +119,8 @@ private Producer producer() {
}
publ
frankvicky commented on code in PR #19269:
URL: https://github.com/apache/kafka/pull/19269#discussion_r2025052348
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsProducer.java:
##
@@ -70,6 +70,7 @@ public class StreamsProducer {
private Producer
lianetm commented on PR #19298:
URL: https://github.com/apache/kafka/pull/19298#issuecomment-2772728528
Hey @m1a2st , thanks for the patch! Haven't looked into the code in detail
yet, but high level comments:
1. The new test is being added outside of the `consumer` folder, is that
i
[
https://issues.apache.org/jira/browse/KAFKA-17958?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17940376#comment-17940376
]
oshione gabriel esiemokhai commented on KAFKA-17958:
Hi there. If th
[
https://issues.apache.org/jira/browse/KAFKA-18002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17940374#comment-17940374
]
oshione gabriel esiemokhai commented on KAFKA-18002:
Please could yo
chia7712 merged PR #19284:
URL: https://github.com/apache/kafka/pull/19284
--
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
[
https://issues.apache.org/jira/browse/KAFKA-19044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lucas Brutschy reassigned KAFKA-19044:
--
Assignee: Lucas Brutschy
> Handle tasks that are not present in the current topology
[
https://issues.apache.org/jira/browse/KAFKA-19076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nick Guo reassigned KAFKA-19076:
Assignee: Nick Guo (was: Chia-Ping Tsai)
> UnifiedLog#maybeHandleIOException should replace `Str
leaf-soba commented on PR #18926:
URL: https://github.com/apache/kafka/pull/18926#issuecomment-2771040071
@chia7712 yes I want to fix whole issue.
--
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
[
https://issues.apache.org/jira/browse/KAFKA-18781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kaushik Raina resolved KAFKA-18781.
---
Resolution: Fixed
> Extend RefreshRetriableException related exceptions
> --
Rancho-7 opened a new pull request, #19347:
URL: https://github.com/apache/kafka/pull/19347
jira: https://issues.apache.org/jira/browse/KAFKA-19027
[KAFKA-18329](https://issues.apache.org/jira/browse/KAFKA-18329) will remove
old coordinator, so `ConsumerGroupCommandTestUtils#generator
[
https://issues.apache.org/jira/browse/KAFKA-17932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17940357#comment-17940357
]
oshione gabriel esiemokhai commented on KAFKA-17932:
Hi please if th
smjn commented on code in PR #19339:
URL: https://github.com/apache/kafka/pull/19339#discussion_r2024712166
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java:
##
@@ -4870,37 +4921,127 @@ public CoordinatorResult
initializeShareGroup
smjn commented on PR #19339:
URL: https://github.com/apache/kafka/pull/19339#issuecomment-2772412093
@AndrewJSchofield Thanks for the review, incorporated comments.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
U
smjn commented on code in PR #19328:
URL: https://github.com/apache/kafka/pull/19328#discussion_r2024607201
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorService.java:
##
@@ -1365,6 +1368,67 @@ public
CompletableFuture
describeShareGroup
smjn commented on code in PR #19339:
URL: https://github.com/apache/kafka/pull/19339#discussion_r2024714018
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java:
##
@@ -4870,37 +4921,127 @@ public CoordinatorResult
initializeShareGroup
smjn commented on code in PR #19339:
URL: https://github.com/apache/kafka/pull/19339#discussion_r2024706270
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java:
##
@@ -4870,37 +4921,127 @@ public CoordinatorResult
initializeShareGroup
m1a2st commented on code in PR #19068:
URL: https://github.com/apache/kafka/pull/19068#discussion_r2024705430
##
clients/clients-integration-tests/src/test/java/org/apache/kafka/server/quota/CustomQuotaCallbackTest.java:
##
@@ -69,10 +70,42 @@ public void testCustomQuotaCallback
AndrewJSchofield merged PR #19343:
URL: https://github.com/apache/kafka/pull/19343
--
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...@kafk
smjn commented on code in PR #19328:
URL: https://github.com/apache/kafka/pull/19328#discussion_r2024640257
##
clients/src/main/java/org/apache/kafka/clients/admin/ListShareGroupOffsetsSpec.java:
##
@@ -47,9 +46,10 @@ public ListShareGroupOffsetsSpec
topicPartitions(Collection
smjn commented on code in PR #19328:
URL: https://github.com/apache/kafka/pull/19328#discussion_r2024640257
##
clients/src/main/java/org/apache/kafka/clients/admin/ListShareGroupOffsetsSpec.java:
##
@@ -47,9 +46,10 @@ public ListShareGroupOffsetsSpec
topicPartitions(Collection
smjn commented on code in PR #19328:
URL: https://github.com/apache/kafka/pull/19328#discussion_r2024601473
##
core/src/main/scala/kafka/server/KafkaApis.scala:
##
@@ -3533,19 +3539,74 @@ class KafkaApis(val requestChannel: RequestChannel,
}
}
- private def describeSh
smjn commented on code in PR #19261:
URL: https://github.com/apache/kafka/pull/19261#discussion_r2024547661
##
clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/consumer/ShareConsumerTest.java:
##
@@ -2090,6 +2091,307 @@ public void testComplexShareConsume
chirag-wadhwa5 opened a new pull request, #19348:
URL: https://github.com/apache/kafka/pull/19348
…reGroupConfigMap method in ShareGroupConfig
Delete this text and replace it with a detailed description of your change.
The
PR title and body will become the squashed commit message.
smjn commented on PR #19328:
URL: https://github.com/apache/kafka/pull/19328#issuecomment-2772232357
Thanks @AndrewJSchofield for the PR.
Only couple of minor comments in first pass. Will need one more iteration
over the tests.
--
This is an automated message from the Apache Git Servic
smjn commented on code in PR #19261:
URL: https://github.com/apache/kafka/pull/19261#discussion_r2024547661
##
clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/consumer/ShareConsumerTest.java:
##
@@ -2090,6 +2091,307 @@ public void testComplexShareConsume
Rancho-7 commented on PR #19347:
URL: https://github.com/apache/kafka/pull/19347#issuecomment-2772095318
I retained all the `serverProperties` when replacing with
`@ClusterTestDefaults`,as I found that these properties play an important role
in stabilizing the tests. To avoid introducing in
AndrewJSchofield commented on code in PR #19339:
URL: https://github.com/apache/kafka/pull/19339#discussion_r2024467706
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorService.java:
##
@@ -533,15 +555,38 @@ private
CompletableFuture perform
[
https://issues.apache.org/jira/browse/KAFKA-18971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alieh Saeedi resolved KAFKA-18971.
--
Resolution: Won't Do
Already done!
> Update AK system tests for AK 4.0
>
janchilling commented on code in PR #19275:
URL: https://github.com/apache/kafka/pull/19275#discussion_r2024462086
##
streams/src/test/java/org/apache/kafka/streams/processor/internals/StoreChangelogReaderTest.java:
##
@@ -407,30 +406,6 @@ public long position(final TopicPartiti
davide-armand commented on PR #18142:
URL: https://github.com/apache/kafka/pull/18142#issuecomment-2771640033
> Hi @davide-armand Thanks for the fix, and thanks for the test!
>
> Are you able to remove the Thread.sleep calls from the test? These could
introduce some flakiness later if
Chirag Wadhwa created KAFKA-19075:
-
Summary: Include all share group dynamic configs in
extractShareGroupConfigMap method in ShareGroupConfig
Key: KAFKA-19075
URL: https://issues.apache.org/jira/browse/KAFKA-19075
FrankYang0529 commented on code in PR #19343:
URL: https://github.com/apache/kafka/pull/19343#discussion_r2024025953
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/Group.java:
##
@@ -200,4 +200,13 @@ void validateOffsetFetch(
* Requests a metadata re
m1a2st commented on code in PR #19345:
URL: https://github.com/apache/kafka/pull/19345#discussion_r2024038450
##
clients/src/main/java/org/apache/kafka/common/config/TopicConfig.java:
##
@@ -81,7 +81,8 @@ public class TopicConfig {
public static final String REMOTE_LOG_ST
92 matches
Mail list logo
