chia7712 commented on code in PR #19589:
URL: https://github.com/apache/kafka/pull/19589#discussion_r2275659257
##
raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java:
##
@@ -3271,13 +3317,56 @@ private long pollFollowerAsVoter(FollowerState state,
long currentTimeMs)
Chia-Ping Tsai created KAFKA-19605:
--
Summary: Fix the busy loop occurring in the broker observer
Key: KAFKA-19605
URL: https://issues.apache.org/jira/browse/KAFKA-19605
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-19605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai updated KAFKA-19605:
---
Fix Version/s: 4.2.0
> Fix the busy loop occurring in the broker observer
>
see-quick commented on code in PR #20349:
URL: https://github.com/apache/kafka/pull/20349#discussion_r2275559588
##
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/log/TestLinearWriteSpeed.java:
##
@@ -143,6 +143,7 @@ public static void main(String[] args) throws Exception {
sjhajharia commented on PR #20346:
URL: https://github.com/apache/kafka/pull/20346#issuecomment-3187041066
Thanks @mingyen066
I have assigned the JIRA to myself and as per your suggestion got rid of
some of the toString() methods as well. I did not touch the ones which use
Stringify in
[
https://issues.apache.org/jira/browse/KAFKA-18699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18013837#comment-18013837
]
Sanskar Jhajharia commented on KAFKA-18699:
---
Hey [~mingyen066]
Assigning this
[
https://issues.apache.org/jira/browse/KAFKA-18699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sanskar Jhajharia reassigned KAFKA-18699:
-
Assignee: Sanskar Jhajharia (was: Ming-Yen Chung)
> Migrate suitable classes t
[
https://issues.apache.org/jira/browse/KAFKA-18701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18013834#comment-18013834
]
Sanskar Jhajharia commented on KAFKA-18701:
---
Hey [~mingdaoy] ,
If you have not
[ https://issues.apache.org/jira/browse/KAFKA-18701 ]
Sanskar Jhajharia deleted comment on KAFKA-18701:
---
was (Author: JIRAUSER303707):
Hey [~mingdaoy] , if you have not started working on the same, can I take up
the same?
I have a PR alre
[
https://issues.apache.org/jira/browse/KAFKA-18701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18013833#comment-18013833
]
Sanskar Jhajharia commented on KAFKA-18701:
---
Hey [~mingdaoy] , if you have not
sjhajharia commented on code in PR #20180:
URL: https://github.com/apache/kafka/pull/20180#discussion_r2275435455
##
server/src/main/java/org/apache/kafka/server/purgatory/DelayedDeleteRecords.java:
##
@@ -57,7 +56,7 @@ public DelayedDeleteRecords(long delayMs,
sjhajharia commented on code in PR #20156:
URL: https://github.com/apache/kafka/pull/20156#discussion_r2275311819
##
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/distributed/DistributedHerderTest.java:
##
@@ -4188,12 +4186,12 @@ private void expectRebalance(fin
github-actions[bot] closed pull request #19466: KAFKA-15853: Move static
functions from KafkaConfig to AbstractKafkaConfig (wip)
URL: https://github.com/apache/kafka/pull/19466
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
github-actions[bot] commented on PR #19466:
URL: https://github.com/apache/kafka/pull/19466#issuecomment-3186705431
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 #18808:
URL: https://github.com/apache/kafka/pull/18808#issuecomment-3186705328
This PR is being marked as stale since it has not had any activity in 90
days. If you
would like to keep this PR alive, please leave a comment asking for a
review. If the P
github-actions[bot] commented on PR #20256:
URL: https://github.com/apache/kafka/pull/20256#issuecomment-3186663045
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 #20314:
URL: https://github.com/apache/kafka/pull/20314#issuecomment-3186662877
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 #20318:
URL: https://github.com/apache/kafka/pull/20318#issuecomment-3186662831
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
[
https://issues.apache.org/jira/browse/KAFKA-19168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18013823#comment-18013823
]
Jhen-Yung Hsu commented on KAFKA-19168:
---
Here is the KIP: https://cwiki.apache.org
Yunyung commented on PR #19573:
URL: https://github.com/apache/kafka/pull/19573#issuecomment-3186609003
Here is the KIP: https://cwiki.apache.org/confluence/x/vomKFQ.
I also created the discussion thread a few days ago:
https://lists.apache.org/thread/vdhfxlzkb8z7gpgky69y9qxw9cqjpog8. Th
Yunyung commented on PR #20339:
URL: https://github.com/apache/kafka/pull/20339#issuecomment-3186577144
> @Yunyung : Could you please merge the trunk to trigger ci again?
Done. Thanks.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
[
https://issues.apache.org/jira/browse/KAFKA-19596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen resolved KAFKA-19596.
---
Fix Version/s: 4.2.0
Resolution: Fixed
> Log auto topic creation failures more visibly
>
showuon merged PR #20340:
URL: https://github.com/apache/kafka/pull/20340
--
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.
mingyen066 commented on code in PR #20346:
URL: https://github.com/apache/kafka/pull/20346#discussion_r2275191518
##
metadata/src/main/java/org/apache/kafka/controller/BrokerControlStates.java:
##
@@ -17,37 +17,7 @@
package org.apache.kafka.controller;
-import java.util.Obj
mjsax commented on code in PR #20325:
URL: https://github.com/apache/kafka/pull/20325#discussion_r2275149725
##
core/src/main/scala/kafka/server/AutoTopicCreationManager.scala:
##
@@ -112,6 +128,45 @@ class DefaultAutoTopicCreationManager(
}
}
+ override def getTopicC
mjsax commented on code in PR #20325:
URL: https://github.com/apache/kafka/pull/20325#discussion_r2275159146
##
core/src/main/scala/kafka/server/KafkaApis.scala:
##
@@ -2889,6 +2889,24 @@ class KafkaApis(val requestChannel: RequestChannel,
}
} else {
mjsax commented on code in PR #20325:
URL: https://github.com/apache/kafka/pull/20325#discussion_r2275144231
##
core/src/main/scala/kafka/server/AutoTopicCreationManager.scala:
##
@@ -64,6 +77,9 @@ class DefaultAutoTopicCreationManager(
) extends AutoTopicCreationManager with L
mjsax commented on code in PR #20325:
URL: https://github.com/apache/kafka/pull/20325#discussion_r2275137991
##
core/src/main/scala/kafka/server/AutoTopicCreationManager.scala:
##
@@ -64,6 +77,9 @@ class DefaultAutoTopicCreationManager(
) extends AutoTopicCreationManager with L
[
https://issues.apache.org/jira/browse/KAFKA-19430?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18013819#comment-18013819
]
Matthias J. Sax commented on KAFKA-19430:
-
{quote}About CONTINUE case: exception
mjsax commented on code in PR #20347:
URL: https://github.com/apache/kafka/pull/20347#discussion_r2274993836
##
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/RestoreIntegrationTest.java:
##
@@ -244,8 +258,13 @@ public void shouldRestoreNullRecord()
mingyen066 commented on code in PR #20335:
URL: https://github.com/apache/kafka/pull/20335#discussion_r2275013842
##
core/src/test/scala/unit/kafka/cluster/AssignmentStateTest.scala:
##
@@ -86,31 +86,33 @@ class AssignmentStateTest extends AbstractPartitionTest {
@Parameter
chia7712 commented on code in PR #20338:
URL: https://github.com/apache/kafka/pull/20338#discussion_r2274997289
##
core/src/test/java/kafka/server/BrokerRegistrationRequestTest.java:
##
@@ -0,0 +1,217 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
mjsax commented on code in PR #20347:
URL: https://github.com/apache/kafka/pull/20347#discussion_r2274987340
##
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/RestoreIntegrationTest.java:
##
@@ -814,29 +838,56 @@ private void createStateForRestorati
x1ng-z commented on PR #12331:
URL: https://github.com/apache/kafka/pull/12331#issuecomment-3186300818
is it available in v4.0?
--
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
[
https://issues.apache.org/jira/browse/KAFKA-19604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai reassigned KAFKA-19604:
--
Assignee: Kevin Wu
> Document controller.quorum.auto.join.enable config in upgrade.ht
chia7712 commented on PR #20351:
URL: https://github.com/apache/kafka/pull/20351#issuecomment-3186286761
@mingyen066 please fix the build 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
[
https://issues.apache.org/jira/browse/KAFKA-19604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18013802#comment-18013802
]
Chia-Ping Tsai commented on KAFKA-19604:
[~kevinwu2412] Please feel free to unas
chia7712 commented on code in PR #20156:
URL: https://github.com/apache/kafka/pull/20156#discussion_r2274910909
##
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/distributed/DistributedHerderTest.java:
##
@@ -4188,12 +4186,12 @@ private void expectRebalance(final
mjsax commented on code in PR #20347:
URL: https://github.com/apache/kafka/pull/20347#discussion_r2274742917
##
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/RestoreIntegrationTest.java:
##
@@ -815,28 +826,28 @@ private void createStateForRestorati
[
https://issues.apache.org/jira/browse/KAFKA-19430?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18013769#comment-18013769
]
Uladzislau Blok edited comment on KAFKA-19430 at 8/13/25 8:24 PM:
[
https://issues.apache.org/jira/browse/KAFKA-19430?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18013769#comment-18013769
]
Uladzislau Blok commented on KAFKA-19430:
-
I'm not fully sure for now what would
jim0987795064 commented on code in PR #20199:
URL: https://github.com/apache/kafka/pull/20199#discussion_r2274402970
##
server/src/test/java/org/apache/kafka/server/EligibleLeaderReplicasIntegrationTest.java:
##
@@ -0,0 +1,387 @@
+/*
+ * Licensed to the Apache Software Foundatio
lianetm commented on code in PR #20324:
URL: https://github.com/apache/kafka/pull/20324#discussion_r2274334185
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/OffsetsRequestManager.java:
##
@@ -243,8 +237,11 @@ public CompletableFuture
updateFetchPositions(
mjsax commented on PR #20321:
URL: https://github.com/apache/kafka/pull/20321#issuecomment-3185174405
Thanks. Merged the other PR.
Also took the liberty to cherry-pick this commit to 4.1, 4.0, and 3.9
branches. -- As we are getting a new RC for 4.0.1 release, it should pickup the
cha
[
https://issues.apache.org/jira/browse/KAFKA-19556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18013762#comment-18013762
]
oshione gabriel esiemokhai commented on KAFKA-19556:
Yes exactly so
chia7712 commented on code in PR #20199:
URL: https://github.com/apache/kafka/pull/20199#discussion_r227423
##
server/src/test/java/org/apache/kafka/server/EligibleLeaderReplicasIntegrationTest.java:
##
@@ -0,0 +1,387 @@
+/*
+ * Licensed to the Apache Software Foundation (AS
chia7712 commented on code in PR #20335:
URL: https://github.com/apache/kafka/pull/20335#discussion_r2274273267
##
core/src/test/scala/unit/kafka/cluster/AssignmentStateTest.scala:
##
@@ -86,31 +86,33 @@ class AssignmentStateTest extends AbstractPartitionTest {
@Parameteriz
[
https://issues.apache.org/jira/browse/KAFKA-10789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ksolves India Limited reassigned KAFKA-10789:
-
Assignee: Ksolves India Limited (was: Ryan Ye)
> Streamlining Tests in
[
https://issues.apache.org/jira/browse/KAFKA-10789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18013755#comment-18013755
]
Matthias J. Sax commented on KAFKA-10789:
-
Please go ahead. It seems Ryan had dr
chia7712 commented on code in PR #20180:
URL: https://github.com/apache/kafka/pull/20180#discussion_r2274230694
##
server/src/test/java/org/apache/kafka/network/SocketServerConfigsTest.java:
##
@@ -36,7 +36,7 @@ public void testDefaultNameToSecurityProto() {
new
chia7712 commented on code in PR #20180:
URL: https://github.com/apache/kafka/pull/20180#discussion_r2274207213
##
server/src/main/java/org/apache/kafka/server/config/ClientQuotaManagerConfig.java:
##
@@ -15,6 +15,7 @@
* limitations under the License.
*/
package org.apache.
chia7712 commented on code in PR #18981:
URL: https://github.com/apache/kafka/pull/18981#discussion_r2274188359
##
core/src/main/scala/kafka/server/AutoTopicCreationManager.scala:
##
@@ -83,9 +89,30 @@ class DefaultAutoTopicCreationManager(
uncreatableTopicResponses ++ crea
junrao commented on code in PR #19762:
URL: https://github.com/apache/kafka/pull/19762#discussion_r2271552627
##
raft/src/main/java/org/apache/kafka/raft/internals/KafkaRaftLog.java:
##
@@ -0,0 +1,829 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
chia7712 commented on code in PR #19589:
URL: https://github.com/apache/kafka/pull/19589#discussion_r2274143020
##
raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java:
##
@@ -3271,13 +3317,56 @@ private long pollFollowerAsVoter(FollowerState state,
long currentTimeMs)
mingyen066 opened a new pull request, #20351:
URL: https://github.com/apache/kafka/pull/20351
Refactor metric gauges instantiation to use lambda expressions instead of
ImmutableValue.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
kirktrue commented on code in PR #20347:
URL: https://github.com/apache/kafka/pull/20347#discussion_r2273992582
##
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/RestoreIntegrationTest.java:
##
@@ -120,14 +124,23 @@ public class RestoreIntegrationTe
chia7712 commented on code in PR #20349:
URL: https://github.com/apache/kafka/pull/20349#discussion_r2273963415
##
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/log/TestLinearWriteSpeed.java:
##
@@ -143,6 +143,7 @@ public static void main(String[] args) throws Exception {
brandboat commented on code in PR #18981:
URL: https://github.com/apache/kafka/pull/18981#discussion_r2273873010
##
core/src/main/scala/kafka/server/AutoTopicCreationManager.scala:
##
@@ -83,9 +89,30 @@ class DefaultAutoTopicCreationManager(
uncreatableTopicResponses ++ cre
brandboat commented on code in PR #18981:
URL: https://github.com/apache/kafka/pull/18981#discussion_r2273873010
##
core/src/main/scala/kafka/server/AutoTopicCreationManager.scala:
##
@@ -83,9 +89,30 @@ class DefaultAutoTopicCreationManager(
uncreatableTopicResponses ++ cre
brandboat opened a new pull request, #20350:
URL: https://github.com/apache/kafka/pull/20350
Part 1: Migrate AutoTopicCreationManager.scala to Java. No functional
changes; this step only converts the implementation. Part 2 will migrate
AutoTopicCreationManagerTest.scala to Java.
--
This
brandboat commented on code in PR #18981:
URL: https://github.com/apache/kafka/pull/18981#discussion_r2273873010
##
core/src/main/scala/kafka/server/AutoTopicCreationManager.scala:
##
@@ -83,9 +89,30 @@ class DefaultAutoTopicCreationManager(
uncreatableTopicResponses ++ cre
[
https://issues.apache.org/jira/browse/KAFKA-19078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai resolved KAFKA-19078.
Resolution: Fixed
> Implement automatic controller addition to cluster metadata partition
chia7712 merged PR #19589:
URL: https://github.com/apache/kafka/pull/19589
--
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
kevin-wu24 commented on code in PR #19589:
URL: https://github.com/apache/kafka/pull/19589#discussion_r2273790581
##
raft/src/main/java/org/apache/kafka/raft/QuorumConfig.java:
##
@@ -102,6 +103,11 @@ public class QuorumConfig {
public static final String QUORUM_RETRY_BACKO
Kevin Wu created KAFKA-19604:
Summary: Document controller.quorum.auto.join.enable config in
upgrade.html
Key: KAFKA-19604
URL: https://issues.apache.org/jira/browse/KAFKA-19604
Project: Kafka
I
chia7712 commented on code in PR #19589:
URL: https://github.com/apache/kafka/pull/19589#discussion_r2273767603
##
raft/src/main/java/org/apache/kafka/raft/QuorumConfig.java:
##
@@ -102,6 +103,11 @@ public class QuorumConfig {
public static final String QUORUM_RETRY_BACKOFF
see-quick commented on code in PR #20349:
URL: https://github.com/apache/kafka/pull/20349#discussion_r2273448472
##
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/log/TestLinearWriteSpeed.java:
##
@@ -143,6 +143,9 @@ public static void main(String[] args) throws Exception {
see-quick commented on code in PR #20349:
URL: https://github.com/apache/kafka/pull/20349#discussion_r2273447479
##
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/log/TestLinearWriteSpeed.java:
##
@@ -143,6 +143,9 @@ public static void main(String[] args) throws Exception {
aliehsaeedii commented on code in PR #20325:
URL: https://github.com/apache/kafka/pull/20325#discussion_r2273440201
##
core/src/main/scala/kafka/server/KafkaApis.scala:
##
@@ -2889,6 +2889,24 @@ class KafkaApis(val requestChannel: RequestChannel,
}
}
aliehsaeedii commented on code in PR #20325:
URL: https://github.com/apache/kafka/pull/20325#discussion_r2273440201
##
core/src/main/scala/kafka/server/KafkaApis.scala:
##
@@ -2889,6 +2889,24 @@ class KafkaApis(val requestChannel: RequestChannel,
}
}
aliehsaeedii commented on code in PR #20325:
URL: https://github.com/apache/kafka/pull/20325#discussion_r2273419281
##
core/src/test/scala/unit/kafka/server/AutoTopicCreationManagerTest.scala:
##
@@ -393,4 +403,119 @@ class AutoTopicCreationManagerTest {
.setNumPartitions
aliehsaeedii commented on code in PR #20325:
URL: https://github.com/apache/kafka/pull/20325#discussion_r2273417888
##
core/src/test/scala/unit/kafka/server/AutoTopicCreationManagerTest.scala:
##
@@ -393,4 +403,119 @@ class AutoTopicCreationManagerTest {
.setNumPartitions
aliehsaeedii commented on code in PR #20325:
URL: https://github.com/apache/kafka/pull/20325#discussion_r2273386686
##
core/src/main/scala/kafka/server/AutoTopicCreationManager.scala:
##
@@ -263,4 +318,30 @@ class DefaultAutoTopicCreationManager(
(creatableTopics, uncreat
aliehsaeedii commented on code in PR #20325:
URL: https://github.com/apache/kafka/pull/20325#discussion_r2273380363
##
core/src/main/scala/kafka/server/AutoTopicCreationManager.scala:
##
@@ -134,11 +180,20 @@ class DefaultAutoTopicCreationManager(
override def onComplete(
aliehsaeedii commented on code in PR #20325:
URL: https://github.com/apache/kafka/pull/20325#discussion_r2273377362
##
core/src/main/scala/kafka/server/AutoTopicCreationManager.scala:
##
@@ -134,11 +180,20 @@ class DefaultAutoTopicCreationManager(
override def onComplete(
[
https://issues.apache.org/jira/browse/KAFKA-10789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18013681#comment-18013681
]
Ksolves India Limited commented on KAFKA-10789:
---
[~mjsax] It seems like th
aliehsaeedii commented on code in PR #20325:
URL: https://github.com/apache/kafka/pull/20325#discussion_r2273302083
##
core/src/main/scala/kafka/server/AutoTopicCreationManager.scala:
##
@@ -135,10 +190,17 @@ class DefaultAutoTopicCreationManager(
clearInflightRequests(
aliehsaeedii commented on code in PR #20325:
URL: https://github.com/apache/kafka/pull/20325#discussion_r2273282296
##
core/src/main/scala/kafka/server/AutoTopicCreationManager.scala:
##
@@ -135,10 +190,17 @@ class DefaultAutoTopicCreationManager(
clearInflightRequests(
aliehsaeedii commented on code in PR #20325:
URL: https://github.com/apache/kafka/pull/20325#discussion_r2273282296
##
core/src/main/scala/kafka/server/AutoTopicCreationManager.scala:
##
@@ -135,10 +190,17 @@ class DefaultAutoTopicCreationManager(
clearInflightRequests(
mimaison commented on code in PR #20349:
URL: https://github.com/apache/kafka/pull/20349#discussion_r2273276617
##
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/log/TestLinearWriteSpeed.java:
##
@@ -143,6 +143,9 @@ public static void main(String[] args) throws Exception {
aliehsaeedii commented on code in PR #20325:
URL: https://github.com/apache/kafka/pull/20325#discussion_r2273257251
##
core/src/main/scala/kafka/server/AutoTopicCreationManager.scala:
##
@@ -112,6 +128,45 @@ class DefaultAutoTopicCreationManager(
}
}
+ override def ge
[
https://issues.apache.org/jira/browse/KAFKA-19012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18013672#comment-18013672
]
Krzysztof Barczynski commented on KAFKA-19012:
--
[~junrao] We experienced th
aliehsaeedii commented on code in PR #20325:
URL: https://github.com/apache/kafka/pull/20325#discussion_r2273217176
##
core/src/main/scala/kafka/server/AutoTopicCreationManager.scala:
##
@@ -53,17 +55,34 @@ trait AutoTopicCreationManager {
requestContext: RequestContext
[
https://issues.apache.org/jira/browse/KAFKA-19601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18013671#comment-18013671
]
Chia-Ping Tsai commented on KAFKA-19601:
Nice idea, Perhaps we could do the same
aliehsaeedii commented on code in PR #20347:
URL: https://github.com/apache/kafka/pull/20347#discussion_r2272990965
##
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/RestoreIntegrationTest.java:
##
@@ -815,28 +828,28 @@ private void createStateForRe
[
https://issues.apache.org/jira/browse/KAFKA-19603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18013645#comment-18013645
]
ally heev commented on KAFKA-19603:
---
[~proggga] you might want to create a KIP and add
tinaselenge commented on PR #20343:
URL: https://github.com/apache/kafka/pull/20343#issuecomment-3183089299
thank you @sjhajharia for reviewing!
@showuon can you please take a look and kick off the CI build when you get a
chance? Thank you.
--
This is an automated message from th
[
https://issues.apache.org/jira/browse/KAFKA-19603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mikhail Fesenko updated KAFKA-19603:
Description:
h2. Description
h3. Summary
Change the data type of *{{log.segment.bytes}}*
Mikhail Fesenko created KAFKA-19603:
---
Summary: Change log.segment.bytes configuration type from int to
long to support segments larger than 2GB
Key: KAFKA-19603
URL: https://issues.apache.org/jira/browse/KAFKA-
see-quick opened a new pull request, #20349:
URL: https://github.com/apache/kafka/pull/20349
This PR fixes a problem related to `TestLinearWriteSpeed`. During my work
on KIP-780, I discovered that benchmarks for `TestLinearWriteSpeed` do not
account for compression algorithms. It always us
Florens Pauwels created KAFKA-19602:
---
Summary: Kafka Streams join after unmaterialized transformValues
on KTable with extra store fails
Key: KAFKA-19602
URL: https://issues.apache.org/jira/browse/KAFKA-19602
[
https://issues.apache.org/jira/browse/KAFKA-19602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Florens Pauwels updated KAFKA-19602:
Description:
I believe for this to occur you need
# transformValues on a KTable, followed
[
https://issues.apache.org/jira/browse/KAFKA-19556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18013597#comment-18013597
]
Tamas Kornai commented on KAFKA-19556:
--
We are routing by IP.
> [Connect] Provide
93 matches
Mail list logo
