yashmayya commented on code in PR #13465:
URL: https://github.com/apache/kafka/pull/13465#discussion_r1167384274
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Worker.java:
##
@@ -114,6 +127,7 @@ public class Worker {
public static final long
Yash Mayya created KAFKA-14910:
--
Summary: Consider cancelling ongoing alter connector offsets
requests when the connector is resumed
Key: KAFKA-14910
URL: https://issues.apache.org/jira/browse/KAFKA-14910
[
https://issues.apache.org/jira/browse/KAFKA-14910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yash Mayya updated KAFKA-14910:
---
Summary: Consider cancelling ongoing alter / reset connector offsets
requests when the connector is
[
https://issues.apache.org/jira/browse/KAFKA-7739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17712586#comment-17712586
]
Henry Cai commented on KAFKA-7739:
--
[~satish.duggana] I saw this KIP is moved out of [3.5.0 release plan
[
https://issues.apache.org/jira/browse/KAFKA-14884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Justine Olshan updated KAFKA-14884:
---
Priority: Blocker (was: Major)
> Include check transaction is still ongoing right before
[
https://issues.apache.org/jira/browse/KAFKA-14790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Justine Olshan resolved KAFKA-14790.
Resolution: Fixed
> Add more AddPartitionsToTxn tests in KafkaApis and Authorizer tests
>
[
https://issues.apache.org/jira/browse/KAFKA-14884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Justine Olshan updated KAFKA-14884:
---
Affects Version/s: 3.5.0
> Include check transaction is still ongoing right before append
[
https://issues.apache.org/jira/browse/KAFKA-14402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Justine Olshan updated KAFKA-14402:
---
Affects Version/s: 3.5.0
> Transactions Server Side Defense
>
[
https://issues.apache.org/jira/browse/KAFKA-14904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Justine Olshan updated KAFKA-14904:
---
Affects Version/s: 3.5.0
> Flaky Test kafka.api.TransactionsBounceTest.testWithGroupId()
>
gharris1727 opened a new pull request, #13580:
URL: https://github.com/apache/kafka/pull/13580
It appears that very rarely the EmbeddedConnectCluster will not come up,
possibly due to the underlying EmbeddedKafkaCluster being unhealthy. This PR is
trying to improve the debug info for this
gharris1727 commented on PR #13575:
URL: https://github.com/apache/kafka/pull/13575#issuecomment-1509359010
It looks like this change does solve some of the failures, which are now
flaky instead of consistently failing. This needs some more iteration to reduce
the flakiness.
--
This is
jolshan opened a new pull request, #13579:
URL: https://github.com/apache/kafka/pull/13579
[KAFKA-14561](https://github.com/apache/kafka/commit/56dcb837a2f1c1d8c016cfccf8268a910bb77a36)
added verification to transactional produce requests to confirm an ongoing
transaction.
There is
mjsax commented on PR #13533:
URL: https://github.com/apache/kafka/pull/13533#issuecomment-1509328479
@fqaiser94 -- what do you think? It's your KIP in the end. I think we should
make this change and also "simplify" the KIP to drop implementation details.
--
This is an automated message
mjsax commented on PR #13533:
URL: https://github.com/apache/kafka/pull/13533#issuecomment-1509326373
I think it's better to keep the changes in this PR, because it's not related
to KIP-914, but to KIP-904.
I just rebased and updated this PR.
--
This is an automated message from
mjsax merged PR #13545:
URL: https://github.com/apache/kafka/pull/13545
--
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:
[
https://issues.apache.org/jira/browse/KAFKA-14904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17712556#comment-17712556
]
Justine Olshan commented on KAFKA-14904:
Marking as a blocker since the commit that caused this
[
https://issues.apache.org/jira/browse/KAFKA-14904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Justine Olshan updated KAFKA-14904:
---
Priority: Blocker (was: Major)
> Flaky Test
mjsax opened a new pull request, #13578:
URL: https://github.com/apache/kafka/pull/13578
*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
jeffkbkim commented on PR #13526:
URL: https://github.com/apache/kafka/pull/13526#issuecomment-1509245732
@dajac
> I recall that we discussed adding a mechanism to prevent adding non-tagged
fields in the future. Have you looked into this?
@hachikuji pointed out that we may
jeffkbkim commented on code in PR #13526:
URL: https://github.com/apache/kafka/pull/13526#discussion_r1167262801
##
core/src/test/scala/unit/kafka/coordinator/group/GroupMetadataManagerTest.scala:
##
@@ -2466,6 +2467,64 @@ class GroupMetadataManagerTest {
jeffkbkim commented on code in PR #13526:
URL: https://github.com/apache/kafka/pull/13526#discussion_r1167261871
##
group-coordinator/src/main/resources/common/message/GroupMetadataValue.json:
##
@@ -13,11 +13,14 @@
// See the License for the specific language governing
jeffkbkim commented on code in PR #13511:
URL: https://github.com/apache/kafka/pull/13511#discussion_r1167257449
##
core/src/main/scala/kafka/coordinator/transaction/TransactionLog.scala:
##
@@ -148,17 +149,23 @@ object TransactionLog {
// Formatter for use with tools to
mjsax opened a new pull request, #13577:
URL: https://github.com/apache/kafka/pull/13577
*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
jolshan commented on code in PR #12149:
URL: https://github.com/apache/kafka/pull/12149#discussion_r1167247268
##
clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java:
##
@@ -1294,7 +1309,10 @@ public void handleResponse(AbstractResponse
jolshan commented on code in PR #12149:
URL: https://github.com/apache/kafka/pull/12149#discussion_r1167246564
##
clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java:
##
@@ -607,6 +608,14 @@ public synchronized void
mjsax commented on PR #13576:
URL: https://github.com/apache/kafka/pull/13576#issuecomment-1509174831
Merged to `trunk` and cherry-picked to `3.5` branch.
Thanks for the follow up!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
mjsax merged PR #13576:
URL: https://github.com/apache/kafka/pull/13576
--
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:
mjsax commented on PR #13527:
URL: https://github.com/apache/kafka/pull/13527#issuecomment-1509166017
Merged to `trunk` and cherry-picked to `3.5` branch.
--
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
philipnee commented on code in PR #12149:
URL: https://github.com/apache/kafka/pull/12149#discussion_r1167231804
##
clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java:
##
@@ -1294,7 +1309,10 @@ public void handleResponse(AbstractResponse
philipnee commented on code in PR #12149:
URL: https://github.com/apache/kafka/pull/12149#discussion_r1167230503
##
clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java:
##
@@ -607,6 +608,14 @@ public synchronized void
David Arthur created KAFKA-14909:
Summary: KRaft Controllers not setting ZkMigrationReady tagged
field
Key: KAFKA-14909
URL: https://issues.apache.org/jira/browse/KAFKA-14909
Project: Kafka
dajac commented on code in PR #13526:
URL: https://github.com/apache/kafka/pull/13526#discussion_r1167208479
##
core/src/test/scala/unit/kafka/coordinator/group/GroupMetadataManagerTest.scala:
##
@@ -2466,6 +2467,64 @@ class GroupMetadataManagerTest {
mjsax merged PR #13527:
URL: https://github.com/apache/kafka/pull/13527
--
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:
mjsax commented on code in PR #13527:
URL: https://github.com/apache/kafka/pull/13527#discussion_r1167196102
##
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/HighAvailabilityTaskAssignorTest.java:
##
@@ -71,7 +67,23 @@
import static
mjsax commented on code in PR #13527:
URL: https://github.com/apache/kafka/pull/13527#discussion_r1167194742
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/AssignorConfiguration.java:
##
@@ -261,41 +261,29 @@ public interface AssignmentListener
[
https://issues.apache.org/jira/browse/KAFKA-14904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17712497#comment-17712497
]
Justine Olshan commented on KAFKA-14904:
The issue is the first request we verify is still in
[
https://issues.apache.org/jira/browse/KAFKA-14900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Harris reassigned KAFKA-14900:
---
Assignee: Colin McCabe (was: Greg Harris)
> Flaky test AuthorizerTest failing with NPE
>
jeqo commented on code in PR #12637:
URL: https://github.com/apache/kafka/pull/12637#discussion_r1167124072
##
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/field/SingleFieldPath.java:
##
@@ -0,0 +1,585 @@
+/*
+ * Licensed to the Apache Software
mjsax commented on PR #13534:
URL: https://github.com/apache/kafka/pull/13534#issuecomment-1509012485
Merged to `trunk` and cherry-picked to `3.5` branch.
--
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
jeqo commented on code in PR #12637:
URL: https://github.com/apache/kafka/pull/12637#discussion_r1167124072
##
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/field/SingleFieldPath.java:
##
@@ -0,0 +1,585 @@
+/*
+ * Licensed to the Apache Software
mumrah closed pull request #13574: DO NOT MERGE: Jenkins AuthorizerTest
investigation
URL: https://github.com/apache/kafka/pull/13574
--
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
mumrah merged PR #13543:
URL: https://github.com/apache/kafka/pull/13543
--
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:
philipnee commented on code in PR #12149:
URL: https://github.com/apache/kafka/pull/12149#discussion_r1167110290
##
clients/src/test/java/org/apache/kafka/clients/producer/KafkaProducerTest.java:
##
@@ -1237,6 +1238,34 @@ public void testInitTransactionWhileThrottled() {
bbejeck commented on PR #13527:
URL: https://github.com/apache/kafka/pull/13527#issuecomment-1508982838
I looked at the build and the test failures are unrelated to this PR
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
bbejeck commented on code in PR #13527:
URL: https://github.com/apache/kafka/pull/13527#discussion_r1167075556
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/AssignorConfiguration.java:
##
@@ -261,41 +261,29 @@ public interface
philipnee commented on code in PR #13477:
URL: https://github.com/apache/kafka/pull/13477#discussion_r1167095917
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordCollectorImpl.java:
##
@@ -212,11 +212,11 @@ public void send(final String topic,
philipnee commented on code in PR #13477:
URL: https://github.com/apache/kafka/pull/13477#discussion_r1167093584
##
streams/src/test/java/org/apache/kafka/streams/processor/internals/RecordCollectorTest.java:
##
@@ -1391,21 +1390,57 @@ public void
philipnee commented on PR #13576:
URL: https://github.com/apache/kafka/pull/13576#issuecomment-1508973679
@mjsax - I think.. this seems to be the way to do it? Originally I thought
we would just mock the producer, but this seems to work too.
--
This is an automated message from the
cmccabe merged PR #13553:
URL: https://github.com/apache/kafka/pull/13553
--
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:
mjsax commented on code in PR #13477:
URL: https://github.com/apache/kafka/pull/13477#discussion_r1167091288
##
streams/src/test/java/org/apache/kafka/streams/processor/internals/RecordCollectorTest.java:
##
@@ -1391,21 +1390,57 @@ public void
mjsax commented on code in PR #13477:
URL: https://github.com/apache/kafka/pull/13477#discussion_r1167090307
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordCollectorImpl.java:
##
@@ -212,11 +212,11 @@ public void send(final String topic,
cmccabe commented on PR #13280:
URL: https://github.com/apache/kafka/pull/13280#issuecomment-1508967636
@rondagostino BTW I still would like to understand what is wrong with
calling `values()` on the map (if anything) but let's take that discussion
offline and not block on it
--
This is
Hangleton commented on code in PR #13561:
URL: https://github.com/apache/kafka/pull/13561#discussion_r1167074461
##
core/src/main/java/kafka/log/remote/RemoteLogManager.java:
##
@@ -595,6 +609,193 @@ public void run() {
}
}
+public void
cmccabe commented on PR #13280:
URL: https://github.com/apache/kafka/pull/13280#issuecomment-1508964167
OK. It sounds like the consensus is that we should keep the "immutable"
naming then.
Thanks, @rondagostino , @showuon , @emissionnebula , @ijuma . LGTM
--
This is an automated
philipnee opened a new pull request, #13576:
URL: https://github.com/apache/kafka/pull/13576
We want to make sure the streamsProducer doesn't send upon handling the
error per comment here:
https://github.com/apache/kafka/pull/13477/commits/510f2aaf0808d3c543720dec8a6dd6b455b41460
--
cmccabe commented on code in PR #13280:
URL: https://github.com/apache/kafka/pull/13280#discussion_r1167076930
##
server-common/src/main/java/org/apache/kafka/server/immutable/ImmutableMap.java:
##
@@ -0,0 +1,47 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under
philipnee commented on code in PR #13477:
URL: https://github.com/apache/kafka/pull/13477#discussion_r1167075145
##
streams/src/test/java/org/apache/kafka/streams/processor/internals/RecordCollectorTest.java:
##
@@ -1391,21 +1390,57 @@ public void
mumrah commented on PR #13574:
URL: https://github.com/apache/kafka/pull/13574#issuecomment-1508946825
Merged in #13543
--
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
mumrah commented on PR #13574:
URL: https://github.com/apache/kafka/pull/13574#issuecomment-1508944703
AuthorizerTest failed a few times in the first run
https://ci-builds.apache.org/job/Kafka/job/kafka-pr/job/PR-13574/1/testReport/
--
This is an automated message from the Apache Git
jeffkbkim commented on code in PR #13526:
URL: https://github.com/apache/kafka/pull/13526#discussion_r1167066378
##
core/src/main/resources/common/message/TransactionLogValue.json:
##
@@ -13,27 +13,31 @@
// See the License for the specific language governing permissions and
jeffkbkim commented on code in PR #13526:
URL: https://github.com/apache/kafka/pull/13526#discussion_r1167065703
##
core/src/test/scala/unit/kafka/coordinator/group/GroupMetadataManagerTest.scala:
##
@@ -2466,6 +2467,64 @@ class GroupMetadataManagerTest {
gharris1727 opened a new pull request, #13575:
URL: https://github.com/apache/kafka/pull/13575
This fixes test failures introduced in KIP-894 #13373
These tests consistently pass locally with or without this change, but it
appears that Jenkins is more discerning. I do not know yet
mjsax merged PR #13534:
URL: https://github.com/apache/kafka/pull/13534
--
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:
philipnee commented on code in PR #13477:
URL: https://github.com/apache/kafka/pull/13477#discussion_r1167062912
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordCollectorImpl.java:
##
@@ -212,11 +212,11 @@ public void send(final String topic,
jeffkbkim commented on code in PR #13526:
URL: https://github.com/apache/kafka/pull/13526#discussion_r1167058951
##
core/src/test/scala/unit/kafka/coordinator/transaction/TransactionLogTest.scala:
##
@@ -135,4 +138,28 @@ class TransactionLogTest {
assertEquals(Some(""),
jolshan merged PR #13502:
URL: https://github.com/apache/kafka/pull/13502
--
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:
jeffkbkim commented on code in PR #13526:
URL: https://github.com/apache/kafka/pull/13526#discussion_r1167056232
##
core/src/test/scala/unit/kafka/coordinator/group/GroupMetadataManagerTest.scala:
##
@@ -2616,7 +2675,8 @@ class GroupMetadataManagerTest {
[
https://issues.apache.org/jira/browse/KAFKA-14904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17712459#comment-17712459
]
Justine Olshan commented on KAFKA-14904:
Further investigation shows this occurs after the
Hangleton commented on code in PR #13487:
URL: https://github.com/apache/kafka/pull/13487#discussion_r1167007616
##
core/src/main/java/kafka/log/remote/RemoteLogManager.java:
##
@@ -0,0 +1,719 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ *
Hangleton commented on PR #13487:
URL: https://github.com/apache/kafka/pull/13487#issuecomment-1508916524
> *Since this PR blocks other following PRs, I'm going to merge it soon. We
can have a follow-up PR to address any new comments if any. Thank you.*
Provided a few comments FYI
mumrah opened a new pull request, #13574:
URL: https://github.com/apache/kafka/pull/13574
This PR is only here to get some data out of Jenkins regarding the recent
AuthorizerTest failures. Do not merge this PR
--
This is an automated message from the Apache Git Service.
To respond to the
Hangleton commented on code in PR #13487:
URL: https://github.com/apache/kafka/pull/13487#discussion_r1166975428
##
core/src/main/java/kafka/log/remote/RemoteLogManager.java:
##
@@ -0,0 +1,719 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ *
jeffkbkim commented on code in PR #13511:
URL: https://github.com/apache/kafka/pull/13511#discussion_r1167009340
##
core/src/main/scala/kafka/coordinator/group/GroupMetadataManager.scala:
##
@@ -683,8 +685,10 @@ class GroupMetadataManager(brokerId: Int,
ijuma commented on PR #13373:
URL: https://github.com/apache/kafka/pull/13373#issuecomment-1508861550
Thanks for helping with this @gharris1727.
--
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
gharris1727 commented on PR #13373:
URL: https://github.com/apache/kafka/pull/13373#issuecomment-1508855593
Ticket for the failures introduced here:
https://issues.apache.org/jira/browse/KAFKA-14905
Some cursory investigation reveals that these tests hook into `alterConfigs`
via
ijuma commented on PR #13548:
URL: https://github.com/apache/kafka/pull/13548#issuecomment-1508828513
@gharris1727 I think what you did was fine. :) My concern is more on how we
decided that it was ok to merge. I looked a bit more and I think the issues
potentially started around here for
ijuma commented on PR #13373:
URL: https://github.com/apache/kafka/pull/13373#issuecomment-1508823431
It looks like we started getting a _lot_ of test failures after this PR:
https://ci-builds.apache.org/job/Kafka/job/kafka/job/trunk/1746/#showFailuresLink
I see a lot of the
gharris1727 commented on PR #13548:
URL: https://github.com/apache/kafka/pull/13548#issuecomment-1508814690
@ijuma I proposed this PR in the form I did because it restored a piece of
code that was unintentionally changed. From an end user-perspective, the
unintentional change was certainly
mjsax commented on PR #13563:
URL: https://github.com/apache/kafka/pull/13563#issuecomment-1508797441
Merged to `trunk` and cherry-picked to `3.5` branch.
--
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
ijuma commented on PR #13548:
URL: https://github.com/apache/kafka/pull/13548#issuecomment-1508774105
But how do we even know that this is helping vs making it worse with so many
failures?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
gharris1727 commented on PR #13548:
URL: https://github.com/apache/kafka/pull/13548#issuecomment-1508726959
@ijuma The scope of this PR was small, addressing just one issue. We
certainly have several flakey and failing tests that need to be addressed
during this test stabilization period.
Hangleton commented on code in PR #13535:
URL: https://github.com/apache/kafka/pull/13535#discussion_r1166887367
##
core/src/main/java/kafka/log/remote/RemoteLogManager.java:
##
@@ -600,6 +622,176 @@ public String toString() {
}
}
+public FetchDataInfo
Hangleton commented on code in PR #13535:
URL: https://github.com/apache/kafka/pull/13535#discussion_r1166887367
##
core/src/main/java/kafka/log/remote/RemoteLogManager.java:
##
@@ -600,6 +622,176 @@ public String toString() {
}
}
+public FetchDataInfo
[
https://issues.apache.org/jira/browse/KAFKA-4107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison updated KAFKA-4107:
--
Labels: kip (was: needs-kip)
> Support offset reset capability in Kafka Connect
>
[
https://issues.apache.org/jira/browse/KAFKA-4107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17712414#comment-17712414
]
Mickael Maison commented on KAFKA-4107:
---
This is being implemented by
Hangleton commented on code in PR #13535:
URL: https://github.com/apache/kafka/pull/13535#discussion_r1166846747
##
core/src/main/java/kafka/log/remote/RemoteLogManager.java:
##
@@ -600,6 +622,176 @@ public String toString() {
}
}
+public FetchDataInfo
divijvaidya commented on code in PR #13561:
URL: https://github.com/apache/kafka/pull/13561#discussion_r1166622209
##
core/src/main/java/kafka/log/remote/RemoteLogManager.java:
##
@@ -581,11 +588,18 @@ public void run() {
if (isLeader()) {
mjsax merged PR #13563:
URL: https://github.com/apache/kafka/pull/13563
--
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:
mumrah merged PR #13573:
URL: https://github.com/apache/kafka/pull/13573
--
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:
[
https://issues.apache.org/jira/browse/KAFKA-10892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison updated KAFKA-10892:
---
Fix Version/s: 3.6.0
> Add Topology#connectSourceStoreAndTopic as a public method
>
[
https://issues.apache.org/jira/browse/KAFKA-10892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison updated KAFKA-10892:
---
Labels: kip (was: )
> Add Topology#connectSourceStoreAndTopic as a public method
>
mumrah opened a new pull request, #13573:
URL: https://github.com/apache/kafka/pull/13573
Until the KRaft controller supports pre-migration mode, it is possible for
metadata updates to happen before the migration starts during tests.
--
This is an automated message from the Apache Git
ijuma commented on PR #13548:
URL: https://github.com/apache/kafka/pull/13548#issuecomment-1508573002
The PR build has 95 failures:
> Build / JDK 17 and Scala 2.13 /
org.apache.kafka.common.network.SslTransportLayerTest.[2] tlsProtocol=TLSv1.2,
useInlinePem=true
Build / JDK 17
[
https://issues.apache.org/jira/browse/KAFKA-14091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sudesh Wasnik reassigned KAFKA-14091:
-
Assignee: Sudesh Wasnik (was: Sagar Rao)
> Suddenly-killed tasks can leave hanging
urbandan commented on code in PR #13557:
URL: https://github.com/apache/kafka/pull/13557#discussion_r1166859143
##
clients/src/main/java/org/apache/kafka/common/utils/ThreadUtils.java:
##
@@ -52,4 +55,26 @@ public Thread newThread(Runnable r) {
}
};
}
viktorsomogyi commented on code in PR #13557:
URL: https://github.com/apache/kafka/pull/13557#discussion_r1166798950
##
clients/src/main/java/org/apache/kafka/common/utils/ThreadUtils.java:
##
@@ -52,4 +55,26 @@ public Thread newThread(Runnable r) {
}
};
dajac commented on PR #13537:
URL: https://github.com/apache/kafka/pull/13537#issuecomment-1508440940
@clolov Thanks for the comments. I have addressed them while rebasing the PR.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
[
https://issues.apache.org/jira/browse/KAFKA-7739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison updated KAFKA-7739:
--
Fix Version/s: 3.6.0
(was: 3.5.0)
> Kafka Tiered Storage
>
dajac merged PR #13536:
URL: https://github.com/apache/kafka/pull/13536
--
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:
dajac merged PR #13524:
URL: https://github.com/apache/kafka/pull/13524
--
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:
1 - 100 of 140 matches
Mail list logo
