[
https://issues.apache.org/jira/browse/KAFKA-7281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864028#comment-17864028
]
Ksolves commented on KAFKA-7281:
The behavior of the cleanup.policy parameter is inconsis
[
https://issues.apache.org/jira/browse/KAFKA-16355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ksolves reassigned KAFKA-16355:
---
Assignee: Ksolves
> ConcurrentModificationException in
> InMemoryTimeOrderedKeyValueBuffer.evictWh
[
https://issues.apache.org/jira/browse/KAFKA-7281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ksolves updated KAFKA-7281:
---
Attachment: topic-cleanup-policy.png
> Fix documentation and error message regarding cleanup.policy=[compact,
chirag-wadhwa5 commented on code in PR #16456:
URL: https://github.com/apache/kafka/pull/16456#discussion_r1669817534
##
core/src/main/scala/kafka/server/KafkaApis.scala:
##
@@ -4004,6 +4471,99 @@ class KafkaApis(val requestChannel: RequestChannel,
CompletableFuture.complet
chirag-wadhwa5 commented on code in PR #16456:
URL: https://github.com/apache/kafka/pull/16456#discussion_r1669815168
##
core/src/test/scala/unit/kafka/server/KafkaApisTest.scala:
##
@@ -4390,6 +4401,2215 @@ class KafkaApisTest extends Logging {
assertEquals("broker2", node
[
https://issues.apache.org/jira/browse/KAFKA-17071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Abhinav Dixit resolved KAFKA-17071.
---
Fix Version/s: 4.0.0
3.9.0
Resolution: Fixed
> SharePartition - Ad
omkreddy merged PR #16530:
URL: https://github.com/apache/kafka/pull/16530
--
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
showuon commented on code in PR #16132:
URL: https://github.com/apache/kafka/pull/16132#discussion_r1669550818
##
metadata/src/main/java/org/apache/kafka/metadata/KafkaConfigSchema.java:
##
@@ -166,9 +166,11 @@ public Map
resolveEffectiveTopicConfigs(
ConfigDef configD
chirag-wadhwa5 commented on code in PR #16456:
URL: https://github.com/apache/kafka/pull/16456#discussion_r1669768302
##
core/src/test/scala/unit/kafka/server/KafkaApisTest.scala:
##
@@ -4390,6 +4401,2215 @@ class KafkaApisTest extends Logging {
assertEquals("broker2", node
mjsax commented on PR #16509:
URL: https://github.com/apache/kafka/pull/16509#issuecomment-2216578847
@dujian0068 -- you should send a final email to the VOTE thread calling the
vote closed and accepted (also summarizing the vote result), and update the KIP
wiki pages accordingly. Thanks.
mjsax commented on PR #16509:
URL: https://github.com/apache/kafka/pull/16509#issuecomment-2216575106
Please don't forget to update the docs (upgrade guide and configs sections).
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
kaushik srinivas created KAFKA-17101:
Summary: Mirror maker internal topics cleanup policy changes to
'delete' from 'compact'
Key: KAFKA-17101
URL: https://issues.apache.org/jira/browse/KAFKA-17101
[
https://issues.apache.org/jira/browse/KAFKA-17098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17863989#comment-17863989
]
Eduwer Camacaro commented on KAFKA-17098:
-
[~mjsax] Yes, I just attached a log f
[
https://issues.apache.org/jira/browse/KAFKA-17098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eduwer Camacaro updated KAFKA-17098:
Attachment: server.log
> Error Opening RocksDBStore
> --
>
>
showuon commented on code in PR #16132:
URL: https://github.com/apache/kafka/pull/16132#discussion_r1669549418
##
clients/src/main/java/org/apache/kafka/common/config/TopicConfig.java:
##
@@ -93,6 +93,17 @@ public class TopicConfig {
"deletes the old segments. Defau
xijiu commented on PR #16549:
URL: https://github.com/apache/kafka/pull/16549#issuecomment-2216139424
> @xijiu, Thanks for your comments, I leaved some comments
@m1a2st
Thanks for your code review. They are all very helpful. I have fixed all of
them, please review again.
--
Th
[
https://issues.apache.org/jira/browse/KAFKA-17100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17863980#comment-17863980
]
kangning.li commented on KAFKA-17100:
-
hi [~gharris1727] , If you are not start work
[
https://issues.apache.org/jira/browse/KAFKA-17096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17863978#comment-17863978
]
xuanzhang gong commented on KAFKA-17096:
hello，i will handle this issue. Please
[
https://issues.apache.org/jira/browse/KAFKA-17097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17863977#comment-17863977
]
PoAn Yang commented on KAFKA-17097:
---
Hi [~gharris1727], I'm interested in this. If you
[
https://issues.apache.org/jira/browse/KAFKA-17098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17863975#comment-17863975
]
Matthias J. Sax commented on KAFKA-17098:
-
[~cadonna] – do you think you recent
ulysses-you commented on code in PR #16497:
URL: https://github.com/apache/kafka/pull/16497#discussion_r1669509734
##
clients/src/test/java/org/apache/kafka/common/requests/ConsumerGroupHeartbeatRequestTest.java:
##
@@ -0,0 +1,51 @@
+/*
+ * Licensed to the Apache Software Founda
brenden20 commented on PR #16200:
URL: https://github.com/apache/kafka/pull/16200#issuecomment-2215943716
@lianetm @philipnee thank you both for the feedback! I have addressed all
comments and left some replies as well, let me know what you think, made some
pretty major improvements over th
brenden20 commented on code in PR #16200:
URL: https://github.com/apache/kafka/pull/16200#discussion_r1669499524
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/HeartbeatRequestManagerTest.java:
##
@@ -251,23 +304,25 @@ public void testSkippingHeartbeat(fina
brenden20 commented on code in PR #16200:
URL: https://github.com/apache/kafka/pull/16200#discussion_r1669499273
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/HeartbeatRequestManagerTest.java:
##
@@ -349,6 +408,10 @@ public void testNoCoordinator() {
brenden20 commented on code in PR #16200:
URL: https://github.com/apache/kafka/pull/16200#discussion_r1669498721
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/HeartbeatRequestManagerTest.java:
##
@@ -898,6 +967,6 @@ private HeartbeatRequestManager
createH
brenden20 commented on code in PR #16200:
URL: https://github.com/apache/kafka/pull/16200#discussion_r1669497625
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/HeartbeatRequestManagerTest.java:
##
@@ -756,18 +846,18 @@ public void
testFencedMemberStopHeart
brenden20 commented on code in PR #16200:
URL: https://github.com/apache/kafka/pull/16200#discussion_r1669495115
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/HeartbeatRequestManagerTest.java:
##
@@ -756,18 +846,18 @@ public void
testFencedMemberStopHeart
m1a2st commented on code in PR #16549:
URL: https://github.com/apache/kafka/pull/16549#discussion_r1669482604
##
clients/src/test/java/org/apache/kafka/common/utils/UtilsTest.java:
##
@@ -448,6 +449,87 @@ public void testMin() {
assertEquals(1, Utils.min(2, 3, 1));
m1a2st commented on code in PR #16532:
URL: https://github.com/apache/kafka/pull/16532#discussion_r1669472238
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/FetcherTest.java:
##
@@ -3665,6 +3670,18 @@ public void
testWhenFetchResponseReturnsALeaderShipChan
m1a2st commented on code in PR #16532:
URL: https://github.com/apache/kafka/pull/16532#discussion_r1669472238
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/FetcherTest.java:
##
@@ -3665,6 +3670,18 @@ public void
testWhenFetchResponseReturnsALeaderShipChan
m1a2st commented on code in PR #16532:
URL: https://github.com/apache/kafka/pull/16532#discussion_r1669467090
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/FetcherTest.java:
##
@@ -3665,6 +3670,18 @@ public void
testWhenFetchResponseReturnsALeaderShipChan
m1a2st commented on code in PR #16532:
URL: https://github.com/apache/kafka/pull/16532#discussion_r1669467090
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/FetcherTest.java:
##
@@ -3665,6 +3670,18 @@ public void
testWhenFetchResponseReturnsALeaderShipChan
brenden20 commented on code in PR #16200:
URL: https://github.com/apache/kafka/pull/16200#discussion_r1669465217
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/HeartbeatRequestManagerTest.java:
##
@@ -312,31 +369,33 @@ public void testHeartbeatOutsideInterv
brenden20 commented on code in PR #16200:
URL: https://github.com/apache/kafka/pull/16200#discussion_r1669460104
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/HeartbeatRequestManagerTest.java:
##
@@ -251,23 +304,25 @@ public void testSkippingHeartbeat(fina
brenden20 commented on code in PR #16200:
URL: https://github.com/apache/kafka/pull/16200#discussion_r1669445851
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/HeartbeatRequestManagerTest.java:
##
@@ -251,23 +304,25 @@ public void testSkippingHeartbeat(fina
brenden20 commented on code in PR #16200:
URL: https://github.com/apache/kafka/pull/16200#discussion_r1669445851
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/HeartbeatRequestManagerTest.java:
##
@@ -251,23 +304,25 @@ public void testSkippingHeartbeat(fina
brenden20 commented on code in PR #16200:
URL: https://github.com/apache/kafka/pull/16200#discussion_r1669428550
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/HeartbeatRequestManagerTest.java:
##
@@ -251,23 +304,25 @@ public void testSkippingHeartbeat(fina
brenden20 commented on code in PR #16200:
URL: https://github.com/apache/kafka/pull/16200#discussion_r1669428550
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/HeartbeatRequestManagerTest.java:
##
@@ -251,23 +304,25 @@ public void testSkippingHeartbeat(fina
[
https://issues.apache.org/jira/browse/KAFKA-17100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Harris updated KAFKA-17100:
Labels: newbie (was: )
> GlobalStreamThread#start should not busy-wait
>
Greg Harris created KAFKA-17100:
---
Summary: GlobalStreamThread#start should not busy-wait
Key: KAFKA-17100
URL: https://issues.apache.org/jira/browse/KAFKA-17100
Project: Kafka
Issue Type: Task
[
https://issues.apache.org/jira/browse/KAFKA-17095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17863953#comment-17863953
]
Greg Harris commented on KAFKA-17095:
-
> I believe the renaming should not break it.
junrao commented on code in PR #16421:
URL: https://github.com/apache/kafka/pull/16421#discussion_r1669372235
##
clients/src/main/java/org/apache/kafka/common/requests/BrokerRegistrationRequest.java:
##
@@ -45,7 +46,21 @@ public short oldestAllowedVersion() {
@Overrid
[
https://issues.apache.org/jira/browse/KAFKA-17099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Loïc Greffier updated KAFKA-17099:
--
Component/s: streams
> Improve the process exception logs with the exact processor node name i
[
https://issues.apache.org/jira/browse/KAFKA-17099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Loïc Greffier updated KAFKA-17099:
--
Summary: Improve the process exception logs with the exact processor node
name in which except
[
https://issues.apache.org/jira/browse/KAFKA-17099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Loïc Greffier updated KAFKA-17099:
--
Summary: Improve the process exception logs with the exact processor node
name in which proces
apoorvmittal10 commented on code in PR #16532:
URL: https://github.com/apache/kafka/pull/16532#discussion_r1669355387
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/FetcherTest.java:
##
@@ -3665,6 +3670,18 @@ public void
testWhenFetchResponseReturnsALeader
[
https://issues.apache.org/jira/browse/KAFKA-17099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Loïc Greffier updated KAFKA-17099:
--
Description:
h2. Current Behaviour
When an exception occurs in a processor node, the task exe
[
https://issues.apache.org/jira/browse/KAFKA-17099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Loïc Greffier updated KAFKA-17099:
--
Summary: Improve the process exception logs with the exact processor node
name in which except
bachmanity1 commented on code in PR #15475:
URL: https://github.com/apache/kafka/pull/15475#discussion_r1669346859
##
clients/src/test/java/org/apache/kafka/common/security/oauthbearer/internals/secured/HttpAccessTokenRetrieverTest.java:
##
@@ -174,33 +176,39 @@ public void test
[
https://issues.apache.org/jira/browse/KAFKA-17099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Loïc Greffier updated KAFKA-17099:
--
Description:
h2. Current Behaviour
When an exception occurs in a processor node, the task e
[
https://issues.apache.org/jira/browse/KAFKA-17099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Loïc Greffier updated KAFKA-17099:
--
Description:
h2. Current Behaviour
When an exception occurs in a processor node, the task exe
[
https://issues.apache.org/jira/browse/KAFKA-17099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Loïc Greffier updated KAFKA-17099:
--
Description:
h3. Current Behaviour
When an exception occurs in a processor node, the task e
Loïc Greffier created KAFKA-17099:
-
Summary: Improve the process exception logs with the exact
processor node where the exception occurs
Key: KAFKA-17099
URL: https://issues.apache.org/jira/browse/KAFKA-17099
bachmanity1 commented on code in PR #15475:
URL: https://github.com/apache/kafka/pull/15475#discussion_r1669337234
##
clients/src/test/java/org/apache/kafka/common/security/oauthbearer/internals/secured/HttpAccessTokenRetrieverTest.java:
##
@@ -174,33 +176,39 @@ public void test
cmccabe commented on code in PR #16230:
URL: https://github.com/apache/kafka/pull/16230#discussion_r1669277905
##
metadata/src/main/java/org/apache/kafka/metadata/bootstrap/BootstrapMetadata.java:
##
@@ -73,6 +80,22 @@ public static Optional
recordToMetadataVersion(ApiMessage r
cmccabe commented on PR #16230:
URL: https://github.com/apache/kafka/pull/16230#issuecomment-2215235517
I have revised this PR. We now get the value of `kraft.version` directly
from the raft layer, and metadata layer does not have anything to do with it.
This requires passing in a callback
cmccabe commented on code in PR #16230:
URL: https://github.com/apache/kafka/pull/16230#discussion_r1669277755
##
metadata/src/main/java/org/apache/kafka/metadata/bootstrap/BootstrapMetadata.java:
##
@@ -116,6 +139,34 @@ public BootstrapMetadata copyWithOnlyVersion() {
jolshan commented on code in PR #16421:
URL: https://github.com/apache/kafka/pull/16421#discussion_r1669262604
##
clients/src/main/java/org/apache/kafka/common/requests/BrokerRegistrationRequest.java:
##
@@ -45,7 +46,21 @@ public short oldestAllowedVersion() {
@Overri
C0urante commented on PR #16551:
URL: https://github.com/apache/kafka/pull/16551#issuecomment-2215205173
The full CI run has not completed yet, but based on logs, all tests have
passed. It may be worth triggering another run once this one completes.
--
This is an automated message from th
[
https://issues.apache.org/jira/browse/KAFKA-17098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eduwer Camacaro updated KAFKA-17098:
Priority: Minor (was: Critical)
> Error Opening RocksDBStore
> --
chia7712 commented on code in PR #16421:
URL: https://github.com/apache/kafka/pull/16421#discussion_r1669192153
##
clients/src/main/java/org/apache/kafka/common/requests/BrokerRegistrationRequest.java:
##
@@ -45,7 +46,21 @@ public short oldestAllowedVersion() {
@Overr
cmccabe commented on code in PR #16230:
URL: https://github.com/apache/kafka/pull/16230#discussion_r1669239654
##
server-common/src/main/java/org/apache/kafka/server/common/KRaftVersion.java:
##
@@ -0,0 +1,81 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
cmccabe commented on code in PR #16230:
URL: https://github.com/apache/kafka/pull/16230#discussion_r1669237196
##
server-common/src/main/java/org/apache/kafka/server/common/Features.java:
##
@@ -40,7 +40,8 @@ public enum Features {
* See {@link TestFeatureVersion} as an ex
cmccabe commented on code in PR #16230:
URL: https://github.com/apache/kafka/pull/16230#discussion_r1669234970
##
raft/src/main/java/org/apache/kafka/snapshot/RecordsSnapshotWriter.java:
##
@@ -146,7 +147,7 @@ final public static class Builder {
private Time time = Time
Eduwer Camacaro created KAFKA-17098:
---
Summary: Error Opening RocksDBStore
Key: KAFKA-17098
URL: https://issues.apache.org/jira/browse/KAFKA-17098
Project: Kafka
Issue Type: Bug
Co
[
https://issues.apache.org/jira/browse/KAFKA-16984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans updated KAFKA-16984:
---
Description:
When the new consumer attempts to leave a group, it sends a leave group request
ahuang98 commented on code in PR #16518:
URL: https://github.com/apache/kafka/pull/16518#discussion_r1669188656
##
raft/src/test/java/org/apache/kafka/raft/KafkaRaftClientReconfigTest.java:
##
@@ -0,0 +1,271 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one o
ahuang98 commented on code in PR #16518:
URL: https://github.com/apache/kafka/pull/16518#discussion_r1669188332
##
raft/src/test/java/org/apache/kafka/raft/KafkaRaftClientReconfigTest.java:
##
@@ -0,0 +1,271 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one o
ahuang98 commented on code in PR #16518:
URL: https://github.com/apache/kafka/pull/16518#discussion_r1669183797
##
raft/src/main/java/org/apache/kafka/raft/internals/VoterSetOffset.java:
##
@@ -0,0 +1,35 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or mo
ahuang98 commented on code in PR #16518:
URL: https://github.com/apache/kafka/pull/16518#discussion_r1669183797
##
raft/src/main/java/org/apache/kafka/raft/internals/VoterSetOffset.java:
##
@@ -0,0 +1,35 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or mo
chia7712 commented on PR #16532:
URL: https://github.com/apache/kafka/pull/16532#issuecomment-2215008466
@apoorvmittal10 you had reviewed on #15966, so could you please take a look
at this PR? thanks!
--
This is an automated message from the Apache Git Service.
To respond to the message,
C0urante commented on code in PR #14372:
URL: https://github.com/apache/kafka/pull/14372#discussion_r1669161112
##
connect/runtime/src/main/java/org/apache/kafka/connect/util/KafkaBasedLog.java:
##
@@ -567,13 +567,12 @@ private class WorkThread extends Thread {
public W
[
https://issues.apache.org/jira/browse/KAFKA-16984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans updated KAFKA-16984:
---
Description:
When the new consumer attempts to leave a group, it sends a leave group request
[
https://issues.apache.org/jira/browse/KAFKA-16984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans updated KAFKA-16984:
---
Description:
When the new consumer attempts to leave a group, it sends a leave group request
mjsax commented on PR #16544:
URL: https://github.com/apache/kafka/pull/16544#issuecomment-2214996644
It seems `ForeachAction` is missing?
Also wondering about `TransformerSupplier` (and siblings) -- are they not
effectively deprecated via
https://cwiki.apache.org/confluence/display/
[
https://issues.apache.org/jira/browse/KAFKA-17095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17863910#comment-17863910
]
Chia-Ping Tsai commented on KAFKA-17095:
[~gharris1727] thanks for response.
{q
cadonna merged PR #16550:
URL: https://github.com/apache/kafka/pull/16550
--
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-16984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans updated KAFKA-16984:
---
Summary: New consumer should not complete leave operation until it gets a
response (was: Ne
brenden20 commented on code in PR #16200:
URL: https://github.com/apache/kafka/pull/16200#discussion_r1669143238
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/HeartbeatRequestManagerTest.java:
##
@@ -106,72 +102,90 @@ public class HeartbeatRequestManagerTe
brenden20 commented on code in PR #16200:
URL: https://github.com/apache/kafka/pull/16200#discussion_r1669139534
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/HeartbeatRequestManagerTest.java:
##
@@ -106,72 +102,90 @@ public class HeartbeatRequestManagerTe
ahuang98 commented on code in PR #16518:
URL: https://github.com/apache/kafka/pull/16518#discussion_r1669133266
##
raft/src/test/java/org/apache/kafka/raft/KafkaRaftClientReconfigTest.java:
##
@@ -0,0 +1,271 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one o
brenden20 commented on code in PR #16200:
URL: https://github.com/apache/kafka/pull/16200#discussion_r1669122743
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/HeartbeatRequestManagerTest.java:
##
@@ -106,72 +102,90 @@ public class HeartbeatRequestManagerTe
C0urante merged PR #16525:
URL: https://github.com/apache/kafka/pull/16525
--
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
ahuang98 commented on code in PR #16518:
URL: https://github.com/apache/kafka/pull/16518#discussion_r1669120830
##
raft/src/test/java/org/apache/kafka/raft/KafkaRaftClientReconfigTest.java:
##
@@ -0,0 +1,271 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one o
C0urante commented on PR #16525:
URL: https://github.com/apache/kafka/pull/16525#issuecomment-2214937353
The latest change is trivial and I'm able to build and run all unit tests
for the `:connect:mirror` module, and run the `DedicatedMirrorIntegrationTest`
suite locally. Merging...
--
T
C0urante commented on code in PR #16525:
URL: https://github.com/apache/kafka/pull/16525#discussion_r1669116891
##
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/integration/DedicatedMirrorIntegrationTest.java:
##
@@ -354,8 +355,10 @@ private void
awaitTaskConfig
brenden20 commented on code in PR #16200:
URL: https://github.com/apache/kafka/pull/16200#discussion_r1669112935
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/HeartbeatRequestManagerTest.java:
##
@@ -106,72 +102,90 @@ public class HeartbeatRequestManagerTe
OmniaGM commented on code in PR #15999:
URL: https://github.com/apache/kafka/pull/15999#discussion_r1669096983
##
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorCheckpointConfig.java:
##
@@ -166,6 +167,30 @@ Duration consumerPollTimeout() {
return Du
OmniaGM commented on code in PR #15999:
URL: https://github.com/apache/kafka/pull/15999#discussion_r1669096566
##
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorCheckpointConfig.java:
##
@@ -166,6 +167,30 @@ Duration consumerPollTimeout() {
return Du
jsancio commented on code in PR #16518:
URL: https://github.com/apache/kafka/pull/16518#discussion_r1669073620
##
raft/src/test/java/org/apache/kafka/raft/KafkaRaftClientReconfigTest.java:
##
@@ -0,0 +1,271 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or
[
https://issues.apache.org/jira/browse/KAFKA-17097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Harris updated KAFKA-17097:
Description:
{color:#172b4d}See
[https://cwiki.apache.org/confluence/pages/viewpage.action?pageId
[
https://issues.apache.org/jira/browse/KAFKA-17097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Harris updated KAFKA-17097:
Labels: newbie (was: )
> Add replace.null.with.default configuration to ValueToKey and ReplaceFie
Greg Harris created KAFKA-17097:
---
Summary: Add replace.null.with.default configuration to ValueToKey
and ReplaceField (KIP-1040)
Key: KAFKA-17097
URL: https://issues.apache.org/jira/browse/KAFKA-17097
P
[
https://issues.apache.org/jira/browse/KAFKA-15838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Harris resolved KAFKA-15838.
-
Fix Version/s: 3.9.0
Resolution: Fixed
The InsertField, ExtractField, HeaderFrom, Cast, S
[
https://issues.apache.org/jira/browse/KAFKA-17095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17863890#comment-17863890
]
Greg Harris commented on KAFKA-17095:
-
Is this a backwards compatible change? If som
gharris1727 commented on PR #15756:
URL: https://github.com/apache/kafka/pull/15756#issuecomment-2214862389
Thank you @mfvitale for driving the KIP and implementation!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use th
gharris1727 merged PR #15756:
URL: https://github.com/apache/kafka/pull/15756
--
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 #15756:
URL: https://github.com/apache/kafka/pull/15756#issuecomment-2214855870
Test failures appear unrelated, and connect:transforms:test passes for me
locally.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
gharris1727 commented on code in PR #16525:
URL: https://github.com/apache/kafka/pull/16525#discussion_r1669065888
##
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/integration/DedicatedMirrorIntegrationTest.java:
##
@@ -354,8 +355,10 @@ private void
awaitTaskCon
lianetm commented on PR #16200:
URL: https://github.com/apache/kafka/pull/16200#issuecomment-2214850627
Hey @brenden20 , thanks for the updates! I completed another pass, left some
comments. Thanks!
--
This is an automated message from the Apache Git Service.
To respond to the message, pl
1 - 100 of 235 matches
Mail list logo
