[
https://issues.apache.org/jira/browse/KAFKA-18841?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
PoAn Yang updated KAFKA-18841:
--
Fix Version/s: 4.2.0
> Enable to test docker image locally
> ---
>
>
[
https://issues.apache.org/jira/browse/KAFKA-18841?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
PoAn Yang resolved KAFKA-18841.
---
Resolution: Fixed
> Enable to test docker image locally
> ---
>
>
abhijeetk88 commented on code in PR #16884:
URL: https://github.com/apache/kafka/pull/16884#discussion_r2299871505
##
core/src/test/scala/unit/kafka/server/AbstractFetcherThreadTest.scala:
##
@@ -1180,4 +1180,562 @@ class AbstractFetcherThreadTest {
fetcher.processFetchRequ
kamalcph commented on PR #16584:
URL: https://github.com/apache/kafka/pull/16584#issuecomment-3222638785
@abhijeetk88
Could you follow this https://github.com/apache/kafka/pull/16781 PR and
handle similarly for EarliestPendingUploadSpec? Thanks!
--
This is an automated message fr
[
https://issues.apache.org/jira/browse/KAFKA-19622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18016189#comment-18016189
]
Sharad Garg commented on KAFKA-19622:
-
Hello, could someone please check this?
> Li
kamalcph commented on code in PR #16884:
URL: https://github.com/apache/kafka/pull/16884#discussion_r2299738443
##
core/src/test/scala/unit/kafka/server/AbstractFetcherThreadTest.scala:
##
@@ -1180,4 +1180,562 @@ class AbstractFetcherThreadTest {
fetcher.processFetchRequest
pjl1070048431 closed pull request #20360: KAFKA-19612: Remove Redundant
Validation in StripedReplicaPlacer
URL: https://github.com/apache/kafka/pull/20360
--
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 g
pjl1070048431 commented on PR #20360:
URL: https://github.com/apache/kafka/pull/20360#issuecomment-3222459672
Just close the PR
--
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 commen
github-actions[bot] commented on PR #20367:
URL: https://github.com/apache/kafka/pull/20367#issuecomment-3222446334
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 #20368:
URL: https://github.com/apache/kafka/pull/20368#issuecomment-3222446291
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 #20371:
URL: https://github.com/apache/kafka/pull/20371#issuecomment-3222446257
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
chia7712 merged PR #20404:
URL: https://github.com/apache/kafka/pull/20404
--
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 #20046:
URL: https://github.com/apache/kafka/pull/20046#discussion_r2299617791
##
core/src/main/scala/kafka/server/KafkaConfig.scala:
##
@@ -513,6 +513,11 @@ class KafkaConfig private(doLog: Boolean, val props:
util.Map[_, _])
require(repli
shashankhs11 commented on PR #20408:
URL: https://github.com/apache/kafka/pull/20408#issuecomment-3222408760
Tagging @mjsax for review.
Also, I need help in rendering the `html` to preview my changes. I was able
to find the guidelines to render the `kafka-site` repo but not the Kafka
[
https://issues.apache.org/jira/browse/KAFKA-19645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lan Ding reassigned KAFKA-19645:
Assignee: Lan Ding (was: Chia-Ping Tsai)
> add a lower bound to num.replica.fetchers
> -
shashankhs11 commented on PR #20329:
URL: https://github.com/apache/kafka/pull/20329#issuecomment-3222372711
Hi @mjsax, apologies for the delay and not pushing as promised. Here is the
new PR #20408, ready for review!
--
This is an automated message from the Apache Git Service.
To respond
shashankhs11 opened a new pull request, #20408:
URL: https://github.com/apache/kafka/pull/20408
Added new section for `window-serdes`
--
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
chia7712 merged PR #20370:
URL: https://github.com/apache/kafka/pull/20370
--
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
frankvicky merged PR #19028:
URL: https://github.com/apache/kafka/pull/19028
--
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.apac
kirktrue commented on code in PR #20324:
URL: https://github.com/apache/kafka/pull/20324#discussion_r2299517175
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/CommitOffsetsSharedState.java:
##
@@ -0,0 +1,162 @@
+/*
+ * Licensed to the Apache Software Founda
kirktrue commented on code in PR #20324:
URL: https://github.com/apache/kafka/pull/20324#discussion_r2299515725
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/CommitOffsetsSharedState.java:
##
@@ -0,0 +1,162 @@
+/*
+ * Licensed to the Apache Software Founda
mjsax commented on PR #20329:
URL: https://github.com/apache/kafka/pull/20329#issuecomment-340103
Thanks @shashankhs11 -- please ping for review on the new PR when you have
it ready.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
[
https://issues.apache.org/jira/browse/KAFKA-19641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18016158#comment-18016158
]
Matthias J. Sax commented on KAFKA-19641:
-
We recently merged [https://github.co
yunchipang commented on code in PR #20396:
URL: https://github.com/apache/kafka/pull/20396#discussion_r2299495289
##
tools/src/main/java/org/apache/kafka/tools/LogCompactionTester.java:
##
@@ -226,6 +236,56 @@ public static String peekLine(BufferedReader reader)
throws IOExcept
[
https://issues.apache.org/jira/browse/KAFKA-19641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-19641:
Component/s: unit tests
> Fix flaky
> RestoreIntegrationTest#shouldInvokeUserDefinedGloba
[
https://issues.apache.org/jira/browse/KAFKA-19641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-19641:
Component/s: streams
> Fix flaky
> RestoreIntegrationTest#shouldInvokeUserDefinedGlobalSt
kirktrue opened a new pull request, #20407:
URL: https://github.com/apache/kafka/pull/20407
Simple test method rename.
--
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 un
mjsax commented on code in PR #20403:
URL: https://github.com/apache/kafka/pull/20403#discussion_r2299384167
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java:
##
@@ -1104,11 +1104,18 @@ private void initializeTopology() {
// initiali
chia7712 commented on PR #20389:
URL: https://github.com/apache/kafka/pull/20389#issuecomment-3221571954
@sjhajharia could you please rebase code to trigger CI again?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
chia7712 commented on code in PR #20396:
URL: https://github.com/apache/kafka/pull/20396#discussion_r2299003609
##
tools/src/main/java/org/apache/kafka/tools/LogCompactionTester.java:
##
@@ -226,6 +236,56 @@ public static String peekLine(BufferedReader reader)
throws IOExceptio
Chia-Ping Tsai created KAFKA-19645:
--
Summary: add a lower bound to num.replica.fetchers
Key: KAFKA-19645
URL: https://issues.apache.org/jira/browse/KAFKA-19645
Project: Kafka
Issue Type: Imp
apoorvmittal10 commented on code in PR #20395:
URL: https://github.com/apache/kafka/pull/20395#discussion_r2298978810
##
core/src/test/java/kafka/server/share/SharePartitionTest.java:
##
@@ -1088,6 +1088,672 @@ public void
testMaybeInitializeStateBatchesWithoutGaps() {
apoorvmittal10 commented on code in PR #20395:
URL: https://github.com/apache/kafka/pull/20395#discussion_r2298978186
##
core/src/main/java/kafka/server/share/SharePartition.java:
##
@@ -1512,6 +1566,13 @@ private ShareAcquiredRecords acquireNewBatchRecords(
//
kirktrue commented on code in PR #19980:
URL: https://github.com/apache/kafka/pull/19980#discussion_r2298971190
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractFetch.java:
##
@@ -222,6 +222,10 @@ protected void handleFetchSuccess(final Node fetchTarg
kirktrue commented on code in PR #19980:
URL: https://github.com/apache/kafka/pull/19980#discussion_r2298969509
##
clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/consumer/PlaintextConsumerTest.java:
##
@@ -1588,6 +1593,103 @@ private void sendCompressed
chia7712 commented on PR #20405:
URL: https://github.com/apache/kafka/pull/20405#issuecomment-3221510808
> Thanks for the feedback. I'm still working on adding the test case and
will update the PR once it's ready.
Perhaps we could enhance
`testServersCanStartWithInvalidStaticConfigsA
apoorvmittal10 commented on code in PR #20395:
URL: https://github.com/apache/kafka/pull/20395#discussion_r2298890511
##
core/src/test/java/kafka/server/share/SharePartitionTest.java:
##
@@ -1088,6 +1088,672 @@ public void
testMaybeInitializeStateBatchesWithoutGaps() {
apoorvmittal10 commented on code in PR #20395:
URL: https://github.com/apache/kafka/pull/20395#discussion_r2298884746
##
core/src/test/java/kafka/server/share/SharePartitionTest.java:
##
@@ -1088,6 +1088,672 @@ public void
testMaybeInitializeStateBatchesWithoutGaps() {
RaidenE1 opened a new pull request, #20406:
URL: https://github.com/apache/kafka/pull/20406
After [KAFKA-7944](https://github.com/apache/kafka/pull/6382), the system
test `streams_eos_test.py` is mostly redundant.
--
This is an automated message from the Apache Git Service.
To respond to
chia7712 merged PR #20401:
URL: https://github.com/apache/kafka/pull/20401
--
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 PR #20401:
URL: https://github.com/apache/kafka/pull/20401#issuecomment-3221120177
the flaky is traced by https://issues.apache.org/jira/browse/KAFKA-19641
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
jim0987795064 commented on PR #20405:
URL: https://github.com/apache/kafka/pull/20405#issuecomment-3221108306
> @jim0987795064 : Thanks for the PR. A couple of comments. Also, could we
add a test case?
Thanks for the feedback. I'm still working on adding the test case and will
update the
jim0987795064 commented on code in PR #20405:
URL: https://github.com/apache/kafka/pull/20405#discussion_r2298676949
##
core/src/main/scala/kafka/server/DynamicBrokerConfig.scala:
##
@@ -231,15 +230,15 @@ object DynamicBrokerConfig {
if (configRecord.resourc
jim0987795064 commented on code in PR #20405:
URL: https://github.com/apache/kafka/pull/20405#discussion_r2298676949
##
core/src/main/scala/kafka/server/DynamicBrokerConfig.scala:
##
@@ -231,15 +230,15 @@ object DynamicBrokerConfig {
if (configRecord.resourc
lianetm commented on code in PR #19980:
URL: https://github.com/apache/kafka/pull/19980#discussion_r2298036689
##
clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/consumer/PlaintextConsumerTest.java:
##
@@ -1588,6 +1593,103 @@ private void sendCompressedM
junrao commented on code in PR #20405:
URL: https://github.com/apache/kafka/pull/20405#discussion_r2298598556
##
core/src/main/scala/kafka/server/DynamicBrokerConfig.scala:
##
@@ -231,15 +230,15 @@ object DynamicBrokerConfig {
if (configRecord.resourceName()
Rancho-7 commented on code in PR #20301:
URL: https://github.com/apache/kafka/pull/20301#discussion_r2298566652
##
tools/src/main/java/org/apache/kafka/tools/EndToEndLatency.java:
##
@@ -221,4 +290,173 @@ private static KafkaProducer
createKafkaProducer(Optional(producerProps);
Rancho-7 commented on code in PR #20301:
URL: https://github.com/apache/kafka/pull/20301#discussion_r2298564631
##
tools/src/main/java/org/apache/kafka/tools/EndToEndLatency.java:
##
@@ -122,33 +137,87 @@ static void execute(String... args) throws Exception {
la
Rancho-7 commented on code in PR #20301:
URL: https://github.com/apache/kafka/pull/20301#discussion_r2298545145
##
tools/src/main/java/org/apache/kafka/tools/EndToEndLatency.java:
##
@@ -221,4 +290,173 @@ private static KafkaProducer
createKafkaProducer(Optional(producerProps);
Rancho-7 commented on code in PR #20301:
URL: https://github.com/apache/kafka/pull/20301#discussion_r2298541868
##
tools/src/main/java/org/apache/kafka/tools/EndToEndLatency.java:
##
@@ -221,4 +290,173 @@ private static KafkaProducer
createKafkaProducer(Optional(producerProps);
AndrewJSchofield commented on code in PR #20385:
URL: https://github.com/apache/kafka/pull/20385#discussion_r2298444121
##
tests/kafkatest/services/performance/share_consumer_performance.py:
##
@@ -33,7 +33,7 @@ class ShareConsumerPerformanceService(PerformanceService):
jolshan commented on code in PR #15087:
URL: https://github.com/apache/kafka/pull/15087#discussion_r2298430334
##
core/src/main/scala/kafka/server/ReplicaManager.scala:
##
@@ -762,167 +763,123 @@ class ReplicaManager(val config: KafkaConfig,
delayedProduceLo
AndrewJSchofield commented on code in PR #20390:
URL: https://github.com/apache/kafka/pull/20390#discussion_r2298331901
##
tools/src/main/java/org/apache/kafka/tools/VerifiableConsumer.java:
##
@@ -622,16 +631,27 @@ public static VerifiableConsumer
createFromArgs(ArgumentParser
[
https://issues.apache.org/jira/browse/KAFKA-8080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
travis reassigned KAFKA-8080:
-
Assignee: travis
> Remove streams_eos_test system test
> ---
>
>
mimaison commented on PR #20308:
URL: https://github.com/apache/kafka/pull/20308#issuecomment-3220564096
@showuon Can you take a look? 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 s
[
https://issues.apache.org/jira/browse/KAFKA-19613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18016014#comment-18016014
]
Uladzislau Blok commented on KAFKA-19613:
-
[~lianetm]
Hello
Just today I've go
[
https://issues.apache.org/jira/browse/KAFKA-19613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Uladzislau Blok updated KAFKA-19613:
Attachment: corrupted_records.excalidraw.png
> Expose consumer CorruptRecordException as c
m1a2st commented on code in PR #20385:
URL: https://github.com/apache/kafka/pull/20385#discussion_r2298240936
##
tools/src/main/java/org/apache/kafka/tools/ConsumerPerformance.java:
##
@@ -292,13 +298,18 @@ public ConsumerPerfOptions(String[] args) {
.ofType(Int
FrankYang0529 commented on code in PR #20046:
URL: https://github.com/apache/kafka/pull/20046#discussion_r2298260187
##
core/src/main/scala/kafka/server/KafkaConfig.scala:
##
@@ -513,6 +513,11 @@ class KafkaConfig private(doLog: Boolean, val props:
util.Map[_, _])
require(
m1a2st commented on code in PR #20385:
URL: https://github.com/apache/kafka/pull/20385#discussion_r2298240936
##
tools/src/main/java/org/apache/kafka/tools/ConsumerPerformance.java:
##
@@ -292,13 +298,18 @@ public ConsumerPerfOptions(String[] args) {
.ofType(Int
mimaison commented on PR #19341:
URL: https://github.com/apache/kafka/pull/19341#issuecomment-3220499805
You can bump the thread to remind people to 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
shashankhs11 commented on PR #20329:
URL: https://github.com/apache/kafka/pull/20329#issuecomment-3220470410
Hi @mimaison, I'll raise a new PR with the `4.1` changes within the next 6
hours, which hopefully gives enough time to review before merging. I hope this
sounds good.
--
This is a
mimaison commented on PR #11442:
URL: https://github.com/apache/kafka/pull/11442#issuecomment-3220458864
@MartinJohannessen This is an open source project. If an issue or feature
matters to you, you can participate and help.
In this case, @mnegodaev has done most of the work already b
FrankYang0529 commented on code in PR #20370:
URL: https://github.com/apache/kafka/pull/20370#discussion_r2298216660
##
core/src/main/scala/kafka/coordinator/transaction/TransactionLog.scala:
##
@@ -115,28 +115,25 @@ object TransactionLog {
val version = buffer.getShort
jim0987795064 opened a new pull request, #20405:
URL: https://github.com/apache/kafka/pull/20405
- Changes: Replace dynamicPerBrokerConfigs with dynamicDefaultConfigs
- Reasons: KRaft servers don't handle the cluser-level configs in starting
from: https://github.com/apache/kafka/pul
[
https://issues.apache.org/jira/browse/KAFKA-19613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18016004#comment-18016004
]
Lianet Magrans commented on KAFKA-19613:
Agree it sounds useful to expose a Corr
abhijeetk88 commented on code in PR #16884:
URL: https://github.com/apache/kafka/pull/16884#discussion_r2298169429
##
core/src/test/scala/unit/kafka/server/AbstractFetcherThreadTest.scala:
##
@@ -1180,4 +1180,551 @@ class AbstractFetcherThreadTest {
fetcher.processFetchRequ
abhijeetk88 commented on code in PR #16884:
URL: https://github.com/apache/kafka/pull/16884#discussion_r2298170907
##
core/src/test/scala/unit/kafka/server/AbstractFetcherThreadTest.scala:
##
@@ -1180,4 +1180,551 @@ class AbstractFetcherThreadTest {
fetcher.processFetchRequ
abhijeetk88 commented on code in PR #16884:
URL: https://github.com/apache/kafka/pull/16884#discussion_r2298167782
##
core/src/test/scala/unit/kafka/server/AbstractFetcherThreadTest.scala:
##
@@ -1180,4 +1180,551 @@ class AbstractFetcherThreadTest {
fetcher.processFetchRequ
chirag-wadhwa5 commented on code in PR #20395:
URL: https://github.com/apache/kafka/pull/20395#discussion_r2298033995
##
core/src/test/java/kafka/server/share/SharePartitionTest.java:
##
@@ -1088,6 +1088,672 @@ public void
testMaybeInitializeStateBatchesWithoutGaps() {
brandboat commented on code in PR #20385:
URL: https://github.com/apache/kafka/pull/20385#discussion_r2298117407
##
tools/src/main/java/org/apache/kafka/tools/ConsumerPerformance.java:
##
@@ -258,11 +258,17 @@ protected static class ConsumerPerfOptions extends
CommandDefaultOpt
JimmyWang6 commented on PR #20271:
URL: https://github.com/apache/kafka/pull/20271#issuecomment-3220274620
@lucasbru Thanks for your reply! I haved fixed the failure test, PTAL.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
sjhajharia commented on PR #20180:
URL: https://github.com/apache/kafka/pull/20180#issuecomment-3220274004
Thanks @chia7712 for the review.
I have addressed the comments and added two unit test files ->
`ClientSensorsTest.java` and `ShareSessionKeyTest.java` for the same.
Pls review w
[
https://issues.apache.org/jira/browse/KAFKA-12456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kuan Po Tseng reassigned KAFKA-12456:
-
Assignee: Kuan Po Tseng
> Log "Listeners are not identical across brokers" message at W
[
https://issues.apache.org/jira/browse/KAFKA-12456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kuan Po Tseng updated KAFKA-12456:
--
Affects Version/s: 3.9.1
> Log "Listeners are not identical across brokers" message at WARN/IN
brandboat opened a new pull request, #20404:
URL: https://github.com/apache/kafka/pull/20404
Lower the log level to INFO instead of ERROR.
--
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
mimaison commented on PR #20178:
URL: https://github.com/apache/kafka/pull/20178#issuecomment-3220249532
Have you been able to validate the actions work?
--
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
JimmyWang6 commented on code in PR #20390:
URL: https://github.com/apache/kafka/pull/20390#discussion_r2298064862
##
tools/src/main/java/org/apache/kafka/tools/VerifiableConsumer.java:
##
@@ -622,16 +631,27 @@ public static VerifiableConsumer
createFromArgs(ArgumentParser parse
JimmyWang6 commented on code in PR #20249:
URL: https://github.com/apache/kafka/pull/20249#discussion_r2298093923
##
core/src/main/java/kafka/server/logger/RuntimeLoggerManager.java:
##
@@ -69,6 +69,21 @@ public void applyChangesForResource(
}
}
+/**
+ *
brandboat commented on PR #10313:
URL: https://github.com/apache/kafka/pull/10313#issuecomment-3220254882
here you go!
https://github.com/apache/kafka/pull/20404
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
U
JimmyWang6 commented on code in PR #20390:
URL: https://github.com/apache/kafka/pull/20390#discussion_r2298064862
##
tools/src/main/java/org/apache/kafka/tools/VerifiableConsumer.java:
##
@@ -622,16 +631,27 @@ public static VerifiableConsumer
createFromArgs(ArgumentParser parse
eduwercamacaro opened a new pull request, #20403:
URL: https://github.com/apache/kafka/pull/20403
Delete this text and replace it with a detailed description of your change.
The
PR title and body will become the squashed commit message.
If you would like to tag individuals, add so
brandboat commented on code in PR #20383:
URL: https://github.com/apache/kafka/pull/20383#discussion_r2298066928
##
server/src/main/java/org/apache/kafka/server/DefaultAutoTopicCreationManager.java:
##
@@ -0,0 +1,268 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) un
JimmyWang6 commented on code in PR #20390:
URL: https://github.com/apache/kafka/pull/20390#discussion_r2298064862
##
tools/src/main/java/org/apache/kafka/tools/VerifiableConsumer.java:
##
@@ -622,16 +631,27 @@ public static VerifiableConsumer
createFromArgs(ArgumentParser parse
brandboat commented on code in PR #20401:
URL: https://github.com/apache/kafka/pull/20401#discussion_r2298054761
##
docs/ops.html:
##
@@ -4116,11 +4116,10 @@
$ bin/kafka-storage.sh format -t KAFKA_CLUSTER_ID --feature kraft.version=1
-c controller.properties
- Cannot set k
chia7712 commented on code in PR #20401:
URL: https://github.com/apache/kafka/pull/20401#discussion_r2298038668
##
docs/ops.html:
##
@@ -4116,11 +4116,10 @@
$ bin/kafka-storage.sh format -t KAFKA_CLUSTER_ID --feature kraft.version=1
-c controller.properties
- Cannot set kr
lucasbru commented on PR #20172:
URL: https://github.com/apache/kafka/pull/20172#issuecomment-3220166034
@mjsax Reminder to please review this when you have time, or let me know if
I should split up the optimization further.
--
This is an automated message from the Apache Git Service.
To
anton-liauchuk commented on PR #20384:
URL: https://github.com/apache/kafka/pull/20384#issuecomment-3220156542
> Hi @anton-liauchuk,
>
> Your PoC introduces a new configuration so it requires a KIP. See
https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Improvement+Proposals
for
jim0987795064 commented on code in PR #20375:
URL: https://github.com/apache/kafka/pull/20375#discussion_r2297972834
##
clients/src/test/java/org/apache/kafka/clients/admin/KafkaAdminClientTest.java:
##
@@ -11668,4 +11668,26 @@ private static StreamsGroupDescribeResponseData
ma
[
https://issues.apache.org/jira/browse/KAFKA-19643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zzshine updated KAFKA-19643:
Attachment: controller_every_min_change.png
part_leader_to_one_node.png
> Controller keeps
[
https://issues.apache.org/jira/browse/KAFKA-19643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zzshine updated KAFKA-19643:
Attachment: (was: part_leader_to_one_node.png)
> Controller keeps switching and occasionally goes offl
chia7712 commented on code in PR #20340:
URL: https://github.com/apache/kafka/pull/20340#discussion_r2297961128
##
core/src/main/scala/kafka/server/AutoTopicCreationManager.scala:
##
@@ -138,6 +138,19 @@ class DefaultAutoTopicCreationManager(
} else if (response.version
[
https://issues.apache.org/jira/browse/KAFKA-19643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zzshine updated KAFKA-19643:
Attachment: (was: xxx.png)
> Controller keeps switching and occasionally goes offline.
> -
[
https://issues.apache.org/jira/browse/KAFKA-19643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zzshine updated KAFKA-19643:
Attachment: part_leader_to_one_node.png
> Controller keeps switching and occasionally goes offline.
>
m1a2st commented on code in PR #20375:
URL: https://github.com/apache/kafka/pull/20375#discussion_r2297949904
##
clients/src/test/java/org/apache/kafka/clients/admin/KafkaAdminClientTest.java:
##
@@ -11668,4 +11669,27 @@ private static StreamsGroupDescribeResponseData
makeFullS
chia7712 commented on code in PR #20375:
URL: https://github.com/apache/kafka/pull/20375#discussion_r2297944462
##
clients/src/test/java/org/apache/kafka/clients/admin/KafkaAdminClientTest.java:
##
@@ -11668,4 +11669,27 @@ private static StreamsGroupDescribeResponseData
makeFul
[
https://issues.apache.org/jira/browse/KAFKA-19644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18015977#comment-18015977
]
Jhen-Yung Hsu commented on KAFKA-19644:
---
I'm working on this, thanks :)
> Enhance
[
https://issues.apache.org/jira/browse/KAFKA-19644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jhen-Yung Hsu reassigned KAFKA-19644:
-
Assignee: Jhen-Yung Hsu (was: Chia-Ping Tsai)
> Enhance the documentation for producer
chia7712 commented on code in PR #20249:
URL: https://github.com/apache/kafka/pull/20249#discussion_r2297926717
##
core/src/main/java/kafka/server/logger/RuntimeLoggerManager.java:
##
@@ -69,6 +69,21 @@ public void applyChangesForResource(
}
}
+/**
+ * Al
adixitconfluent commented on code in PR #20395:
URL: https://github.com/apache/kafka/pull/20395#discussion_r2297922555
##
core/src/test/java/kafka/server/share/SharePartitionTest.java:
##
@@ -1088,6 +1088,672 @@ public void
testMaybeInitializeStateBatchesWithoutGaps() {
1 - 100 of 127 matches
Mail list logo
