cadonna opened a new pull request, #15867:
URL: https://github.com/apache/kafka/pull/15867
Uses the new remove operation of the state updater that returns a future to
remove lost tasks from the state udpater.
*More detailed description of your change,
if necessary. The PR title an
chia7712 commented on code in PR #15715:
URL: https://github.com/apache/kafka/pull/15715#discussion_r1590605162
##
core/src/test/java/kafka/test/junit/ClusterTestExtensions.java:
##
@@ -143,11 +143,12 @@ private void processClusterTest(ExtensionContext context,
ClusterTest anno
chia7712 commented on PR #15823:
URL: https://github.com/apache/kafka/pull/15823#issuecomment-2095332052
```
./gradlew cleanTest :tools:test --tests
MetadataQuorumCommandTest.testDescribeQuorumReplicationSuccessful :storage:test
--tests TransactionsWithTieredStoreTest.testFailureToFenceE
chia7712 merged PR #15823:
URL: https://github.com/apache/kafka/pull/15823
--
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
Chia-Ping Tsai created KAFKA-16671:
--
Summary: Revisit
SessionedProtocolIntegrationTest.ensureInternalEndpointIsSecured
Key: KAFKA-16671
URL: https://issues.apache.org/jira/browse/KAFKA-16671
Project:
FrankYang0529 opened a new pull request, #15868:
URL: https://github.com/apache/kafka/pull/15868
*More detailed description of your change,
if necessary. The PR title and PR message become
the squashed commit message, so use a separate
comment to ping reviewers.*
*Summary of t
nizhikov commented on PR #15850:
URL: https://github.com/apache/kafka/pull/15850#issuecomment-2095407751
CI looks OK
@chia7712 Do you have any other comments?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
Chia-Ping Tsai created KAFKA-16672:
--
Summary: Fix flaky
DedicatedMirrorIntegrationTest.testMultiNodeCluster
Key: KAFKA-16672
URL: https://issues.apache.org/jira/browse/KAFKA-16672
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-16672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai updated KAFKA-16672:
---
Description:
It is flaky on my jenkins, and sometimes it fails in Kafka CI[0]
The error hap
chia7712 commented on code in PR #15850:
URL: https://github.com/apache/kafka/pull/15850#discussion_r1590709330
##
core/src/test/java/kafka/admin/ConfigCommandUnitTest.java:
##
@@ -0,0 +1,421 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contr
Phuc-Hong-Tran opened a new pull request, #15869:
URL: https://github.com/apache/kafka/pull/15869
*Added `mirroredMetadataUpdateVersion` field to AsyncKafkaConsumer to act as
reference to check whether metadata has been updated or not.
--
This is an automated message from the Apache G
nizhikov commented on code in PR #15850:
URL: https://github.com/apache/kafka/pull/15850#discussion_r1590734676
##
core/src/test/java/kafka/admin/ConfigCommandUnitTest.java:
##
@@ -0,0 +1,421 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contr
nizhikov commented on code in PR #15850:
URL: https://github.com/apache/kafka/pull/15850#discussion_r1590734676
##
core/src/test/java/kafka/admin/ConfigCommandUnitTest.java:
##
@@ -0,0 +1,421 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contr
kamalcph commented on code in PR #15690:
URL: https://github.com/apache/kafka/pull/15690#discussion_r1590749298
##
storage/src/test/java/org/apache/kafka/tiered/storage/utils/TieredStorageTestUtils.java:
##
@@ -55,7 +57,7 @@ public class TieredStorageTestUtils {
// Log cl
lucasbru commented on code in PR #15852:
URL: https://github.com/apache/kafka/pull/15852#discussion_r1590751522
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateUpdater.java:
##
@@ -103,6 +149,17 @@ public String toString() {
*/
void remove(f
lucasbru commented on code in PR #15852:
URL: https://github.com/apache/kafka/pull/15852#discussion_r1590752878
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/DefaultStateUpdater.java:
##
@@ -506,16 +506,14 @@ private void addTask(final Task task) {
cadonna commented on code in PR #15852:
URL: https://github.com/apache/kafka/pull/15852#discussion_r1590755586
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/DefaultStateUpdater.java:
##
@@ -506,16 +506,14 @@ private void addTask(final Task task) {
cadonna merged PR #15852:
URL: https://github.com/apache/kafka/pull/15852
--
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.
kamalcph commented on code in PR #15690:
URL: https://github.com/apache/kafka/pull/15690#discussion_r1590762158
##
storage/src/test/java/org/apache/kafka/tiered/storage/integration/AlterLogDirTest.java:
##
@@ -0,0 +1,73 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
kamalcph commented on code in PR #15690:
URL: https://github.com/apache/kafka/pull/15690#discussion_r1590764089
##
storage/src/test/java/org/apache/kafka/tiered/storage/utils/TieredStorageTestUtils.java:
##
@@ -55,7 +57,7 @@ public class TieredStorageTestUtils {
// Log cl
cadonna opened a new pull request, #15870:
URL: https://github.com/apache/kafka/pull/15870
Uses the new remove operation of the state updater that returns a future to
remove lost tasks from the state udpater.
### Committer Checklist (excluded from commit message)
- [ ] Verify desig
kamalcph commented on code in PR #15690:
URL: https://github.com/apache/kafka/pull/15690#discussion_r1590764089
##
storage/src/test/java/org/apache/kafka/tiered/storage/utils/TieredStorageTestUtils.java:
##
@@ -55,7 +57,7 @@ public class TieredStorageTestUtils {
// Log cl
kamalcph commented on code in PR #15690:
URL: https://github.com/apache/kafka/pull/15690#discussion_r1590764089
##
storage/src/test/java/org/apache/kafka/tiered/storage/utils/TieredStorageTestUtils.java:
##
@@ -55,7 +57,7 @@ public class TieredStorageTestUtils {
// Log cl
cadonna opened a new pull request, #15871:
URL: https://github.com/apache/kafka/pull/15871
Uses the new remove operation of the state updater that returns
a future to remove revoked tasks from the state udpater.
### Committer Checklist (excluded from commit message)
- [ ] Verify
cadonna closed pull request #15867: KAFKA-10199: Remove lost tasks in state
updater with new remove
URL: https://github.com/apache/kafka/pull/15867
--
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 th
chia7712 commented on code in PR #15850:
URL: https://github.com/apache/kafka/pull/15850#discussion_r1590791878
##
core/src/test/java/kafka/admin/ConfigCommandUnitTest.java:
##
@@ -0,0 +1,421 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contr
chia7712 commented on PR #15868:
URL: https://github.com/apache/kafka/pull/15868#issuecomment-2095618948
@FrankYang0529 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
nizhikov commented on code in PR #15850:
URL: https://github.com/apache/kafka/pull/15850#discussion_r1590805333
##
core/src/test/java/kafka/admin/ConfigCommandUnitTest.java:
##
@@ -0,0 +1,421 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contr
FrankYang0529 opened a new pull request, #15872:
URL: https://github.com/apache/kafka/pull/15872
Ref: https://github.com/apache/kafka/pull/15766#discussion_r1585460093
Add ZK mode with classic consumer back to
DeleteOffsetsConsumerGroupCommandIntegrationTest.
### Committer Chec
chia7712 merged PR #15850:
URL: https://github.com/apache/kafka/pull/15850
--
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
satishd commented on code in PR #15690:
URL: https://github.com/apache/kafka/pull/15690#discussion_r1590586656
##
storage/src/test/java/org/apache/kafka/tiered/storage/utils/TieredStorageTestUtils.java:
##
@@ -55,7 +57,7 @@ public class TieredStorageTestUtils {
// Log cle
satishd commented on code in PR #15690:
URL: https://github.com/apache/kafka/pull/15690#discussion_r1590586656
##
storage/src/test/java/org/apache/kafka/tiered/storage/utils/TieredStorageTestUtils.java:
##
@@ -55,7 +57,7 @@ public class TieredStorageTestUtils {
// Log cle
jsto commented on PR #7121:
URL: https://github.com/apache/kafka/pull/7121#issuecomment-2095734292
Hello. We are also being flagged with metrics-core EOL. Do we have any
update on this task?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
chia7712 commented on PR #15872:
URL: https://github.com/apache/kafka/pull/15872#issuecomment-2095735857
Maybe we should merge `DeleteOffsetsConsumerGroupCommandIntegrationTest` and
`DeleteConsumerGroupsTest`. They are used to test delete-related commands.
--
This is an automated message
chia7712 commented on code in PR #15872:
URL: https://github.com/apache/kafka/pull/15872#discussion_r1590841207
##
tools/src/test/java/org/apache/kafka/tools/consumer/group/DeleteOffsetsConsumerGroupCommandIntegrationTest.java:
##
@@ -88,7 +113,7 @@ public void testDeleteOffsets
chia7712 merged PR #15571:
URL: https://github.com/apache/kafka/pull/15571
--
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-16393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai resolved KAFKA-16393.
Fix Version/s: 3.8.0
Resolution: Fixed
> SslTransportLayer doesn't implement write(
nizhikov opened a new pull request, #15873:
URL: https://github.com/apache/kafka/pull/15873
*More detailed description of your change,
if necessary. The PR title and PR message become
the squashed commit message, so use a separate
comment to ping reviewers.*
*Summary of testin
chia7712 commented on code in PR #15766:
URL: https://github.com/apache/kafka/pull/15766#discussion_r1590911279
##
core/src/test/java/kafka/test/ClusterTestExtensionsTest.java:
##
@@ -108,12 +117,12 @@ public void testClusterTests() {
}
@ClusterTests({
-@Clus
dajac merged PR #15854:
URL: https://github.com/apache/kafka/pull/15854
--
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
johnnychhsu commented on code in PR #15861:
URL: https://github.com/apache/kafka/pull/15861#discussion_r1590940053
##
core/src/test/java/kafka/test/ClusterConfig.java:
##
@@ -83,6 +81,7 @@ private ClusterConfig(Type type, int brokers, int
controllers, int disksPerBroke
johnnychhsu commented on code in PR #15861:
URL: https://github.com/apache/kafka/pull/15861#discussion_r1590943709
##
core/src/test/java/kafka/test/annotation/ClusterTest.java:
##
@@ -44,4 +44,5 @@
String listener() default "";
MetadataVersion metadataVersion() default
lucasbru opened a new pull request, #15874:
URL: https://github.com/apache/kafka/pull/15874
In two streams tests, we are using the current snapshot version as a test
parameter `to_version`, but as the only option. We can hardcode it. This
simplifies testing downstream, since the test parame
yuz10 opened a new pull request, #15875:
URL: https://github.com/apache/kafka/pull/15875
*More detailed description of your change,
if necessary. The PR title and PR message become
the squashed commit message, so use a separate
comment to ping reviewers.*
*Summary of testing s
mannoopj commented on PR #15876:
URL: https://github.com/apache/kafka/pull/15876#issuecomment-2096008537
WIP
--
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,
dajac commented on code in PR #15798:
URL: https://github.com/apache/kafka/pull/15798#discussion_r1590935155
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/consumer/CurrentAssignmentBuilder.java:
##
@@ -203,6 +189,22 @@ public ConsumerGroupMember build() {
johnnychhsu commented on PR #15861:
URL: https://github.com/apache/kafka/pull/15861#issuecomment-2096037200
updated and `./gradlew clean core:test --tests ClusterTestExtensionsTest
--tests ClusterConfigTest` passed
--
This is an automated message from the Apache Git Service.
To respond to
lianetm commented on code in PR #15844:
URL: https://github.com/apache/kafka/pull/15844#discussion_r1591065112
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/CommitRequestManager.java:
##
@@ -1145,14 +1141,42 @@ private CompletableFuture> addOffsetFetch
Dongnuo Lyu created KAFKA-16673:
---
Summary: Optimize toTopicPartitions with
ConsumerProtocolSubscription
Key: KAFKA-16673
URL: https://issues.apache.org/jira/browse/KAFKA-16673
Project: Kafka
I
lianetm commented on PR #15844:
URL: https://github.com/apache/kafka/pull/15844#issuecomment-2096155474
One concern on
[comment](https://github.com/apache/kafka/pull/15844#discussion_r1591065112)
above about how we identify this situation (inflight fetch requests that we
shouldn't delete t
Dongnuo Lyu created KAFKA-16674:
---
Summary: Adjust classicGroupJoinToConsumerGroup to add
subscription model
Key: KAFKA-16674
URL: https://issues.apache.org/jira/browse/KAFKA-16674
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-16674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dongnuo Lyu reassigned KAFKA-16674:
---
Assignee: Dongnuo Lyu
> Adjust classicGroupJoinToConsumerGroup to add subscription model
>
[
https://issues.apache.org/jira/browse/KAFKA-16673?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dongnuo Lyu reassigned KAFKA-16673:
---
Assignee: Dongnuo Lyu
> Optimize toTopicPartitions with ConsumerProtocolSubscription
>
mannoopj commented on PR #15876:
URL: https://github.com/apache/kafka/pull/15876#issuecomment-2096185204
WIP
--
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,
nizhikov commented on PR #15873:
URL: https://github.com/apache/kafka/pull/15873#issuecomment-2096190310
Hello @chia7712
Second part of `ConfigCommandTest` refactoring ready for review.
Please, take a look.
--
This is an automated message from the Apache Git Service.
To respond
mumrah commented on code in PR #15744:
URL: https://github.com/apache/kafka/pull/15744#discussion_r1591110984
##
core/src/test/scala/integration/kafka/zk/ZkMigrationIntegrationTest.scala:
##
@@ -1037,24 +1104,35 @@ class ZkMigrationIntegrationTest {
admin.alterUserScramCred
ashmeet13 commented on PR #12988:
URL: https://github.com/apache/kafka/pull/12988#issuecomment-2096203457
Fixing the failing build
--
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
omkreddy merged PR #15831:
URL: https://github.com/apache/kafka/pull/15831
--
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
lucasbru commented on code in PR #15870:
URL: https://github.com/apache/kafka/pull/15870#discussion_r1591121181
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java:
##
@@ -602,6 +608,47 @@ private void removeUnusedTaskFromStateUpdater(final Tas
mimaison opened a new pull request, #15877:
URL: https://github.com/apache/kafka/pull/15877
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including upgr
mumrah commented on code in PR #15744:
URL: https://github.com/apache/kafka/pull/15744#discussion_r1591129328
##
core/src/main/scala/kafka/zk/KafkaZkClient.scala:
##
@@ -467,13 +474,48 @@ class KafkaZkClient private[zk] (zooKeeperClient:
ZooKeeperClient, isSecure: Boo
* @pa
mumrah commented on code in PR #15744:
URL: https://github.com/apache/kafka/pull/15744#discussion_r1591129328
##
core/src/main/scala/kafka/zk/KafkaZkClient.scala:
##
@@ -467,13 +474,48 @@ class KafkaZkClient private[zk] (zooKeeperClient:
ZooKeeperClient, isSecure: Boo
* @pa
lianetm commented on PR #15844:
URL: https://github.com/apache/kafka/pull/15844#issuecomment-2096232639
Did we consider the approach of simply decoupling the request timeout from
the application event timeout? We could issue the fetch request without a time
boundary (max value probably), an
lucasbru commented on PR #15856:
URL: https://github.com/apache/kafka/pull/15856#issuecomment-2096266336
@lianetm some conflicts need to be resolved
--
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 t
Lianet Magrans created KAFKA-16675:
--
Summary: Move rebalance callback test for positions to callbacks
test file
Key: KAFKA-16675
URL: https://issues.apache.org/jira/browse/KAFKA-16675
Project: Kafka
lianetm commented on PR #15856:
URL: https://github.com/apache/kafka/pull/15856#issuecomment-2096322959
Thanks @lucasbru, conflicts solved. Good pointer about the new file for
callback tests, I created https://issues.apache.org/jira/browse/KAFKA-16675
assigned to me to make sure I move the
jeffkbkim commented on code in PR #15835:
URL: https://github.com/apache/kafka/pull/15835#discussion_r1591194245
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/metrics/GroupCoordinatorRuntimeMetrics.java:
##
@@ -208,8 +209,8 @@ public void recordEventQueue
gharris1727 commented on PR #14729:
URL: https://github.com/apache/kafka/pull/14729#issuecomment-2096338791
Hi @C0urante could you take another pass on this?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL abov
cadonna commented on code in PR #15870:
URL: https://github.com/apache/kafka/pull/15870#discussion_r1591198311
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java:
##
@@ -71,6 +73,10 @@
import static
org.apache.kafka.streams.processor.interna
cadonna commented on code in PR #15870:
URL: https://github.com/apache/kafka/pull/15870#discussion_r1591204373
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java:
##
@@ -602,6 +608,47 @@ private void removeUnusedTaskFromStateUpdater(final Task
cadonna commented on code in PR #15870:
URL: https://github.com/apache/kafka/pull/15870#discussion_r1591204696
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java:
##
@@ -602,6 +608,47 @@ private void removeUnusedTaskFromStateUpdater(final Task
gharris1727 commented on code in PR #14309:
URL: https://github.com/apache/kafka/pull/14309#discussion_r1591196797
##
clients/src/main/java/org/apache/kafka/common/utils/Utils.java:
##
@@ -16,6 +16,15 @@
*/
package org.apache.kafka.common.utils;
+import java.lang.reflect.Mo
lucasbru commented on code in PR #15870:
URL: https://github.com/apache/kafka/pull/15870#discussion_r1591216607
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java:
##
@@ -602,6 +608,47 @@ private void removeUnusedTaskFromStateUpdater(final Tas
gaurav-narula commented on PR #15836:
URL: https://github.com/apache/kafka/pull/15836#issuecomment-2096392283
Resolved conflict with `trunk`
--
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 sp
cadonna commented on code in PR #15870:
URL: https://github.com/apache/kafka/pull/15870#discussion_r1591223152
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java:
##
@@ -602,6 +608,47 @@ private void removeUnusedTaskFromStateUpdater(final Task
mumrah commented on PR #15744:
URL: https://github.com/apache/kafka/pull/15744#issuecomment-2096415182
Thanks for continued reviews @chia7712 đ, I've addressed your latest
feedback.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to G
[
https://issues.apache.org/jira/browse/KAFKA-16619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Arthur updated KAFKA-16619:
-
Labels: good-first-issue (was: )
> Unnecessary controller warning : "Loaded ZK migration state
cadonna commented on code in PR #15870:
URL: https://github.com/apache/kafka/pull/15870#discussion_r1591261680
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java:
##
@@ -602,6 +608,47 @@ private void removeUnusedTaskFromStateUpdater(final Task
cadonna commented on code in PR #15870:
URL: https://github.com/apache/kafka/pull/15870#discussion_r1591262531
##
streams/src/test/java/org/apache/kafka/streams/processor/internals/TaskManagerTest.java:
##
@@ -1421,15 +1422,20 @@ public void
shouldRemoveAllActiveTasksFromStateU
cadonna commented on code in PR #15870:
URL: https://github.com/apache/kafka/pull/15870#discussion_r1591277510
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java:
##
@@ -602,6 +608,47 @@ private void removeUnusedTaskFromStateUpdater(final Task
gharris1727 commented on code in PR #15305:
URL: https://github.com/apache/kafka/pull/15305#discussion_r1591278453
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/WorkerCoordinator.java:
##
@@ -267,6 +267,18 @@ public String memberId() {
re
jeqo commented on code in PR #15379:
URL: https://github.com/apache/kafka/pull/15379#discussion_r1591285305
##
connect/transforms/src/test/java/org/apache/kafka/connect/transforms/field/SingleFieldPathTest.java:
##
@@ -0,0 +1,113 @@
+/*
+ * Licensed to the Apache Software Founda
jeqo commented on PR #15379:
URL: https://github.com/apache/kafka/pull/15379#issuecomment-2096481453
Thanks @C0urante! I've applied most suggestions, PTAL
--
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 t
lianetm commented on code in PR #15408:
URL: https://github.com/apache/kafka/pull/15408#discussion_r1591300734
##
core/src/test/scala/integration/kafka/api/PlaintextConsumerCallbackTest.scala:
##
@@ -0,0 +1,138 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under o
jsancio commented on code in PR #15859:
URL: https://github.com/apache/kafka/pull/15859#discussion_r1591319255
##
raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java:
##
@@ -1700,16 +1710,16 @@ private void handleResponse(RaftResponse.Inbound
response, long currentTim
lianetm commented on code in PR #15408:
URL: https://github.com/apache/kafka/pull/15408#discussion_r1591377060
##
core/src/test/scala/integration/kafka/api/PlaintextConsumerCallbackTest.scala:
##
@@ -0,0 +1,138 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under o
lianetm commented on code in PR #15408:
URL: https://github.com/apache/kafka/pull/15408#discussion_r1591377324
##
core/src/test/scala/integration/kafka/api/PlaintextConsumerCallbackTest.scala:
##
@@ -0,0 +1,138 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under o
Andrew Schofield created KAFKA-16676:
Summary: Security docs missing RPCs from KIP-714 and KIP-1000
Key: KAFKA-16676
URL: https://issues.apache.org/jira/browse/KAFKA-16676
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-16530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
JosĂ© Armando GarcĂa Sancio updated KAFKA-16530:
---
Summary: Fix high-watermark calculation to not assume the leader is i
[
https://issues.apache.org/jira/browse/KAFKA-16531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
JosĂ© Armando GarcĂa Sancio updated KAFKA-16531:
---
Summary: Fix check-quorum calculation to not assume that the leader i
[
https://issues.apache.org/jira/browse/KAFKA-14237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17843869#comment-17843869
]
Gaurav Narula commented on KAFKA-14237:
---
Hi [~soxcks]Â
I'm unable to reproduce th
mumrah commented on PR #15744:
URL: https://github.com/apache/kafka/pull/15744#issuecomment-2096872249
[Latest test
run](https://ci-builds.apache.org/blue/organizations/jenkins/Kafka%2Fkafka-pr/detail/PR-15744/13/tests)
looks pretty reasonable. The failures all look unrelated
--
[
https://issues.apache.org/jira/browse/KAFKA-16670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17843887#comment-17843887
]
Lianet Magrans commented on KAFKA-16670:
Hey [~chickenchickenlove], thanks for t
[
https://issues.apache.org/jira/browse/KAFKA-16670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17843887#comment-17843887
]
Lianet Magrans edited comment on KAFKA-16670 at 5/6/24 9:01 PM:
--
linu-shibu commented on PR #15620:
URL: https://github.com/apache/kafka/pull/15620#issuecomment-2096976398
@gharris1727 any update on this?
--
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 spe
junrao commented on code in PR #15671:
URL: https://github.com/apache/kafka/pull/15671#discussion_r1589798416
##
raft/src/main/java/org/apache/kafka/raft/internals/KRaftControlRecordStateMachine.java:
##
@@ -0,0 +1,261 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
gharris1727 commented on code in PR #15469:
URL: https://github.com/apache/kafka/pull/15469#discussion_r1591616004
##
connect/api/src/main/java/org/apache/kafka/connect/data/Values.java:
##
@@ -177,7 +213,12 @@ public static Long convertToLong(Schema schema, Object
value) throw
TaiJuWu commented on code in PR #15862:
URL: https://github.com/apache/kafka/pull/15862#discussion_r1591630803
##
core/src/test/java/kafka/test/junit/ClusterTestExtensionsUnitTest.java:
##
@@ -33,16 +31,22 @@ public class ClusterTestExtensionsUnitTest {
void testProcessClus
gharris1727 commented on code in PR #15469:
URL: https://github.com/apache/kafka/pull/15469#discussion_r1591636980
##
connect/api/src/main/java/org/apache/kafka/connect/data/Values.java:
##
@@ -766,135 +852,23 @@ protected static boolean
canParseSingleTokenLiteral(Parser parser
[
https://issues.apache.org/jira/browse/KAFKA-16670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sanghyeok An updated KAFKA-16670:
-
Attachment: image-2024-05-07-08-34-06-855.png
> KIP-848 : Consumer will not receive assignment f
1 - 100 of 142 matches
Mail list logo
