[
https://issues.apache.org/jira/browse/KAFKA-16377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17827766#comment-17827766
]
Kuan Po Tseng commented on KAFKA-16377:
---
I'm willing to take over this issue, many
[
https://issues.apache.org/jira/browse/KAFKA-16377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kuan Po Tseng reassigned KAFKA-16377:
-
Assignee: Kuan Po Tseng
> Fix flaky
> HighAvailabilityTaskAssignorIntegrationTest.shou
jinyongchoi commented on code in PR #15495:
URL: https://github.com/apache/kafka/pull/15495#discussion_r1527410280
##
docs/streams/developer-guide/memory-mgmt.html:
##
@@ -151,6 +151,10 @@
Serdes.Long())
.withCachingEnabled();
Record caches are not supported for v
philipnee commented on PR #15548:
URL: https://github.com/apache/kafka/pull/15548#issuecomment-2002293547
Hi @lucasbru @kirktrue - This is the ask to add consumer group protocol to
the test. It should be pretty straightforward and the results are here:
```
===
philipnee opened a new pull request, #15548:
URL: https://github.com/apache/kafka/pull/15548
Adding this as part of the greater effort to modify the system tests to
incorporate the use of consumer group protocol from KIP-848. Following is the
test results and the tests using protocol = con
chia7712 commented on PR #15512:
URL: https://github.com/apache/kafka/pull/15512#issuecomment-2002292346
> should we include this one too ?
yep, please
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL abo
chia7712 commented on code in PR #15512:
URL: https://github.com/apache/kafka/pull/15512#discussion_r1527404009
##
clients/src/test/java/org/apache/kafka/clients/producer/KafkaProducerTest.java:
##
@@ -850,7 +851,7 @@ public void testMetadataTimeoutWithMissingTopic(boolean
isId
[
https://issues.apache.org/jira/browse/KAFKA-15282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17827765#comment-17827765
]
clownxc commented on KAFKA-15282:
-
Hi team, if this ticket is open I will pick it up and
[
https://issues.apache.org/jira/browse/KAFKA-15551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17827764#comment-17827764
]
clownxc commented on KAFKA-15551:
-
It seems not so difficult... Could I pick this up?
>
mjsax commented on code in PR #15510:
URL: https://github.com/apache/kafka/pull/15510#discussion_r1527393681
##
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamKStreamOuterJoinTest.java:
##
@@ -727,7 +801,7 @@ public void testWindowing() {
}
@
[
https://issues.apache.org/jira/browse/KAFKA-15538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17827763#comment-17827763
]
Phuc Hong Tran commented on KAFKA-15538:
[~kirktrue] regarding this comment in K
jinyongchoi commented on code in PR #15495:
URL: https://github.com/apache/kafka/pull/15495#discussion_r1527393749
##
docs/streams/developer-guide/memory-mgmt.html:
##
@@ -151,6 +151,10 @@
Serdes.Long())
.withCachingEnabled();
Record caches are not supported for v
mjsax commented on code in PR #15414:
URL: https://github.com/apache/kafka/pull/15414#discussion_r1527393295
##
streams/src/test/java/org/apache/kafka/streams/integration/GlobalStateReprocessTest.java:
##
@@ -0,0 +1,205 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
mjsax merged PR #15494:
URL: https://github.com/apache/kafka/pull/15494
--
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
brandboat commented on PR #15512:
URL: https://github.com/apache/kafka/pull/15512#issuecomment-2002043253
gentle ping @chia7712, there is another case that could be replaced with
assertIsntanceOf
(in IntelliJ Find in files with regex `assertTrue\(\n?.*isInstance`)
https://github.com/
brandboat commented on code in PR #15512:
URL: https://github.com/apache/kafka/pull/15512#discussion_r1527189077
##
clients/src/test/java/org/apache/kafka/clients/producer/KafkaProducerTest.java:
##
@@ -850,7 +851,7 @@ public void testMetadataTimeoutWithMissingTopic(boolean
isI
johnnychhsu commented on code in PR #15476:
URL: https://github.com/apache/kafka/pull/15476#discussion_r1527123510
##
core/src/test/scala/integration/kafka/admin/ListOffsetsIntegrationTest.scala:
##
@@ -79,9 +79,34 @@ class ListOffsetsIntegrationTest extends
KafkaServerTestHarn
johnnychhsu commented on PR #15476:
URL: https://github.com/apache/kafka/pull/15476#issuecomment-2001881984
test with
```
./gradlew clean core:test --tests kafka.log.LogSegmentTest
./gradlew clean core:test --tests kafka.log.LocalLogTest
```
and it passed
--
This is an auto
johnnychhsu commented on code in PR #15476:
URL: https://github.com/apache/kafka/pull/15476#discussion_r1527119875
##
clients/src/main/java/org/apache/kafka/common/record/MemoryRecords.java:
##
@@ -209,7 +209,7 @@ private static FilterResult filterTo(TopicPartition
partition, I
johnnychhsu commented on code in PR #15476:
URL: https://github.com/apache/kafka/pull/15476#discussion_r1527119875
##
clients/src/main/java/org/apache/kafka/common/record/MemoryRecords.java:
##
@@ -209,7 +209,7 @@ private static FilterResult filterTo(TopicPartition
partition, I
20 matches
Mail list logo
