yashmayya opened a new pull request, #13657:
URL: https://github.com/apache/kafka/pull/13657
- Adds documentation for the new `PUT /connectors/{name}/stop` REST API for
Connect (see
[KIP-875](https://cwiki.apache.org/confluence/display/KAFKA/KIP-875%3A+First-class+offsets+support+in+Kafka+C
[
https://issues.apache.org/jira/browse/KAFKA-14876?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17718464#comment-17718464
]
Yash Mayya commented on KAFKA-14876:
[~gharris1727] [~ChrisEgerton] sounds good, I'v
yashmayya commented on code in PR #13657:
URL: https://github.com/apache/kafka/pull/13657#discussion_r1182174568
##
docs/connect.html:
##
@@ -301,7 +301,8 @@ REST
API
GET /connectors/{name}/tasks - get a list of tasks
currently running for a connector
GET /co
showuon commented on PR #13514:
URL: https://github.com/apache/kafka/pull/13514#issuecomment-1531036253
@fvaleri , there is checkstyle failure. Could you fix it?
```
Execution failed for task ':examples:checkstyleMain'.
```
--
This is an automated message from the Apache Git S
[
https://issues.apache.org/jira/browse/KAFKA-14876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yash Mayya updated KAFKA-14876:
---
Description:
Add public documentation for the new Kafka Connect REST APIs from
[KIP-875|https://cwi
fvaleri commented on PR #13514:
URL: https://github.com/apache/kafka/pull/13514#issuecomment-1531090993
Hi @showuon, I missed that. Thanks.
--
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
divijvaidya commented on code in PR #13535:
URL: https://github.com/apache/kafka/pull/13535#discussion_r1182279902
##
core/src/main/scala/kafka/server/ReplicaManager.scala:
##
@@ -1160,48 +1171,100 @@ class ReplicaManager(val config: KafkaConfig,
fetchPartitionStatus
showuon commented on PR #13514:
URL: https://github.com/apache/kafka/pull/13514#issuecomment-1531149504
Thanks for the update. I'll merge it after CI build completed.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
[
https://issues.apache.org/jira/browse/KAFKA-14946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen updated KAFKA-14946:
--
Summary: KRaft Node Shutting down while (was: Kafka Node Shutting Down
Automatically)
> KRaft Node
[
https://issues.apache.org/jira/browse/KAFKA-14946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen updated KAFKA-14946:
--
Summary: KRaft Node Shutting down while renouncing leadership (was: KRaft
Node Shutting down while )
[
https://issues.apache.org/jira/browse/KAFKA-14946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen updated KAFKA-14946:
--
Summary: KRaft controller node shutting down while renouncing leadership
(was: KRaft Node Shutting do
Divij Vaidya created KAFKA-14953:
Summary: Add metrics for expiration of delayed remote fetch
Key: KAFKA-14953
URL: https://issues.apache.org/jira/browse/KAFKA-14953
Project: Kafka
Issue Type
divijvaidya commented on code in PR #13535:
URL: https://github.com/apache/kafka/pull/13535#discussion_r1182326466
##
core/src/main/scala/kafka/server/DelayedRemoteFetch.scala:
##
@@ -0,0 +1,112 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * c
Divij Vaidya created KAFKA-14954:
Summary: Use BufferPools to optimize allocation in
RemoteLogInputStream
Key: KAFKA-14954
URL: https://issues.apache.org/jira/browse/KAFKA-14954
Project: Kafka
divijvaidya commented on code in PR #13535:
URL: https://github.com/apache/kafka/pull/13535#discussion_r1182330923
##
core/src/main/java/kafka/log/remote/RemoteLogManager.java:
##
@@ -600,25 +622,208 @@ public String toString() {
}
}
-long findHighestRemoteOf
showuon commented on code in PR #13312:
URL: https://github.com/apache/kafka/pull/13312#discussion_r1182330077
##
clients/src/test/java/org/apache/kafka/common/utils/ByteUtilsTest.java:
##
@@ -241,6 +244,119 @@ public void testDouble() throws IOException {
assertDoubleS
Hangleton commented on code in PR #13561:
URL: https://github.com/apache/kafka/pull/13561#discussion_r1182338603
##
core/src/main/java/kafka/log/remote/RemoteLogManager.java:
##
@@ -595,6 +609,193 @@ public void run() {
}
}
+public void handleLogS
Hangleton commented on code in PR #13561:
URL: https://github.com/apache/kafka/pull/13561#discussion_r1182338603
##
core/src/main/java/kafka/log/remote/RemoteLogManager.java:
##
@@ -595,6 +609,193 @@ public void run() {
}
}
+public void handleLogS
Hangleton commented on code in PR #13535:
URL: https://github.com/apache/kafka/pull/13535#discussion_r1180448490
##
core/src/main/java/kafka/log/remote/RemoteLogManager.java:
##
@@ -600,25 +622,208 @@ public String toString() {
}
}
-long findHighestRemoteOffs
sambhav-jain-16 commented on PR #13646:
URL: https://github.com/apache/kafka/pull/13646#issuecomment-1531223773
hi @vamossagar12
> For starters, can you try increasing CONSUME_RECORDS_TIMEOUT_MS to 100s or
as such and see if it even works?
Actually I tried it and it failed for me
[
https://issues.apache.org/jira/browse/KAFKA-14947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17718513#comment-17718513
]
Yash Mayya commented on KAFKA-14947:
[~krishnendudas] the offset commits for source
Hangleton commented on code in PR #13561:
URL: https://github.com/apache/kafka/pull/13561#discussion_r1182338603
##
core/src/main/java/kafka/log/remote/RemoteLogManager.java:
##
@@ -595,6 +609,193 @@ public void run() {
}
}
+public void handleLogS
Hangleton commented on code in PR #13561:
URL: https://github.com/apache/kafka/pull/13561#discussion_r1182338603
##
core/src/main/java/kafka/log/remote/RemoteLogManager.java:
##
@@ -595,6 +609,193 @@ public void run() {
}
}
+public void handleLogS
dajac merged PR #13652:
URL: https://github.com/apache/kafka/pull/13652
--
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
[
https://issues.apache.org/jira/browse/KAFKA-14639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot updated KAFKA-14639:
Fix Version/s: 3.4.1
> Kafka CooperativeStickyAssignor revokes/assigns partition in one rebalance
dajac commented on PR #13550:
URL: https://github.com/apache/kafka/pull/13550#issuecomment-1531331123
Merged https://github.com/apache/kafka/pull/13652 to 3.4.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL ab
divijvaidya commented on code in PR #13535:
URL: https://github.com/apache/kafka/pull/13535#discussion_r1182398774
##
core/src/main/java/kafka/log/remote/RemoteLogManager.java:
##
@@ -670,6 +875,14 @@ public void close() {
} catch (InterruptedException e) {
dajac commented on code in PR #13637:
URL: https://github.com/apache/kafka/pull/13637#discussion_r1182450145
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/consumer/TargetAssignmentBuilder.java:
##
@@ -0,0 +1,327 @@
+/*
+ * Licensed to the Apache Software
dajac commented on code in PR #13637:
URL: https://github.com/apache/kafka/pull/13637#discussion_r1182451755
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/consumer/TargetAssignmentBuilder.java:
##
@@ -0,0 +1,327 @@
+/*
+ * Licensed to the Apache Software
cadonna merged PR #13529:
URL: https://github.com/apache/kafka/pull/13529
--
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.
dajac commented on code in PR #13637:
URL: https://github.com/apache/kafka/pull/13637#discussion_r1182452889
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/consumer/TargetAssignmentBuilderTest.java:
##
@@ -0,0 +1,698 @@
+/*
+ * Licensed to the Apache Softw
cadonna commented on PR #13621:
URL: https://github.com/apache/kafka/pull/13621#issuecomment-1531348081
@clolov Thanks for the updates! I just merged
https://github.com/apache/kafka/pull/13529. Could you please rebase this PR?
--
This is an automated message from the Apache Git Servic
dajac commented on code in PR #13637:
URL: https://github.com/apache/kafka/pull/13637#discussion_r1182453174
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/consumer/TargetAssignmentBuilder.java:
##
@@ -0,0 +1,327 @@
+/*
+ * Licensed to the Apache Software
dajac commented on code in PR #13637:
URL: https://github.com/apache/kafka/pull/13637#discussion_r1182455767
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/consumer/TargetAssignmentBuilderTest.java:
##
@@ -0,0 +1,698 @@
+/*
+ * Licensed to the Apache Softw
divijvaidya commented on code in PR #13312:
URL: https://github.com/apache/kafka/pull/13312#discussion_r1182456902
##
clients/src/test/java/org/apache/kafka/common/utils/ByteUtilsTest.java:
##
@@ -241,6 +244,119 @@ public void testDouble() throws IOException {
assertDou
dajac commented on PR #13637:
URL: https://github.com/apache/kafka/pull/13637#issuecomment-1531356888
@jeffkbkim I have addressed your comments. Thanks!
--
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
showuon commented on code in PR #13461:
URL: https://github.com/apache/kafka/pull/13461#discussion_r1182450255
##
metadata/src/test/java/org/apache/kafka/metadata/migration/KRaftMigrationDriverTest.java:
##
@@ -534,5 +421,157 @@ public void testSkipWaitForBrokersInDualWrite() th
showuon commented on PR #13514:
URL: https://github.com/apache/kafka/pull/13514#issuecomment-1531392005
Failed tests are unrelated:
```
Build / JDK 8 and Scala 2.12 /
org.apache.kafka.connect.integration.ExactlyOnceSourceIntegrationTest.testConnectorBoundary
Build / JDK 8 an
showuon merged PR #13514:
URL: https://github.com/apache/kafka/pull/13514
--
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.
dajac commented on code in PR #13644:
URL: https://github.com/apache/kafka/pull/13644#discussion_r1182474216
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/generic/GenericGroupMember.java:
##
@@ -0,0 +1,560 @@
+/**
+ * Licensed to the Apache Software Found
Hangleton commented on code in PR #13535:
URL: https://github.com/apache/kafka/pull/13535#discussion_r1182493022
##
core/src/main/scala/kafka/server/ReplicaManager.scala:
##
@@ -1160,48 +1171,100 @@ class ReplicaManager(val config: KafkaConfig,
fetchPartitionStatus +=
tinaselenge opened a new pull request, #13658:
URL: https://github.com/apache/kafka/pull/13658
Currently all three generated docs for MirrorMaker contain fields from
BASE_CONNECTOR_CONFIG_DEF which results in duplicated fields when using them in
the doc. This PR separates BASE_CONNECTOR_CON
clolov commented on code in PR #13122:
URL: https://github.com/apache/kafka/pull/13122#discussion_r1182518605
##
tools/src/test/java/org/apache/kafka/tools/LogDirsCommandTest.java:
##
@@ -0,0 +1,83 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ *
clolov commented on code in PR #13122:
URL: https://github.com/apache/kafka/pull/13122#discussion_r1182519045
##
tools/src/test/java/org/apache/kafka/tools/LogDirsCommandTest.java:
##
@@ -0,0 +1,83 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ *
clolov commented on PR #13122:
URL: https://github.com/apache/kafka/pull/13122#issuecomment-1531443138
Heya @mimaison, thank you for the review! I have updated the assertions to
be more precise. I wanted to avoid creating a whole new POJO to turn the String
into a navigable map, but if you
divijvaidya commented on code in PR #13623:
URL: https://github.com/apache/kafka/pull/13623#discussion_r1182536794
##
core/src/main/scala/kafka/log/LogCleaner.scala:
##
@@ -167,8 +167,20 @@ class LogCleaner(initialConfig: CleanerConfig,
*/
def shutdown(): Unit = {
in
divijvaidya commented on code in PR #13623:
URL: https://github.com/apache/kafka/pull/13623#discussion_r1182552980
##
core/src/main/scala/kafka/log/LogCleaner.scala:
##
@@ -167,8 +167,20 @@ class LogCleaner(initialConfig: CleanerConfig,
*/
def shutdown(): Unit = {
in
divijvaidya commented on PR #13623:
URL: https://github.com/apache/kafka/pull/13623#issuecomment-1531493129
@mimaison when you get a chance, please take a look.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL a
jeffkbkim commented on code in PR #13637:
URL: https://github.com/apache/kafka/pull/13637#discussion_r1182592483
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/consumer/TargetAssignmentBuilder.java:
##
@@ -0,0 +1,327 @@
+/*
+ * Licensed to the Apache Softw
machi1990 commented on code in PR #13623:
URL: https://github.com/apache/kafka/pull/13623#discussion_r1182592921
##
core/src/main/scala/kafka/log/LogCleaner.scala:
##
@@ -167,8 +167,20 @@ class LogCleaner(initialConfig: CleanerConfig,
*/
def shutdown(): Unit = {
info
jeffkbkim commented on code in PR #13637:
URL: https://github.com/apache/kafka/pull/13637#discussion_r1182594976
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/consumer/TargetAssignmentBuilder.java:
##
@@ -0,0 +1,327 @@
+/*
+ * Licensed to the Apache Softw
splett2 commented on PR #13655:
URL: https://github.com/apache/kafka/pull/13655#issuecomment-1531539359
@showuon
not explicitly. I was hoping it would reduce some of the CI job resource
utilization.
--
This is an automated message from the Apache Git Service.
To respond to the message
dajac commented on code in PR #13623:
URL: https://github.com/apache/kafka/pull/13623#discussion_r1182595446
##
core/src/test/scala/unit/kafka/log/LogCleanerTest.scala:
##
@@ -62,6 +65,33 @@ class LogCleanerTest {
Utils.delete(tmpdir)
}
+ @Test
+ def testRemoveMetric
fvaleri commented on PR #13492:
URL: https://github.com/apache/kafka/pull/13492#issuecomment-1531544193
This PR was broken into multiple reviews.
--
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 t
fvaleri closed pull request #13492: KAFKA-14752: Kafka examples improvements
URL: https://github.com/apache/kafka/pull/13492
--
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
dajac commented on code in PR #13637:
URL: https://github.com/apache/kafka/pull/13637#discussion_r1182598786
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/consumer/TargetAssignmentBuilder.java:
##
@@ -0,0 +1,327 @@
+/*
+ * Licensed to the Apache Software
dajac commented on code in PR #13637:
URL: https://github.com/apache/kafka/pull/13637#discussion_r1182599075
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/consumer/TargetAssignmentBuilder.java:
##
@@ -0,0 +1,327 @@
+/*
+ * Licensed to the Apache Software
dajac commented on code in PR #13637:
URL: https://github.com/apache/kafka/pull/13637#discussion_r1182598786
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/consumer/TargetAssignmentBuilder.java:
##
@@ -0,0 +1,327 @@
+/*
+ * Licensed to the Apache Software
mumrah commented on code in PR #13461:
URL: https://github.com/apache/kafka/pull/13461#discussion_r1182705187
##
metadata/src/test/java/org/apache/kafka/metadata/migration/KRaftMigrationDriverTest.java:
##
@@ -534,5 +421,157 @@ public void testSkipWaitForBrokersInDualWrite() thr
David Jacot created KAFKA-14955:
---
Summary: Validate that all partitions are assigned in
TargetAssignmentBuilder
Key: KAFKA-14955
URL: https://issues.apache.org/jira/browse/KAFKA-14955
Project: Kafka
divijvaidya commented on code in PR #13623:
URL: https://github.com/apache/kafka/pull/13623#discussion_r1182715489
##
core/src/main/scala/kafka/log/LogCleaner.scala:
##
@@ -124,29 +124,37 @@ class LogCleaner(initialConfig: CleanerConfig,
private def maxOverCleanerThreads(f: C
rreddy-22 commented on code in PR #13443:
URL: https://github.com/apache/kafka/pull/13443#discussion_r1182715705
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/assignor/RangeAssignorTest.java:
##
@@ -0,0 +1,574 @@
+/*
+ * Licensed to the Apache Software Fo
divijvaidya commented on code in PR #13623:
URL: https://github.com/apache/kafka/pull/13623#discussion_r1182721302
##
core/src/main/scala/kafka/log/LogCleaner.scala:
##
@@ -167,8 +167,20 @@ class LogCleaner(initialConfig: CleanerConfig,
*/
def shutdown(): Unit = {
in
Sagar Rao created KAFKA-14956:
-
Summary: Flaky test
org.apache.kafka.connect.integration.OffsetsApiIntegrationTest#testGetSinkConnectorOffsetsDifferentKafkaClusterTargeted
Key: KAFKA-14956
URL: https://issues.apache.o
mimaison merged PR #13259:
URL: https://github.com/apache/kafka/pull/13259
--
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 #13657:
URL: https://github.com/apache/kafka/pull/13657#discussion_r1182730958
##
docs/connect.html:
##
@@ -301,7 +301,8 @@ REST
API
GET /connectors/{name}/tasks - get a list of tasks
currently running for a connector
GET /con
mimaison commented on code in PR #13122:
URL: https://github.com/apache/kafka/pull/13122#discussion_r1182729223
##
tools/src/test/java/org/apache/kafka/tools/LogDirsCommandTest.java:
##
@@ -0,0 +1,119 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
C0urante commented on code in PR #13657:
URL: https://github.com/apache/kafka/pull/13657#discussion_r1182739254
##
docs/connect.html:
##
@@ -301,7 +301,8 @@ REST
API
GET /connectors/{name}/tasks - get a list of tasks
currently running for a connector
GET /con
dajac merged PR #13637:
URL: https://github.com/apache/kafka/pull/13637
--
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
yashmayya commented on code in PR #13657:
URL: https://github.com/apache/kafka/pull/13657#discussion_r1182756093
##
docs/connect.html:
##
@@ -301,7 +301,8 @@ REST
API
GET /connectors/{name}/tasks - get a list of tasks
currently running for a connector
GET /co
yashmayya commented on code in PR #13657:
URL: https://github.com/apache/kafka/pull/13657#discussion_r1182756093
##
docs/connect.html:
##
@@ -301,7 +301,8 @@ REST
API
GET /connectors/{name}/tasks - get a list of tasks
currently running for a connector
GET /co
[
https://issues.apache.org/jira/browse/KAFKA-14956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yash Mayya reassigned KAFKA-14956:
--
Assignee: Yash Mayya
> Flaky test
> org.apache.kafka.connect.integration.OffsetsApiIntegrati
[
https://issues.apache.org/jira/browse/KAFKA-14661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Divij Vaidya updated KAFKA-14661:
-
Fix Version/s: 3.6.0
> Upgrade Zookeeper to 3.8.1
> ---
>
>
[
https://issues.apache.org/jira/browse/KAFKA-14661?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17718640#comment-17718640
]
Divij Vaidya commented on KAFKA-14661:
--
Adding targeted fix version to 3.6.0. The K
mjsax commented on PR #13654:
URL: https://github.com/apache/kafka/pull/13654#issuecomment-1531777179
Same issue. Trying again:
https://jenkins.confluent.io/job/system-test-kafka-branch-builder/5655/
--
This is an automated message from the Apache Git Service.
To respond to the message, p
mjsax commented on code in PR #13656:
URL: https://github.com/apache/kafka/pull/13656#discussion_r1182064875
##
streams/src/test/java/org/apache/kafka/streams/tests/SmokeTestDriver.java:
##
@@ -126,7 +130,7 @@ static void generatePerpetually(final String kafka,
data
kirktrue commented on PR #13640:
URL: https://github.com/apache/kafka/pull/13640#issuecomment-1531804943
@mimaison Would you be willing to merge this change? Thanks!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
kirktrue commented on code in PR #13591:
URL: https://github.com/apache/kafka/pull/13591#discussion_r1182800168
##
clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java:
##
@@ -968,13 +1035,23 @@ private void transitionTo(State target) {
kirktrue commented on code in PR #13591:
URL: https://github.com/apache/kafka/pull/13591#discussion_r1182800998
##
clients/src/main/java/org/apache/kafka/clients/producer/internals/Sender.java:
##
@@ -263,7 +263,14 @@ public void run() {
while (!forceClose && transactio
kirktrue commented on code in PR #13591:
URL: https://github.com/apache/kafka/pull/13591#discussion_r1182801453
##
clients/src/test/java/org/apache/kafka/clients/producer/internals/TransactionManagerTest.java:
##
@@ -3405,6 +3406,52 @@ MAX_REQUEST_SIZE, ACKS_ALL, MAX_RETRIES, ne
mimaison commented on PR #13640:
URL: https://github.com/apache/kafka/pull/13640#issuecomment-1531813505
@kirktrue I'm looking at it now. With this PR I consistently get failures
with the following tests:
```
SslAdminIntegrationTest.testAclUpdatesUsingAsynchronousAuthorizer()
SslAdm
jolshan commented on code in PR #13591:
URL: https://github.com/apache/kafka/pull/13591#discussion_r1182805033
##
clients/src/main/java/org/apache/kafka/clients/producer/internals/Sender.java:
##
@@ -263,7 +263,14 @@ public void run() {
while (!forceClose && transaction
jolshan commented on code in PR #13591:
URL: https://github.com/apache/kafka/pull/13591#discussion_r1182805477
##
clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java:
##
@@ -968,13 +1035,23 @@ private void transitionTo(State target) {
}
C0urante commented on code in PR #13657:
URL: https://github.com/apache/kafka/pull/13657#discussion_r1182806166
##
docs/connect.html:
##
@@ -301,7 +301,8 @@ REST
API
GET /connectors/{name}/tasks - get a list of tasks
currently running for a connector
GET /con
C0urante commented on code in PR #13657:
URL: https://github.com/apache/kafka/pull/13657#discussion_r1182806166
##
docs/connect.html:
##
@@ -301,7 +301,8 @@ REST
API
GET /connectors/{name}/tasks - get a list of tasks
currently running for a connector
GET /con
Mickael Maison created KAFKA-14957:
--
Summary: Default value for state.dir is confusing
Key: KAFKA-14957
URL: https://issues.apache.org/jira/browse/KAFKA-14957
Project: Kafka
Issue Type: Bug
cmccabe commented on code in PR #13653:
URL: https://github.com/apache/kafka/pull/13653#discussion_r1182836931
##
server-common/src/main/java/org/apache/kafka/timeline/SnapshottableHashTable.java:
##
@@ -113,7 +113,7 @@ public void mergeFrom(long epoch, Delta source) {
cmccabe commented on PR #13653:
URL: https://github.com/apache/kafka/pull/13653#issuecomment-1531861352
Thanks, this is a very good find, @showuon ! We've been seeing this NPE
occassionally but never found out where it was coming from.
I left a correction, take a look
--
This is an
[
https://issues.apache.org/jira/browse/KAFKA-14916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Justine Olshan updated KAFKA-14916:
---
Description:
KAFKA-14561 wrote code that assumed that if a transactional ID was included,
a
Justine Olshan created KAFKA-14958:
--
Summary: Investigate enforcing all batches have the same producer
ID
Key: KAFKA-14958
URL: https://issues.apache.org/jira/browse/KAFKA-14958
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-14916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Justine Olshan updated KAFKA-14916:
---
Description:
KAFKA-14561 wrote code that assumed that if a transactional ID was included,
a
Manyanda Chitimbo created KAFKA-14959:
-
Summary: Remove metrics on ClientQuota Managers shutdown
Key: KAFKA-14959
URL: https://issues.apache.org/jira/browse/KAFKA-14959
Project: Kafka
Iss
[
https://issues.apache.org/jira/browse/KAFKA-14959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Manyanda Chitimbo reassigned KAFKA-14959:
-
Assignee: (was: Divij Vaidya)
> Remove metrics on ClientQuota Managers shut
[
https://issues.apache.org/jira/browse/KAFKA-14959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Manyanda Chitimbo updated KAFKA-14959:
--
Description:
We register metrics in ClientQuotaManager.scala and its child classes but
[
https://issues.apache.org/jira/browse/KAFKA-14959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Manyanda Chitimbo updated KAFKA-14959:
--
Fix Version/s: (was: 3.6.0)
> Remove metrics on ClientQuota Managers shutdown
> --
machi1990 commented on code in PR #13623:
URL: https://github.com/apache/kafka/pull/13623#discussion_r1182849704
##
core/src/main/scala/kafka/log/LogCleaner.scala:
##
@@ -167,8 +167,20 @@ class LogCleaner(initialConfig: CleanerConfig,
*/
def shutdown(): Unit = {
info
[
https://issues.apache.org/jira/browse/KAFKA-14959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Manyanda Chitimbo reassigned KAFKA-14959:
-
Assignee: Manyanda Chitimbo
> Remove metrics on ClientQuota Managers shutdown
>
[
https://issues.apache.org/jira/browse/KAFKA-14666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17718669#comment-17718669
]
Chris Egerton commented on KAFKA-14666:
---
Backported to 3.4 and 3.3.
> MM2 should
[
https://issues.apache.org/jira/browse/KAFKA-14666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton updated KAFKA-14666:
--
Fix Version/s: 3.4.1
3.3.3
> MM2 should translate consumer group offsets be
[
https://issues.apache.org/jira/browse/KAFKA-14837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton updated KAFKA-14837:
--
Fix Version/s: 3.4.1
3.3.3
> The MirrorCheckPointConnector of MM2 will reba
1 - 100 of 165 matches
Mail list logo
