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
[
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-36-40-656.png
> KIP-848 : Consumer will not receive assignment f
[
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-36-22-983.png
> KIP-848 : Consumer will not receive assignment f
[
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-38-27-753.png
> KIP-848 : Consumer will not receive assignment f
[
https://issues.apache.org/jira/browse/KAFKA-16670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17844063#comment-17844063
]
sanghyeok An commented on KAFKA-16670:
--
Hi, [~lianetm]! thanks for your comments. y
gharris1727 merged PR #15620:
URL: https://github.com/apache/kafka/pull/15620
--
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 #15620:
URL: https://github.com/apache/kafka/pull/15620#issuecomment-2097110125
Thanks @linu-shibu for your patience, I was waiting for something else.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHu
[
https://issues.apache.org/jira/browse/KAFKA-16356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Harris resolved KAFKA-16356.
-
Fix Version/s: 3.8.0
Resolution: Fixed
> Remove class-name dispatch in RemoteLogMetadataS
gharris1727 commented on code in PR #15469:
URL: https://github.com/apache/kafka/pull/15469#discussion_r1591671051
##
connect/api/src/main/java/org/apache/kafka/connect/data/Values.java:
##
@@ -766,135 +852,23 @@ protected static boolean
canParseSingleTokenLiteral(Parser parser
chia7712 merged PR #15803:
URL: https://github.com/apache/kafka/pull/15803
--
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-16608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai resolved KAFKA-16608.
Fix Version/s: 3.8.0
Resolution: Fixed
> AsyncKafkaConsumer doesn't honor interrupt
m1a2st commented on PR #15840:
URL: https://github.com/apache/kafka/pull/15840#issuecomment-2097142502
Because Old Test Only have tests with Zookeeper, thus I change old test for
Zookeeper and Kraft, and add new tests for KRaft, I mainly test the the config
update mode for configs
--
Thi
m1a2st commented on PR #15840:
URL: https://github.com/apache/kafka/pull/15840#issuecomment-2097144066
Hello @chia7712 please review, Thank you
--
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
chia7712 merged PR #15744:
URL: https://github.com/apache/kafka/pull/15744
--
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
1 - 100 of 142 matches
Mail list logo
