hudeqi commented on PR #13421:
URL: https://github.com/apache/kafka/pull/13421#issuecomment-1486291886
Hello, are you interested in seeing this issue? I think it's a serious bug.
@hachikuji @mumrah
--
This is an automated message from the Apache Git Service.
To respond to the message, pl
philipnee commented on PR #13269:
URL: https://github.com/apache/kafka/pull/13269#issuecomment-1486266466
Hey @cadonna - Thanks for getting back on this. I added two tests covering
EOS enabled/disabled cases - LMK if this is what you are looking for. I tried
to make the test case explicit t
mjsax commented on code in PR #13449:
URL: https://github.com/apache/kafka/pull/13449#discussion_r1150050550
##
streams/src/test/java/org/apache/kafka/streams/integration/VersionedKeyValueStoreIntegrationTest.java:
##
@@ -361,6 +365,91 @@ public void shouldCreateGlobalTable() th
mjsax commented on code in PR #13444:
URL: https://github.com/apache/kafka/pull/13444#discussion_r1150042983
##
docs/streams/developer-guide/processor-api.html:
##
@@ -261,11 +262,13 @@
space.
RocksDB settings can be
mjsax commented on code in PR #13442:
URL: https://github.com/apache/kafka/pull/13442#discussion_r1150036447
##
streams/src/main/java/org/apache/kafka/streams/state/Stores.java:
##
@@ -110,6 +116,73 @@ public static KeyValueBytesStoreSupplier
persistentTimestampedKeyValueStore(
mjsax commented on code in PR #13431:
URL: https://github.com/apache/kafka/pull/13431#discussion_r1150018327
##
streams/src/main/java/org/apache/kafka/streams/state/internals/LogicalKeyValueSegment.java:
##
@@ -176,7 +184,7 @@ public synchronized KeyValueIterator
range(final By
philipnee commented on code in PR #13380:
URL: https://github.com/apache/kafka/pull/13380#discussion_r1150022881
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/CommitRequestManagerTest.java:
##
@@ -61,73 +83,250 @@ public void setup() {
}
@Test
jeqo commented on PR #13445:
URL: https://github.com/apache/kafka/pull/13445#issuecomment-1486212417
Thank you all for your feedback. It's looking good! Let's see what CI says :)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
C0urante commented on PR #11046:
URL: https://github.com/apache/kafka/pull/11046#issuecomment-1486198234
@nbali this PR was merged over two years ago and I've lost almost all of the
context around it. If you are seeing problems because of the changes made here,
please file a Jira ticket des
mjsax commented on code in PR #13364:
URL: https://github.com/apache/kafka/pull/13364#discussion_r1149989283
##
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBVersionedStoreSegmentValueFormatter.java:
##
@@ -341,8 +345,10 @@ public void insertAsLatest(fina
nbali commented on PR #11046:
URL: https://github.com/apache/kafka/pull/11046#issuecomment-1486190276
@C0urante FYI this has a functionality loss. If you
`KafkaConsumer.poll(Duration)` you are unable to tell anymore if it returns
empty if it was a timeout - so most likely the topic is fully
pprovenzano commented on code in PR #13374:
URL: https://github.com/apache/kafka/pull/13374#discussion_r1150002299
##
core/src/main/scala/kafka/tools/StorageTool.scala:
##
@@ -22,19 +22,37 @@ import java.nio.file.{Files, Paths}
import kafka.server.{BrokerMetadataCheckpoint, Kaf
chia7712 commented on PR #13326:
URL: https://github.com/apache/kafka/pull/13326#issuecomment-1486165359
> I think we should back-port this to 3.4 branch. WDYT?
Will copy that
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Gi
hudeqi commented on code in PR #13446:
URL: https://github.com/apache/kafka/pull/13446#discussion_r1149996731
##
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorCheckpointConnectorTest.java:
##
@@ -123,13 +127,21 @@ public void testFindConsumerGroups() throws
hudeqi commented on code in PR #13446:
URL: https://github.com/apache/kafka/pull/13446#discussion_r1149973082
##
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorCheckpointConnectorTest.java:
##
@@ -123,13 +127,21 @@ public void testFindConsumerGroups() throws
hudeqi commented on code in PR #13446:
URL: https://github.com/apache/kafka/pull/13446#discussion_r1149959295
##
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorCheckpointTask.java:
##
@@ -178,6 +178,7 @@ private List sourceRecordsForGroup(String
group) throw
hudeqi commented on code in PR #13446:
URL: https://github.com/apache/kafka/pull/13446#discussion_r1149959006
##
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorCheckpointTask.java:
##
@@ -178,6 +178,7 @@ private List sourceRecordsForGroup(String
group) throw
showuon commented on PR #13326:
URL: https://github.com/apache/kafka/pull/13326#issuecomment-1486105014
Nice find @chia7712 , I think we should back-port this to 3.4 branch. WDYT?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHu
hudeqi commented on code in PR #13446:
URL: https://github.com/apache/kafka/pull/13446#discussion_r1149948611
##
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorCheckpointConnector.java:
##
@@ -150,10 +156,30 @@ private void loadInitialConsumerGroups()
hudeqi commented on code in PR #13446:
URL: https://github.com/apache/kafka/pull/13446#discussion_r1149948271
##
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorCheckpointConnector.java:
##
@@ -150,10 +156,30 @@ private void loadInitialConsumerGroups()
hudeqi commented on code in PR #13446:
URL: https://github.com/apache/kafka/pull/13446#discussion_r1149947295
##
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorCheckpointConnector.java:
##
@@ -150,10 +156,30 @@ private void loadInitialConsumerGroups()
hudeqi commented on code in PR #13446:
URL: https://github.com/apache/kafka/pull/13446#discussion_r1149945098
##
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorCheckpointConnector.java:
##
@@ -150,10 +156,30 @@ private void loadInitialConsumerGroups()
jolshan commented on code in PR #13391:
URL: https://github.com/apache/kafka/pull/13391#discussion_r1149903116
##
core/src/main/scala/kafka/server/AddPartitionsToTxnManager.scala:
##
@@ -0,0 +1,173 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+
jolshan opened a new pull request, #13463:
URL: https://github.com/apache/kafka/pull/13463
Refactors the interbroker send thread to be a concrete class that can handle
multiple InterBrokerRequestManagers.
This is an intermediate step before completing
https://github.com/apache/kafka/
[
https://issues.apache.org/jira/browse/KAFKA-14843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton updated KAFKA-14843:
--
Affects Version/s: 3.3.2
3.3.1
3.2.3
C0urante commented on code in PR #13445:
URL: https://github.com/apache/kafka/pull/13445#discussion_r1149888198
##
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/AbstractHerderTest.java:
##
@@ -943,35 +943,45 @@ public void
testGenerateResultWithConfigValuesWith
gharris1727 commented on code in PR #13429:
URL: https://github.com/apache/kafka/pull/13429#discussion_r1149859768
##
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/OffsetSyncStore.java:
##
@@ -139,10 +171,103 @@ public void close() {
protected void handleReco
[
https://issues.apache.org/jira/browse/KAFKA-14639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17705734#comment-17705734
]
Guozhang Wang commented on KAFKA-14639:
---
As for the fix.. it's quite tough, since
[
https://issues.apache.org/jira/browse/KAFKA-14843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton updated KAFKA-14843:
--
Description:
Connector plugins GET config endpoint introduced in
[https://cwiki.apache.org/co
[
https://issues.apache.org/jira/browse/KAFKA-14639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17705731#comment-17705731
]
Guozhang Wang commented on KAFKA-14639:
---
I looked at both JIRA tickets and I belie
C0urante commented on code in PR #13446:
URL: https://github.com/apache/kafka/pull/13446#discussion_r1149871568
##
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorCheckpointConnector.java:
##
@@ -150,10 +156,30 @@ private void loadInitialConsumerGroups()
cmccabe commented on code in PR #13374:
URL: https://github.com/apache/kafka/pull/13374#discussion_r1149874897
##
core/src/main/scala/kafka/tools/StorageTool.scala:
##
@@ -22,19 +22,37 @@ import java.nio.file.{Files, Paths}
import kafka.server.{BrokerMetadataCheckpoint, KafkaCo
cmccabe commented on code in PR #13374:
URL: https://github.com/apache/kafka/pull/13374#discussion_r1149874897
##
core/src/main/scala/kafka/tools/StorageTool.scala:
##
@@ -22,19 +22,37 @@ import java.nio.file.{Files, Paths}
import kafka.server.{BrokerMetadataCheckpoint, KafkaCo
cmccabe commented on code in PR #13374:
URL: https://github.com/apache/kafka/pull/13374#discussion_r1149876669
##
core/src/main/scala/kafka/tools/StorageTool.scala:
##
@@ -128,6 +152,108 @@ object StorageTool extends Logging {
.getOrElse(defaultValue)
}
+ def getUse
artemlivshits commented on code in PR #13391:
URL: https://github.com/apache/kafka/pull/13391#discussion_r1149873099
##
core/src/main/scala/kafka/server/AddPartitionsToTxnManager.scala:
##
@@ -0,0 +1,173 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or m
cmccabe commented on code in PR #13374:
URL: https://github.com/apache/kafka/pull/13374#discussion_r1149874897
##
core/src/main/scala/kafka/tools/StorageTool.scala:
##
@@ -22,19 +22,37 @@ import java.nio.file.{Files, Paths}
import kafka.server.{BrokerMetadataCheckpoint, KafkaCo
cmccabe merged PR #13368:
URL: https://github.com/apache/kafka/pull/13368
--
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.
C0urante commented on code in PR #13373:
URL: https://github.com/apache/kafka/pull/13373#discussion_r1149857584
##
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorSourceConnector.java:
##
@@ -514,6 +543,41 @@ private void updateTopicConfigs(Map
topicConfigs)
C0urante commented on code in PR #13373:
URL: https://github.com/apache/kafka/pull/13373#discussion_r1149844764
##
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/integration/IdentityReplicationIntegrationTest.java:
##
@@ -41,12 +41,12 @@
import org.junit.jupiter.a
jolshan commented on code in PR #13391:
URL: https://github.com/apache/kafka/pull/13391#discussion_r1149847782
##
core/src/main/scala/kafka/server/AddPartitionsToTxnManager.scala:
##
@@ -0,0 +1,173 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+
cmccabe opened a new pull request, #13462:
URL: https://github.com/apache/kafka/pull/13462
The MetadataLoader is not supposed to publish metadata updates until we have
loaded up to the high water mark. Previously, this logic was broken, and we
published updates immediately. This PR fixes th
C0urante commented on code in PR #13373:
URL: https://github.com/apache/kafka/pull/13373#discussion_r1149844200
##
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/integration/IdentityReplicationIntegrationTest.java:
##
@@ -41,12 +41,12 @@
import org.junit.jupiter.a
Colin McCabe created KAFKA-14857:
Summary: Fix some MetadataLoader bugs
Key: KAFKA-14857
URL: https://issues.apache.org/jira/browse/KAFKA-14857
Project: Kafka
Issue Type: Bug
Repo
C0urante commented on code in PR #13373:
URL: https://github.com/apache/kafka/pull/13373#discussion_r1149843748
##
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorSourceConnector.java:
##
@@ -96,6 +99,7 @@ public class MirrorSourceConnector extends SourceConne
C0urante commented on code in PR #13373:
URL: https://github.com/apache/kafka/pull/13373#discussion_r1149842964
##
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/DefaultConfigPropertyFilter.java:
##
@@ -30,6 +30,9 @@ public class DefaultConfigPropertyFilter impleme
C0urante commented on code in PR #13373:
URL: https://github.com/apache/kafka/pull/13373#discussion_r1149841456
##
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/ConfigPropertyFilter.java:
##
@@ -25,8 +25,19 @@
@InterfaceStability.Evolving
public interface Config
gharris1727 commented on code in PR #13433:
URL: https://github.com/apache/kafka/pull/13433#discussion_r1149838302
##
connect/api/src/main/java/org/apache/kafka/connect/data/ConnectSchema.java:
##
@@ -289,29 +291,202 @@ public ConnectSchema schema() {
@Override
public
C0urante commented on code in PR #13373:
URL: https://github.com/apache/kafka/pull/13373#discussion_r1149838213
##
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorSourceConnector.java:
##
@@ -540,10 +601,13 @@ Map describeTopicConfigs(Set
topics)
Confi
artemlivshits commented on code in PR #13391:
URL: https://github.com/apache/kafka/pull/13391#discussion_r1149838206
##
core/src/main/scala/kafka/server/AddPartitionsToTxnManager.scala:
##
@@ -0,0 +1,173 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or m
C0urante commented on code in PR #13434:
URL: https://github.com/apache/kafka/pull/13434#discussion_r1149828648
##
connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaOffsetBackingStore.java:
##
@@ -343,12 +336,38 @@ public Future set(final Map
values, final Cal
[
https://issues.apache.org/jira/browse/KAFKA-14757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17705689#comment-17705689
]
Philip Nee commented on KAFKA-14757:
Hi [~sanand] - I'm not sure what's behavior of
[ https://issues.apache.org/jira/browse/KAFKA-14757 ]
Philip Nee deleted comment on KAFKA-14757:
was (Author: JIRAUSER283568):
Hey [~sanand] - I'm unfamiliar with ConsumerAwareRebalanceListener, but do you
know if it revokes the partitions upon
[
https://issues.apache.org/jira/browse/KAFKA-14757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17705687#comment-17705687
]
Philip Nee commented on KAFKA-14757:
Hey [~sanand] - I'm unfamiliar with ConsumerAwa
C0urante commented on code in PR #13434:
URL: https://github.com/apache/kafka/pull/13434#discussion_r1149813420
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/AbstractHerder.java:
##
@@ -866,4 +867,19 @@ public List connectorPluginConfig(String
pluginName) {
Jeff Kim created KAFKA-14856:
Summary: Next gen group coordinator dynamic configs should be
forward compatible
Key: KAFKA-14856
URL: https://issues.apache.org/jira/browse/KAFKA-14856
Project: Kafka
anatasiavela commented on PR #13078:
URL: https://github.com/apache/kafka/pull/13078#issuecomment-1485869027
@mimaison I've marked the JIRA as 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 g
C0urante commented on code in PR #13424:
URL: https://github.com/apache/kafka/pull/13424#discussion_r1149778430
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java:
##
@@ -1090,6 +1090,40 @@ public void putConnectorConfig(final St
C0urante commented on code in PR #13424:
URL: https://github.com/apache/kafka/pull/13424#discussion_r1149776904
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/standalone/StandaloneHerder.java:
##
@@ -237,6 +237,17 @@ private synchronized void putConnectorConfi
C0urante commented on code in PR #13424:
URL: https://github.com/apache/kafka/pull/13424#discussion_r1149773408
##
connect/runtime/src/test/java/org/apache/kafka/connect/integration/ConnectWorkerIntegrationTest.java:
##
@@ -325,6 +325,181 @@ public void
testSourceTaskNotBlocked
Chris Egerton created KAFKA-14855:
-
Summary: Harden integration testing logic for asserting that a
connector is deleted
Key: KAFKA-14855
URL: https://issues.apache.org/jira/browse/KAFKA-14855
Project:
C0urante commented on code in PR #13429:
URL: https://github.com/apache/kafka/pull/13429#discussion_r1149500829
##
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/OffsetSyncStore.java:
##
@@ -25,17 +25,37 @@
import org.apache.kafka.common.utils.Utils;
import org.a
gharris1727 commented on code in PR #13445:
URL: https://github.com/apache/kafka/pull/13445#discussion_r1149755190
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/AbstractHerder.java:
##
@@ -856,11 +867,8 @@ public List connectorPluginConfig(String
pluginName)
[
https://issues.apache.org/jira/browse/KAFKA-14746?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Spacrocket reassigned KAFKA-14746:
--
Assignee: Spacrocket
> Throwing in Connector.taskConfigs generates a lot of logs
> --
rreddy-22 commented on code in PR #13443:
URL: https://github.com/apache/kafka/pull/13443#discussion_r1149655641
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/ServerSideStickyRangeAssignor.java:
##
@@ -0,0 +1,268 @@
+/*
+ * Licensed to the Apache
jeqo commented on code in PR #13445:
URL: https://github.com/apache/kafka/pull/13445#discussion_r1149677176
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/AbstractHerder.java:
##
@@ -856,11 +867,8 @@ public List connectorPluginConfig(String
pluginName) {
jeqo commented on PR #13445:
URL: https://github.com/apache/kafka/pull/13445#issuecomment-1485705474
Sure, thanks @gharris1727! let me know how it looks 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 abo
rreddy-22 commented on code in PR #13443:
URL: https://github.com/apache/kafka/pull/13443#discussion_r1149666320
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/ServerSideStickyRangeAssignor.java:
##
@@ -0,0 +1,268 @@
+/*
+ * Licensed to the Apache
rreddy-22 commented on code in PR #13443:
URL: https://github.com/apache/kafka/pull/13443#discussion_r1149659044
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/ServerSideStickyRangeAssignor.java:
##
@@ -0,0 +1,268 @@
+/*
+ * Licensed to the Apache
rreddy-22 commented on code in PR #13443:
URL: https://github.com/apache/kafka/pull/13443#discussion_r1149659044
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/ServerSideStickyRangeAssignor.java:
##
@@ -0,0 +1,268 @@
+/*
+ * Licensed to the Apache
rreddy-22 commented on code in PR #13443:
URL: https://github.com/apache/kafka/pull/13443#discussion_r1149658306
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/ServerSideStickyRangeAssignor.java:
##
@@ -0,0 +1,268 @@
+/*
+ * Licensed to the Apache
gharris1727 commented on code in PR #13433:
URL: https://github.com/apache/kafka/pull/13433#discussion_r1149656291
##
connect/api/src/main/java/org/apache/kafka/connect/data/ConnectSchema.java:
##
@@ -289,29 +291,202 @@ public ConnectSchema schema() {
@Override
public
rreddy-22 commented on code in PR #13443:
URL: https://github.com/apache/kafka/pull/13443#discussion_r1149655641
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/ServerSideStickyRangeAssignor.java:
##
@@ -0,0 +1,268 @@
+/*
+ * Licensed to the Apache
rreddy-22 commented on code in PR #13443:
URL: https://github.com/apache/kafka/pull/13443#discussion_r1149650468
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/ServerSideStickyRangeAssignor.java:
##
@@ -0,0 +1,268 @@
+/*
+ * Licensed to the Apache
rreddy-22 commented on code in PR #13443:
URL: https://github.com/apache/kafka/pull/13443#discussion_r1149648624
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/ServerSideStickyRangeAssignor.java:
##
@@ -0,0 +1,268 @@
+/*
+ * Licensed to the Apache
gharris1727 commented on code in PR #13445:
URL: https://github.com/apache/kafka/pull/13445#discussion_r1149638851
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/AbstractHerder.java:
##
@@ -836,10 +836,19 @@ public List connectorPluginConfig(String
pluginName
rreddy-22 commented on code in PR #13443:
URL: https://github.com/apache/kafka/pull/13443#discussion_r1149647453
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/ServerSideStickyRangeAssignor.java:
##
@@ -0,0 +1,268 @@
+/*
+ * Licensed to the Apache
rreddy-22 commented on code in PR #13443:
URL: https://github.com/apache/kafka/pull/13443#discussion_r1149644261
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/AssignmentMemberSpec.java:
##
@@ -37,29 +39,28 @@ public class AssignmentMemberSpec {
rreddy-22 commented on code in PR #13443:
URL: https://github.com/apache/kafka/pull/13443#discussion_r1149630814
##
checkstyle/suppressions.xml:
##
@@ -320,6 +320,14 @@
+
+
+
jolshan commented on code in PR #13391:
URL: https://github.com/apache/kafka/pull/13391#discussion_r1149586417
##
core/src/main/scala/kafka/server/AddPartitionsToTxnManager.scala:
##
@@ -0,0 +1,173 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+
Justine Olshan created KAFKA-14854:
--
Summary: Refactor inter broker send thread to handle all
interbroker requests on one thread
Key: KAFKA-14854
URL: https://issues.apache.org/jira/browse/KAFKA-14854
chia7712 opened a new pull request, #13460:
URL: https://github.com/apache/kafka/pull/13460
https://issues.apache.org/jira/browse/KAFKA-14853
I noticed this issue when reviewing #13452. We use the incorrect reference
of serializer/deserializer
### Committer Checklist (exclu
[
https://issues.apache.org/jira/browse/KAFKA-14853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai updated KAFKA-14853:
---
Summary: the serializer/deserialize which extends ClusterResourceListener
is not added to Me
Chia-Ping Tsai created KAFKA-14853:
--
Summary: the serializer/deserialize which extends
ClusterResourceListener is never called
Key: KAFKA-14853
URL: https://issues.apache.org/jira/browse/KAFKA-14853
CalvinConfluent commented on code in PR #13408:
URL: https://github.com/apache/kafka/pull/13408#discussion_r1149550057
##
metadata/src/main/java/org/apache/kafka/controller/ReplicationControlManager.java:
##
@@ -1159,16 +1171,20 @@ private Errors validateAlterPartitionData(
guozhangwang merged PR #13452:
URL: https://github.com/apache/kafka/pull/13452
--
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
guozhangwang commented on PR #13452:
URL: https://github.com/apache/kafka/pull/13452#issuecomment-1485490464
LGTM. Merging to trunk to unblock @rayokota and SR, please feel free to
address @chia7712 's comments in a follow-up PR.
--
This is an automated message from the Apache Git Service
tinaselenge opened a new pull request, #13459:
URL: https://github.com/apache/kafka/pull/13459
```
=== tests
$./bin/kafka-features.sh --bootstrap-server localhost:9092 --command-config
test describe
Feature: metadata.version SupportedMinVersion: 3.0-IV1
SupportedMaxVersio
junrao commented on code in PR #13408:
URL: https://github.com/apache/kafka/pull/13408#discussion_r1149498020
##
metadata/src/main/java/org/apache/kafka/controller/ReplicationControlManager.java:
##
@@ -1159,16 +1171,20 @@ private Errors validateAlterPartitionData(
retu
C0urante commented on code in PR #13433:
URL: https://github.com/apache/kafka/pull/13433#discussion_r1149494051
##
connect/api/src/main/java/org/apache/kafka/connect/data/ConnectSchema.java:
##
@@ -289,29 +291,202 @@ public ConnectSchema schema() {
@Override
public boo
urbandan commented on code in PR #13433:
URL: https://github.com/apache/kafka/pull/13433#discussion_r1149488176
##
connect/api/src/main/java/org/apache/kafka/connect/data/ConnectSchema.java:
##
@@ -289,29 +291,202 @@ public ConnectSchema schema() {
@Override
public boo
urbandan commented on code in PR #13433:
URL: https://github.com/apache/kafka/pull/13433#discussion_r1149465857
##
connect/api/src/main/java/org/apache/kafka/connect/data/ConnectSchema.java:
##
@@ -289,29 +291,202 @@ public ConnectSchema schema() {
@Override
public boo
urbandan commented on PR #10566:
URL: https://github.com/apache/kafka/pull/10566#issuecomment-1485386852
Thanks a lot @C0urante, will review that one!
--
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
C0urante commented on PR #13458:
URL: https://github.com/apache/kafka/pull/13458#issuecomment-1485288081
Hey @urbandan, it's looking like this week is going to be pretty busy for me
so I may not be able to take a look immediately. I can try to take a look next
week if this still hasn't rece
C0urante commented on code in PR #12637:
URL: https://github.com/apache/kafka/pull/12637#discussion_r1149375240
##
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/field/SingleFieldPath.java:
##
@@ -0,0 +1,585 @@
+/*
+ * Licensed to the Apache Software Founda
C0urante commented on PR #12637:
URL: https://github.com/apache/kafka/pull/12637#issuecomment-1485252002
I'm also wondering about the spec for V2 field syntax. The KIP states that
"if the backticks are in a wrapping position (opening or closing a field name),
then need to be escaped with ba
C0urante commented on PR #12637:
URL: https://github.com/apache/kafka/pull/12637#issuecomment-1485251519
I'm also wondering about the spec for V2 field syntax. The KIP states that
"if the backticks are in a wrapping position (opening or closing a field name),
then need to be escaped with ba
pprovenzano commented on PR #13374:
URL: https://github.com/apache/kafka/pull/13374#issuecomment-1485244811
> This seems to have broken `FeatureCommandUnitTest.testHandleDowngrade`
because of changes to storage tool.
> This seems to have broken `FeatureCommandUnitTest.testHand
philipnee commented on code in PR #13269:
URL: https://github.com/apache/kafka/pull/13269#discussion_r1149285314
##
streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamTaskTest.java:
##
@@ -1699,7 +1705,8 @@ public void
shouldReturnOffsetsForRepartitionTopi
[
https://issues.apache.org/jira/browse/KAFKA-14652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Urban updated KAFKA-14652:
-
Description:
MirrorMaker2 runs multiple Connect worker instances in a single process. In
Connec
urbandan commented on PR #13458:
URL: https://github.com/apache/kafka/pull/13458#issuecomment-1485136651
@viktorsomogyi @C0urante @mimaison You had some changes/review in this part
of the code lately, could you please review?
--
This is an automated message from the Apache Git Service.
To
1 - 100 of 132 matches
Mail list logo