Sebastien Viale created KAFKA-16811:
---
Summary: Punctuate Ratio metric almost impossible to track
Key: KAFKA-16811
URL: https://issues.apache.org/jira/browse/KAFKA-16811
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-16807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17848471#comment-17848471
]
Luke Chen commented on KAFKA-16807:
---
Set as blocker for v3.7.1 and v3.8.0 since users
[
https://issues.apache.org/jira/browse/KAFKA-16807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen updated KAFKA-16807:
--
Priority: Blocker (was: Minor)
> DescribeLogDirsResponseData#results#topics have unexpected topics ha
[
https://issues.apache.org/jira/browse/KAFKA-16807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen updated KAFKA-16807:
--
Fix Version/s: 3.8.0
3.7.1
> DescribeLogDirsResponseData#results#topics have unexpe
mjsax commented on PR #15975:
URL: https://github.com/apache/kafka/pull/15975#issuecomment-2123976338
Merged to `trunk` to make progress on the implementation of the KIP.
About testing: I agree that we might not need to test every method which
creates an iterator, but it would be grea
cadonna commented on code in PR #15640:
URL: https://github.com/apache/kafka/pull/15640#discussion_r1609353060
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/ConsumerNetworkThreadTest.java:
##
@@ -281,64 +276,15 @@ void testEnsureMetadataUpdateOnPoll() {
mjsax merged PR #15975:
URL: https://github.com/apache/kafka/pull/15975
--
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
cadonna commented on code in PR #15640:
URL: https://github.com/apache/kafka/pull/15640#discussion_r1609353060
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/ConsumerNetworkThreadTest.java:
##
@@ -281,64 +276,15 @@ void testEnsureMetadataUpdateOnPoll() {
cadonna commented on code in PR #15640:
URL: https://github.com/apache/kafka/pull/15640#discussion_r1609353060
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/ConsumerNetworkThreadTest.java:
##
@@ -281,64 +276,15 @@ void testEnsureMetadataUpdateOnPoll() {
showuon commented on PR #15908:
URL: https://github.com/apache/kafka/pull/15908#issuecomment-2123949904
Forgot to say, thanks for closing all the `ConsumerGroupService` instances.
I can't believe we leak these resources before.
--
This is an automated message from the Apache Git Service.
showuon commented on PR #15908:
URL: https://github.com/apache/kafka/pull/15908#issuecomment-2123948788
One high-level question:
I found after this change, we increased the test case numbers from 492 ->
660. And the time for this test suite takes form 1h 19m -> 1h 31m. Do we really
need
cadonna commented on code in PR #15640:
URL: https://github.com/apache/kafka/pull/15640#discussion_r1609312616
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/ConsumerNetworkThreadTest.java:
##
@@ -281,64 +276,15 @@ void testEnsureMetadataUpdateOnPoll() {
showuon commented on code in PR #15908:
URL: https://github.com/apache/kafka/pull/15908#discussion_r1609296852
##
tools/src/test/java/org/apache/kafka/tools/consumer/group/ConsumerGroupCommandTestUtils.java:
##
@@ -92,6 +94,7 @@ static void generator(ClusterGenerator clusterGene
[
https://issues.apache.org/jira/browse/KAFKA-16810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17848455#comment-17848455
]
Harsh Panchal commented on KAFKA-16810:
---
PR: https://github.com/apache/kafka/pull/
Harsh Panchal created KAFKA-16810:
-
Summary: Improve kafka-consumer-perf-test to benchmark single
partition
Key: KAFKA-16810
URL: https://issues.apache.org/jira/browse/KAFKA-16810
Project: Kafka
omkreddy merged PR #15927:
URL: https://github.com/apache/kafka/pull/15927
--
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
rreddy-22 opened a new pull request, #16026:
URL: https://github.com/apache/kafka/pull/16026
Went through all the files in the group coordinator module and fixed up a
few minor warnings and cleaned up a few leftover errors. Also fixed the
formatting to make it more uniform
--
This is
showuon commented on code in PR #15951:
URL: https://github.com/apache/kafka/pull/15951#discussion_r1609228927
##
core/src/main/scala/kafka/server/ReplicaManager.scala:
##
@@ -2114,16 +2114,12 @@ class ReplicaManager(val config: KafkaConfig,
partition.log.foreach { _ =>
kamalcph commented on PR #15825:
URL: https://github.com/apache/kafka/pull/15825#issuecomment-2123824613
@junrao @showuon
Thanks for the review! Addressed all the review comments. PTAL.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
kamalcph commented on code in PR #15825:
URL: https://github.com/apache/kafka/pull/15825#discussion_r1609227442
##
core/src/main/scala/kafka/log/LocalLog.scala:
##
@@ -370,11 +370,17 @@ class LocalLog(@volatile private var _dir: File,
throw new OffsetOutOfRangeException
kamalcph commented on code in PR #15825:
URL: https://github.com/apache/kafka/pull/15825#discussion_r1609227180
##
core/src/main/scala/kafka/log/LocalLog.scala:
##
@@ -370,11 +370,17 @@ class LocalLog(@volatile private var _dir: File,
throw new OffsetOutOfRangeException
[
https://issues.apache.org/jira/browse/KAFKA-16662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17848436#comment-17848436
]
Jianbin Chen commented on KAFKA-16662:
--
After I deleted all of the __cluster_metada
chia7712 commented on PR #15983:
URL: https://github.com/apache/kafka/pull/15983#issuecomment-2123808122
> I think we can file another PR to improve it, either we add a
future.get(30 sec), or we set a global @timeout tag on the test class to limit
the waiting time.
I love the idea ab
[
https://issues.apache.org/jira/browse/KAFKA-16662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17848434#comment-17848434
]
Jianbin Chen commented on KAFKA-16662:
--
When I executed ./bin/kafka-features.sh --b
[
https://issues.apache.org/jira/browse/KAFKA-16783?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen resolved KAFKA-16783.
---
Fix Version/s: 3.8.0
Resolution: Fixed
> Migrate RemoteLogMetadataManagerTest to new test inf
showuon merged PR #15983:
URL: https://github.com/apache/kafka/pull/15983
--
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-16662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17848431#comment-17848431
]
Jianbin Chen commented on KAFKA-16662:
--
Could someone please pay attention to this
artemlivshits commented on code in PR #15685:
URL: https://github.com/apache/kafka/pull/15685#discussion_r1609158284
##
core/src/main/scala/kafka/server/BrokerFeatures.scala:
##
@@ -75,16 +75,19 @@ object BrokerFeatures extends Logging {
}
def defaultSupportedFeatures(un
showuon commented on PR #15983:
URL: https://github.com/apache/kafka/pull/15983#issuecomment-2123794220
Failed tests are unrelated.
--
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 co
[
https://issues.apache.org/jira/browse/KAFKA-16662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17848424#comment-17848424
]
Jianbin Chen edited comment on KAFKA-16662 at 5/22/24 3:10 AM:
---
gongxuanzhang commented on code in PR #16010:
URL: https://github.com/apache/kafka/pull/16010#discussion_r1609198047
##
core/src/main/scala/kafka/tools/StorageTool.scala:
##
@@ -452,19 +452,20 @@ object StorageTool extends Logging {
stream.println("All of the log director
[
https://issues.apache.org/jira/browse/KAFKA-16662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17848424#comment-17848424
]
Jianbin Chen commented on KAFKA-16662:
--
I have encountered the same issue. Can anyo
showuon commented on code in PR #15924:
URL: https://github.com/apache/kafka/pull/15924#discussion_r1609187500
##
core/src/main/scala/kafka/server/AclApis.scala:
##
@@ -69,7 +69,7 @@ class AclApis(authHelper: AuthHelper,
case Some(auth) =>
val filter = describeAc
showuon commented on code in PR #15825:
URL: https://github.com/apache/kafka/pull/15825#discussion_r1609081346
##
core/src/main/scala/kafka/log/UnifiedLog.scala:
##
@@ -1424,11 +1424,18 @@ class UnifiedLog(@volatile var logStartOffset: Long,
/**
* Given a message offse
showuon commented on code in PR #15825:
URL: https://github.com/apache/kafka/pull/15825#discussion_r1609081346
##
core/src/main/scala/kafka/log/UnifiedLog.scala:
##
@@ -1424,11 +1424,18 @@ class UnifiedLog(@volatile var logStartOffset: Long,
/**
* Given a message offse
showuon commented on code in PR #15825:
URL: https://github.com/apache/kafka/pull/15825#discussion_r1609081346
##
core/src/main/scala/kafka/log/UnifiedLog.scala:
##
@@ -1424,11 +1424,18 @@ class UnifiedLog(@volatile var logStartOffset: Long,
/**
* Given a message offse
showuon commented on code in PR #15825:
URL: https://github.com/apache/kafka/pull/15825#discussion_r1609081346
##
core/src/main/scala/kafka/log/UnifiedLog.scala:
##
@@ -1424,11 +1424,18 @@ class UnifiedLog(@volatile var logStartOffset: Long,
/**
* Given a message offse
showuon commented on code in PR #15825:
URL: https://github.com/apache/kafka/pull/15825#discussion_r1609081346
##
core/src/main/scala/kafka/log/UnifiedLog.scala:
##
@@ -1424,11 +1424,18 @@ class UnifiedLog(@volatile var logStartOffset: Long,
/**
* Given a message offse
showuon commented on code in PR #15825:
URL: https://github.com/apache/kafka/pull/15825#discussion_r1609081346
##
core/src/main/scala/kafka/log/UnifiedLog.scala:
##
@@ -1424,11 +1424,18 @@ class UnifiedLog(@volatile var logStartOffset: Long,
/**
* Given a message offse
brandboat commented on PR #16020:
URL: https://github.com/apache/kafka/pull/16020#issuecomment-2123611516
> The benefit of this approach is that we don't need to add removed class
back. WDYT?
This one is way better, thanks !
--
This is an automated message from the Apache Git Serv
[
https://issues.apache.org/jira/browse/KAFKA-16798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17848404#comment-17848404
]
Greg Harris commented on KAFKA-16798:
-
Hi [~sektor.coder] thanks for the ticket!
Th
gharris1727 commented on code in PR #15910:
URL: https://github.com/apache/kafka/pull/15910#discussion_r1609062958
##
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/OffsetSyncStore.java:
##
@@ -105,12 +106,19 @@ private KafkaBasedLog
createBackingStore(MirrorCheck
junrao commented on PR #15673:
URL: https://github.com/apache/kafka/pull/15673#issuecomment-2123590782
@clolov : 3.8.0 feature freeze is about 1 week away. It would be useful to
get this PR in before the 3.8 branch is cut. Any updates on this PR? What's an
example of the failed test?
--
junrao commented on code in PR #15993:
URL: https://github.com/apache/kafka/pull/15993#discussion_r1609025456
##
core/src/main/scala/kafka/log/UnifiedLog.scala:
##
@@ -2095,7 +2101,8 @@ object UnifiedLog extends Logging {
}
/**
- * If the recordVersion is >= RecordVers
cmccabe commented on PR #16006:
URL: https://github.com/apache/kafka/pull/16006#issuecomment-2123537218
Tests should be fixed now.
--
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 com
edoardocomar commented on PR #15910:
URL: https://github.com/apache/kafka/pull/15910#issuecomment-2123528226
@gharris1727 I gave up and used the ugly try.
That warning is not occurring in every test... But I went all the way in
`OffsetSyncStoreTest` as I prefer consistency to beauty.
jeffkbkim commented on PR #15970:
URL: https://github.com/apache/kafka/pull/15970#issuecomment-2123510093
@dajac thanks for the review. I have addressed your comments
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
junrao commented on code in PR #15825:
URL: https://github.com/apache/kafka/pull/15825#discussion_r1608986312
##
core/src/main/scala/kafka/log/LocalLog.scala:
##
@@ -370,11 +370,17 @@ class LocalLog(@volatile private var _dir: File,
throw new OffsetOutOfRangeException(s
junrao commented on code in PR #15825:
URL: https://github.com/apache/kafka/pull/15825#discussion_r1608984545
##
core/src/main/scala/kafka/log/LocalLog.scala:
##
@@ -370,11 +370,17 @@ class LocalLog(@volatile private var _dir: File,
throw new OffsetOutOfRangeException(s
[
https://issues.apache.org/jira/browse/KAFKA-16779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17847997#comment-17847997
]
Nicholas Feinberg edited comment on KAFKA-16779 at 5/21/24 9:41 PM:
--
gharris1727 commented on code in PR #15910:
URL: https://github.com/apache/kafka/pull/15910#discussion_r1608965614
##
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/OffsetSyncStoreTest.java:
##
@@ -82,77 +86,131 @@ public void testOffsetTranslation() {
@Test
gharris1727 commented on code in PR #15910:
URL: https://github.com/apache/kafka/pull/15910#discussion_r1608959573
##
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/OffsetSyncStoreTest.java:
##
@@ -82,77 +86,131 @@ public void testOffsetTranslation() {
@Test
ableegoldman commented on code in PR #16024:
URL: https://github.com/apache/kafka/pull/16024#discussion_r1608950503
##
streams/src/main/java/org/apache/kafka/streams/processor/assignment/TopicPartitionAssignmentInfo.java:
##
@@ -0,0 +1,45 @@
+package org.apache.kafka.streams.pro
gharris1727 opened a new pull request, #16025:
URL: https://github.com/apache/kafka/pull/16025
Until now, javadoc warnings can be added in PRs, and are only noticed when
someone else runs `./gradlew javadoc`. Now introducing problems in javadocs
will immediately fail the PR CI build, notify
gharris1727 merged PR #15940:
URL: https://github.com/apache/kafka/pull/15940
--
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.apa
gharris1727 commented on PR #15940:
URL: https://github.com/apache/kafka/pull/15940#issuecomment-2123422940
Build passes, CI test failures appear unrelated, and this passes for me
locally.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log o
kirktrue commented on code in PR #15640:
URL: https://github.com/apache/kafka/pull/15640#discussion_r1608934073
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/ConsumerNetworkThreadTest.java:
##
@@ -281,64 +276,15 @@ void testEnsureMetadataUpdateOnPoll() {
[
https://issues.apache.org/jira/browse/KAFKA-16558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Brenden DeLuna reassigned KAFKA-16558:
--
Assignee: Brenden DeLuna (was: Kirk True)
> Implement HeartbeatRequestState.toString
[
https://issues.apache.org/jira/browse/KAFKA-16557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Brenden DeLuna reassigned KAFKA-16557:
--
Assignee: Brenden DeLuna (was: Kirk True)
> Fix OffsetFetchRequestState.toString()
>
[
https://issues.apache.org/jira/browse/KAFKA-16000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Brenden DeLuna reassigned KAFKA-16000:
--
Assignee: Brenden DeLuna (was: Kirk True)
> Migrate MembershipManagerImplTest away f
[
https://issues.apache.org/jira/browse/KAFKA-15999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Brenden DeLuna reassigned KAFKA-15999:
--
Assignee: Brenden DeLuna (was: Kirk True)
> Migrate HeartbeatRequestManagerTest away
[
https://issues.apache.org/jira/browse/KAFKA-16001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Brenden DeLuna reassigned KAFKA-16001:
--
Assignee: Brenden DeLuna
> Migrate ConsumerNetworkThreadTest away from ConsumerTestBu
[
https://issues.apache.org/jira/browse/KAFKA-16001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Philip Nee updated KAFKA-16001:
---
Description:
We should:
# Remove spy calls to the dependencies
# Remove ConsumerNetworkThreadTest
apourchet commented on code in PR #16024:
URL: https://github.com/apache/kafka/pull/16024#discussion_r1608924234
##
streams/src/main/java/org/apache/kafka/streams/processor/assignment/TopicPartitionAssignmentInfo.java:
##
@@ -0,0 +1,45 @@
+package org.apache.kafka.streams.proces
cmccabe commented on code in PR #16006:
URL: https://github.com/apache/kafka/pull/16006#discussion_r1608921813
##
core/src/main/scala/kafka/server/metadata/ZkMetadataCache.scala:
##
@@ -350,11 +347,7 @@ class ZkMetadataCache(
override def getAliveBrokerNode(brokerId: Int, l
apourchet commented on code in PR #16024:
URL: https://github.com/apache/kafka/pull/16024#discussion_r1608918902
##
streams/src/main/java/org/apache/kafka/streams/processor/assignment/TopicPartitionAssignmentInfo.java:
##
@@ -0,0 +1,45 @@
+package org.apache.kafka.streams.proces
cmccabe commented on PR #16008:
URL: https://github.com/apache/kafka/pull/16008#issuecomment-2123394515
> Are there any tests that we should add or do the existing test cover this
functionality?
I think there are some that cover it already, but I added a test of
controller failover i
ableegoldman commented on code in PR #16024:
URL: https://github.com/apache/kafka/pull/16024#discussion_r1608917448
##
streams/src/main/java/org/apache/kafka/streams/processor/assignment/TopicPartitionAssignmentInfo.java:
##
@@ -0,0 +1,61 @@
+/*
+ * Licensed to the Apache Softwa
ableegoldman commented on code in PR #16024:
URL: https://github.com/apache/kafka/pull/16024#discussion_r1608911390
##
streams/src/main/java/org/apache/kafka/streams/processor/assignment/TopicPartitionAssignmentInfo.java:
##
@@ -0,0 +1,45 @@
+package org.apache.kafka.streams.pro
lianetm commented on code in PR #15640:
URL: https://github.com/apache/kafka/pull/15640#discussion_r1608897877
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/ConsumerNetworkThreadTest.java:
##
@@ -281,64 +276,15 @@ void testEnsureMetadataUpdateOnPoll() {
lianetm commented on code in PR #15640:
URL: https://github.com/apache/kafka/pull/15640#discussion_r1608897877
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/ConsumerNetworkThreadTest.java:
##
@@ -281,64 +276,15 @@ void testEnsureMetadataUpdateOnPoll() {
dongnuo123 commented on code in PR #15988:
URL: https://github.com/apache/kafka/pull/15988#discussion_r1608908254
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java:
##
@@ -4209,31 +4241,67 @@ private void removePendingSyncMember(
edoardocomar commented on code in PR #15910:
URL: https://github.com/apache/kafka/pull/15910#discussion_r1608907673
##
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/OffsetSyncStoreTest.java:
##
@@ -82,77 +86,131 @@ public void testOffsetTranslation() {
@Tes
cmccabe commented on code in PR #16008:
URL: https://github.com/apache/kafka/pull/16008#discussion_r1608907374
##
core/src/main/scala/kafka/raft/RaftManager.scala:
##
@@ -313,4 +314,8 @@ class KafkaRaftManager[T](
override def leaderAndEpoch: LeaderAndEpoch = {
client.le
dongnuo123 commented on code in PR #15988:
URL: https://github.com/apache/kafka/pull/15988#discussion_r1608907132
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java:
##
@@ -4274,6 +4342,77 @@ private void validateClassicGroupHeartbeat
edoardocomar commented on code in PR #15910:
URL: https://github.com/apache/kafka/pull/15910#discussion_r1608896699
##
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/OffsetSyncStoreTest.java:
##
@@ -82,77 +86,131 @@ public void testOffsetTranslation() {
@Tes
cmccabe commented on code in PR #16008:
URL: https://github.com/apache/kafka/pull/16008#discussion_r1608906143
##
raft/src/main/java/org/apache/kafka/raft/internals/VoterSet.java:
##
@@ -366,4 +368,16 @@ public static VoterSet fromInetSocketAddresses(String
listener, Map idToNo
cmccabe commented on code in PR #16008:
URL: https://github.com/apache/kafka/pull/16008#discussion_r1608904666
##
raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java:
##
@@ -2548,6 +2549,10 @@ public OptionalLong highWatermark() {
}
}
+public Option
jsancio commented on code in PR #16006:
URL: https://github.com/apache/kafka/pull/16006#discussion_r1608902290
##
core/src/main/scala/kafka/server/metadata/ZkMetadataCache.scala:
##
@@ -350,11 +347,7 @@ class ZkMetadataCache(
override def getAliveBrokerNode(brokerId: Int, l
ableegoldman merged PR #16002:
URL: https://github.com/apache/kafka/pull/16002
--
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.ap
ableegoldman commented on PR #16002:
URL: https://github.com/apache/kafka/pull/16002#issuecomment-2123367972
Test failures are unrelated, merging to trunk
Worth noting that the
`org.apache.kafka.streams.processor.internals.assignment.TaskAssignorConvergenceTest`
did fail, which may s
jsancio commented on code in PR #16008:
URL: https://github.com/apache/kafka/pull/16008#discussion_r1608891761
##
raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java:
##
@@ -2548,6 +2549,10 @@ public OptionalLong highWatermark() {
}
}
+public Option
lianetm commented on code in PR #15640:
URL: https://github.com/apache/kafka/pull/15640#discussion_r1608897877
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/ConsumerNetworkThreadTest.java:
##
@@ -281,64 +276,15 @@ void testEnsureMetadataUpdateOnPoll() {
lianetm commented on code in PR #15640:
URL: https://github.com/apache/kafka/pull/15640#discussion_r1608897877
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/ConsumerNetworkThreadTest.java:
##
@@ -281,64 +276,15 @@ void testEnsureMetadataUpdateOnPoll() {
lianetm commented on code in PR #15640:
URL: https://github.com/apache/kafka/pull/15640#discussion_r1608897877
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/ConsumerNetworkThreadTest.java:
##
@@ -281,64 +276,15 @@ void testEnsureMetadataUpdateOnPoll() {
edoardocomar commented on code in PR #15910:
URL: https://github.com/apache/kafka/pull/15910#discussion_r1608896699
##
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/OffsetSyncStoreTest.java:
##
@@ -82,77 +86,131 @@ public void testOffsetTranslation() {
@Tes
Greg Harris created KAFKA-16809:
---
Summary: Run javadoc build in CI
Key: KAFKA-16809
URL: https://issues.apache.org/jira/browse/KAFKA-16809
Project: Kafka
Issue Type: Task
Components:
kirktrue commented on code in PR #15640:
URL: https://github.com/apache/kafka/pull/15640#discussion_r1608875582
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumerTest.java:
##
@@ -329,6 +334,17 @@ public void testCommitAsyncWithFencedExceptio
lianetm commented on code in PR #15640:
URL: https://github.com/apache/kafka/pull/15640#discussion_r1608870767
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumerTest.java:
##
@@ -329,6 +334,17 @@ public void testCommitAsyncWithFencedException
AndrewJSchofield commented on PR #16022:
URL: https://github.com/apache/kafka/pull/16022#issuecomment-2123317868
Yes, we will wait until we cut the 3.8 branch before merging.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
[
https://issues.apache.org/jira/browse/KAFKA-16586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17848363#comment-17848363
]
A. Sophie Blee-Goldman commented on KAFKA-16586:
By the way – if this te
[
https://issues.apache.org/jira/browse/KAFKA-16586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17848358#comment-17848358
]
A. Sophie Blee-Goldman commented on KAFKA-16586:
Note: when reporting an
cmccabe commented on PR #16008:
URL: https://github.com/apache/kafka/pull/16008#issuecomment-2123296527
I have re-run all the test failures locally, and they all passed (they were
flakes)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
wcarlson5 merged PR #15564:
URL: https://github.com/apache/kafka/pull/15564
--
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.apach
rreddy-22 commented on code in PR #15974:
URL: https://github.com/apache/kafka/pull/15974#discussion_r1608849959
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/consumer/ConsumerGroup.java:
##
@@ -516,16 +522,78 @@ public Assignment targetAssignment(String
wcarlson5 commented on PR #15564:
URL: https://github.com/apache/kafka/pull/15564#issuecomment-2123293255
The failing tests are not related.
--
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
rreddy-22 commented on code in PR #15974:
URL: https://github.com/apache/kafka/pull/15974#discussion_r1608849959
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/consumer/ConsumerGroup.java:
##
@@ -516,16 +522,78 @@ public Assignment targetAssignment(String
[
https://issues.apache.org/jira/browse/KAFKA-16586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17848351#comment-17848351
]
A. Sophie Blee-Goldman commented on KAFKA-16586:
Failed again:
{code:
[
https://issues.apache.org/jira/browse/KAFKA-14517?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17848348#comment-17848348
]
Lianet Magrans commented on KAFKA-14517:
Sure, I'll assign it to me then. Thanks
[
https://issues.apache.org/jira/browse/KAFKA-14517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans reassigned KAFKA-14517:
--
Assignee: Lianet Magrans (was: Phuc Hong Tran)
> Implement regex subscriptions
> ---
1 - 100 of 271 matches
Mail list logo
