Ge commented on code in PR #12393:
URL: https://github.com/apache/kafka/pull/12393#discussion_r998932827
##
streams/src/main/java/org/apache/kafka/streams/state/internals/AbstractTransactionalStore.java:
##
@@ -0,0 +1,442 @@
+/*
+ * Licensed to the Apache Software Foundation
Ge commented on code in PR #12393:
URL: https://github.com/apache/kafka/pull/12393#discussion_r998929720
##
streams/src/main/java/org/apache/kafka/streams/state/internals/AbstractTransactionalStore.java:
##
@@ -0,0 +1,442 @@
+/*
+ * Licensed to the Apache Software Foundation
Ge commented on code in PR #12393:
URL: https://github.com/apache/kafka/pull/12393#discussion_r998928697
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateManagerUtil.java:
##
@@ -115,7 +115,7 @@ static void closeStateManager(final Logger log,
Ge commented on code in PR #12393:
URL: https://github.com/apache/kafka/pull/12393#discussion_r998928697
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateManagerUtil.java:
##
@@ -115,7 +115,7 @@ static void closeStateManager(final Logger log,
ableegoldman commented on code in PR #12758:
URL: https://github.com/apache/kafka/pull/12758#discussion_r998896253
##
streams/src/main/java/org/apache/kafka/streams/internals/StreamsConfigUtils.java:
##
@@ -66,4 +73,28 @@ public static boolean eosEnabled(final ProcessingMode
pr
showuon commented on code in PR #12763:
URL: https://github.com/apache/kafka/pull/12763#discussion_r998898488
##
raft/src/main/java/org/apache/kafka/raft/FileBasedStateStore.java:
##
@@ -149,6 +149,7 @@ private void writeElectionStateToFile(final File stateFile,
QuorumStateData
showuon commented on code in PR #12753:
URL: https://github.com/apache/kafka/pull/12753#discussion_r998892134
##
clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java:
##
@@ -1581,6 +1581,10 @@ public void commitAsync(final Map offsets, Of
* is invoked
Ge commented on code in PR #12393:
URL: https://github.com/apache/kafka/pull/12393#discussion_r998842122
##
streams/src/main/java/org/apache/kafka/streams/state/internals/AbstractTransactionalStore.java:
##
@@ -0,0 +1,442 @@
+/*
+ * Licensed to the Apache Software Foundation
[
https://issues.apache.org/jira/browse/KAFKA-10760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17619908#comment-17619908
]
Jun Rao commented on KAFKA-10760:
-
A potential solution is to implement the time based s
[
https://issues.apache.org/jira/browse/KAFKA-14321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao resolved KAFKA-14321.
-
Resolution: Duplicate
This actually duplicates KAFKA-10760. Closing this one.
> max.compaction.lag.ms i
hachikuji commented on code in PR #12761:
URL: https://github.com/apache/kafka/pull/12761#discussion_r998837515
##
raft/src/main/java/org/apache/kafka/raft/OffsetAndEpoch.java:
##
@@ -25,6 +25,14 @@ public OffsetAndEpoch(long offset, int epoch) {
this.epoch = epoch;
[
https://issues.apache.org/jira/browse/KAFKA-14321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17619904#comment-17619904
]
Jun Rao commented on KAFKA-14321:
-
A potential solution is to implement the time based s
Jun Rao created KAFKA-14321:
---
Summary: max.compaction.lag.ms is not enforced accurately
Key: KAFKA-14321
URL: https://issues.apache.org/jira/browse/KAFKA-14321
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-4545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao resolved KAFKA-4545.
Fix Version/s: 3.1.0
Resolution: Fixed
This is fixed in KAFKA-8522.
> tombstone needs to be removed
[
https://issues.apache.org/jira/browse/KAFKA-10323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17619892#comment-17619892
]
Greg Harris commented on KAFKA-10323:
-
Also for completeness, here is the workaround
[
https://issues.apache.org/jira/browse/KAFKA-14316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson resolved KAFKA-14316.
-
Fix Version/s: 3.4.0
3.3.2
Resolution: Fixed
> NoSuchElementEx
[
https://issues.apache.org/jira/browse/KAFKA-10323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17619891#comment-17619891
]
Greg Harris commented on KAFKA-10323:
-
[~geliba] reported that this is still an issu
hachikuji opened a new pull request, #12767:
URL: https://github.com/apache/kafka/pull/12767
The file `metadata/.jqwik-database` was checked in by mistake in
https://github.com/apache/kafka/pull/12747. In trunk, we exclude this file in
`.gitignore`, so I've done so here as well.
###
jlisam opened a new pull request, #12766:
URL: https://github.com/apache/kafka/pull/12766
[KAFKA-14320](https://issues.apache.org/jira/browse/KAFKA-14320) Upgrade
Jackson for CVE fix.
Jackson: (CVE-2020-36518)[https://nvd.nist.gov/vuln/detail/CVE-2020-36518] -
Fixed by upgrading to 2
[
https://issues.apache.org/jira/browse/KAFKA-14320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Javier Li Sam updated KAFKA-14320:
--
Summary: Upgrade Jackson for CVE fix (was: Upgrade Jackson for CVE fixes)
> Upgrade Jackson f
[
https://issues.apache.org/jira/browse/KAFKA-13486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17619887#comment-17619887
]
Greg Harris commented on KAFKA-13486:
-
I don't believe that the REST listeners are r
[
https://issues.apache.org/jira/browse/KAFKA-13486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Harris resolved KAFKA-13486.
-
Resolution: Duplicate
> Kafka Connect: Failed to start task due to NPE
> ---
[
https://issues.apache.org/jira/browse/KAFKA-14320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Javier Li Sam updated KAFKA-14320:
--
Description:
There is a CVE for Jackson:
Jackson: [CVE-2020-36518|https://nvd.nist.gov/vuln/d
Javier Li Sam created KAFKA-14320:
-
Summary: Upgrade Jackson for CVE fixes
Key: KAFKA-14320
URL: https://issues.apache.org/jira/browse/KAFKA-14320
Project: Kafka
Issue Type: Bug
Com
hachikuji merged PR #12765:
URL: https://github.com/apache/kafka/pull/12765
--
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.apach
philipnee commented on code in PR #12746:
URL: https://github.com/apache/kafka/pull/12746#discussion_r998768064
##
clients/src/main/java/org/apache/kafka/clients/FetchSessionHandler.java:
##
@@ -402,7 +402,7 @@ private String
topicIdPartitionsToLogString(Collection partiti
jsancio merged PR #12747:
URL: https://github.com/apache/kafka/pull/12747
--
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.
cmccabe commented on code in PR #12747:
URL: https://github.com/apache/kafka/pull/12747#discussion_r998736297
##
metadata/src/main/java/org/apache/kafka/controller/QuorumController.java:
##
@@ -1481,8 +1498,7 @@ private void resetToEmptyState() {
snapshotGeneratorManage
[
https://issues.apache.org/jira/browse/KAFKA-14307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
José Armando García Sancio updated KAFKA-14307:
---
Fix Version/s: 3.4.0
> KRaft controller time based snapshots
> -
[
https://issues.apache.org/jira/browse/KAFKA-14286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
José Armando García Sancio updated KAFKA-14286:
---
Fix Version/s: 3.4.0
> Time based cluster metadata snapshots
> -
jsancio commented on code in PR #12747:
URL: https://github.com/apache/kafka/pull/12747#discussion_r998729598
##
metadata/src/main/java/org/apache/kafka/controller/QuorumController.java:
##
@@ -1481,8 +1498,7 @@ private void resetToEmptyState() {
snapshotGeneratorManage
[
https://issues.apache.org/jira/browse/KAFKA-13546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton updated KAFKA-13546:
--
Fix Version/s: 3.4.0
> Explicitly specifying default topic creation groups should not make con
cmccabe commented on code in PR #12747:
URL: https://github.com/apache/kafka/pull/12747#discussion_r998722714
##
metadata/src/main/java/org/apache/kafka/controller/QuorumController.java:
##
@@ -1481,8 +1498,7 @@ private void resetToEmptyState() {
snapshotGeneratorManage
cmccabe commented on PR #12747:
URL: https://github.com/apache/kafka/pull/12747#issuecomment-1283019130
looks good overall, but it seems to me like resetToEmptyState should still
reset this to 0.
--
This is an automated message from the Apache Git Service.
To respond to the message, pleas
[
https://issues.apache.org/jira/browse/KAFKA-13989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Harris reassigned KAFKA-13989:
---
Assignee: Greg Harris
> Get connectors call fails when plugin removed
> ---
[
https://issues.apache.org/jira/browse/KAFKA-14206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17619788#comment-17619788
]
Igor Soarez commented on KAFKA-14206:
-
[~showuon] as the PR was closed and as per co
Jason Gustafson created KAFKA-14319:
---
Summary: Storage tool format command does not work with old
metadata versions
Key: KAFKA-14319
URL: https://issues.apache.org/jira/browse/KAFKA-14319
Project: K
A. Sophie Blee-Goldman created KAFKA-14318:
--
Summary: KIP-878: Autoscaling for Statically Partitioned Streams
Key: KAFKA-14318
URL: https://issues.apache.org/jira/browse/KAFKA-14318
Project: K
[
https://issues.apache.org/jira/browse/KAFKA-14000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17619780#comment-17619780
]
Greg Harris commented on KAFKA-14000:
-
This looks like similar symptoms as
https://
[
https://issues.apache.org/jira/browse/KAFKA-14037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Harris updated KAFKA-14037:
Component/s: mirrormaker
> Stopping mm2 meets ExecutionException for MirrorCheckpointTask
> --
[
https://issues.apache.org/jira/browse/KAFKA-14023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Harris updated KAFKA-14023:
Component/s: mirrormaker
> MirrorCheckpointTask.syncGroupOffset does not have to check if transla
[
https://issues.apache.org/jira/browse/KAFKA-14137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Harris resolved KAFKA-14137.
-
Resolution: Fixed
> Security Vulnerabilities reported in CVE-2021-45046 and CVE-2021-45046
> ---
[
https://issues.apache.org/jira/browse/KAFKA-14137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17619773#comment-17619773
]
Greg Harris commented on KAFKA-14137:
-
[~createdtotrackissues] I believe this should
cadonna commented on code in PR #12762:
URL: https://github.com/apache/kafka/pull/12762#discussion_r998636964
##
streams/src/test/java/org/apache/kafka/streams/processor/internals/DefaultStateUpdaterTest.java:
##
@@ -658,6 +658,29 @@ public void
shouldUpdateStandbyTaskAfterAllA
cadonna merged PR #12749:
URL: https://github.com/apache/kafka/pull/12749
--
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.
cadonna commented on PR #12749:
URL: https://github.com/apache/kafka/pull/12749#issuecomment-1282904554
Restarted the build and failures are unrelated:
[Build / JDK 17 and Scala 2.13 /
org.apache.kafka.connect.mirror.integration.IdentityReplicationIntegrationTest.testReplicationWithEm
[
https://issues.apache.org/jira/browse/KAFKA-14317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14317:
--
Summary: ProduceRequest timeouts are logged as network exceptions (was:
Producer request timeouts are
[
https://issues.apache.org/jira/browse/KAFKA-14317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14317:
--
Description:
In NetworkClient.handleTimedOutRequests, we disconnect the broker connection:
{code:jav
Kirk True created KAFKA-14317:
-
Summary: Producer request timeouts are logged as network exceptions
Key: KAFKA-14317
URL: https://issues.apache.org/jira/browse/KAFKA-14317
Project: Kafka
Issue Ty
[
https://issues.apache.org/jira/browse/KAFKA-14315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17619729#comment-17619729
]
Travis Bischel commented on KAFKA-14315:
Note that I've also had requests repeat
hachikuji opened a new pull request, #12765:
URL: https://github.com/apache/kafka/pull/12765
The iterator `FeatureControlIterator.hasNext()` checks two conditions: 1)
whether we have already written the metadata version, and 2) whether the
underlying iterator has additional records. However
Jason Gustafson created KAFKA-14316:
---
Summary: NoSuchElementException in feature control iterator
Key: KAFKA-14316
URL: https://issues.apache.org/jira/browse/KAFKA-14316
Project: Kafka
Issu
Travis Bischel created KAFKA-14315:
--
Summary: Kraft: 1 broker setup, broker took 34 seconds to
transition from PrepareCommit to CompleteCommit
Key: KAFKA-14315
URL: https://issues.apache.org/jira/browse/KAFKA-143
philipnee commented on code in PR #12672:
URL: https://github.com/apache/kafka/pull/12672#discussion_r998551146
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/EventHandler.java:
##
@@ -30,6 +30,14 @@ public interface EventHandler {
*/
Opti
philipnee commented on code in PR #12672:
URL: https://github.com/apache/kafka/pull/12672#discussion_r998548854
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/DefaultEventHandler.java:
##
@@ -16,45 +16,185 @@
*/
package org.apache.kafka.clients.consumer.
philipnee commented on code in PR #12672:
URL: https://github.com/apache/kafka/pull/12672#discussion_r998532115
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/DefaultBackgroundThread.java:
##
@@ -0,0 +1,226 @@
+/*
+ * Licensed to the Apache Software Foundat
philipnee commented on code in PR #12672:
URL: https://github.com/apache/kafka/pull/12672#discussion_r998527530
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/DefaultBackgroundThread.java:
##
@@ -0,0 +1,226 @@
+/*
+ * Licensed to the Apache Software Foundat
philipnee commented on code in PR #12672:
URL: https://github.com/apache/kafka/pull/12672#discussion_r998526630
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/DefaultBackgroundThread.java:
##
@@ -0,0 +1,226 @@
+/*
+ * Licensed to the Apache Software Foundat
philipnee commented on code in PR #12672:
URL: https://github.com/apache/kafka/pull/12672#discussion_r998525478
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/DefaultBackgroundThread.java:
##
@@ -0,0 +1,226 @@
+/*
+ * Licensed to the Apache Software Foundat
philipnee commented on code in PR #12672:
URL: https://github.com/apache/kafka/pull/12672#discussion_r998524805
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/DefaultBackgroundThread.java:
##
@@ -0,0 +1,226 @@
+/*
+ * Licensed to the Apache Software Foundat
kirktrue commented on code in PR #12672:
URL: https://github.com/apache/kafka/pull/12672#discussion_r998485196
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/EventHandler.java:
##
@@ -30,6 +30,14 @@ public interface EventHandler {
*/
Optio
dajac commented on PR #12748:
URL: https://github.com/apache/kafka/pull/12748#issuecomment-1282700266
Thanks for the PR, @showuon. Is it ready for review? I will help you to get
it in.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
lucasbru commented on PR #12762:
URL: https://github.com/apache/kafka/pull/12762#issuecomment-1282691414
@cadonna @guozhangwang
Could you have a look?
The test failures look unrelated.
```
Build / JDK 17 and Scala 2.13 /
testTransactionAfterProducerIdExpires(String).quor
C0urante commented on code in PR #10528:
URL: https://github.com/apache/kafka/pull/10528#discussion_r998473517
##
build.gradle:
##
@@ -1205,6 +1205,7 @@ project(':clients') {
testImplementation libs.bcpkix
testImplementation libs.junitJupiter
+testImplementation
C0urante opened a new pull request, #12764:
URL: https://github.com/apache/kafka/pull/12764
https://github.com/apache/kafka/pull/10528 accidentally added a duplicate
dependency on Log4j; this change removes it, and also groups the dependencies
by scope to tidy things up a bit.
### Co
lucasbru commented on PR #12749:
URL: https://github.com/apache/kafka/pull/12749#issuecomment-1282671259
There are some errors related to missing state again. But again, it doesn't
look related. Can we merge it?
```
Build / JDK 11 and Scala 2.13 /
testLargeAssignmentAndGroupWithNo
ijuma commented on code in PR #10528:
URL: https://github.com/apache/kafka/pull/10528#discussion_r998453999
##
build.gradle:
##
@@ -1205,6 +1205,7 @@ project(':clients') {
testImplementation libs.bcpkix
testImplementation libs.junitJupiter
+testImplementation lib
ijuma commented on code in PR #10528:
URL: https://github.com/apache/kafka/pull/10528#discussion_r998451795
##
build.gradle:
##
@@ -1205,6 +1205,7 @@ project(':clients') {
testImplementation libs.bcpkix
testImplementation libs.junitJupiter
+testImplementation lib
renaldobf opened a new pull request, #12763:
URL: https://github.com/apache/kafka/pull/12763
Windows does not allow moving a file if a file descriptor is still opened.
Closing the FileOutputStream prior to moving the file fix the issue.
--
This is an automated message from the Apache Gi
[
https://issues.apache.org/jira/browse/KAFKA-14314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison reassigned KAFKA-14314:
--
Assignee: John Krupka
> MirrorSourceConnector throwing NPE during `isCycle` check
> -
[
https://issues.apache.org/jira/browse/KAFKA-14314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17619564#comment-17619564
]
Mickael Maison edited comment on KAFKA-14314 at 10/18/22 1:49 PM:
[
https://issues.apache.org/jira/browse/KAFKA-14314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17619564#comment-17619564
]
Mickael Maison commented on KAFKA-14314:
Great, I'll assign this ticket to you t
[
https://issues.apache.org/jira/browse/KAFKA-14314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17619555#comment-17619555
]
John Krupka commented on KAFKA-14314:
-
Thanks, Mickael. Sure I can do that. I though
[
https://issues.apache.org/jira/browse/KAFKA-14314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17619540#comment-17619540
]
Mickael Maison commented on KAFKA-14314:
Thanks for the details.
The Replicatio
OmniaGM commented on PR #12577:
URL: https://github.com/apache/kafka/pull/12577#issuecomment-1282380207
> The `MirrorMakerConfigTest` tests the config part, but there's nothing
that proves that the configured ForwardingAdmin is actually used when creating
topics, ACLs etc. That might not be
[
https://issues.apache.org/jira/browse/KAFKA-14314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17619514#comment-17619514
]
John Krupka commented on KAFKA-14314:
-
We're using a custom replication policy. Here
OmniaGM commented on code in PR #12577:
URL: https://github.com/apache/kafka/pull/12577#discussion_r998207034
##
clients/src/main/java/org/apache/kafka/clients/admin/ForwardingAdmin.java:
##
@@ -0,0 +1,284 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or
OmniaGM commented on code in PR #12577:
URL: https://github.com/apache/kafka/pull/12577#discussion_r998206276
##
connect/mirror-client/src/main/java/org/apache/kafka/connect/mirror/MirrorClientConfig.java:
##
@@ -56,7 +58,10 @@ public class MirrorClientConfig extends AbstractCon
ijuma commented on PR #12750:
URL: https://github.com/apache/kafka/pull/12750#issuecomment-1282365842
I went ahead and merged this since it's a clear improvement over what we
have. We can do follow up PRs for further improvements.
--
This is an automated message from the Apache Git Servic
ijuma merged PR #12750:
URL: https://github.com/apache/kafka/pull/12750
--
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-14314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17619486#comment-17619486
]
Mickael Maison commented on KAFKA-14314:
Which replication policy are you using?
soarez commented on code in PR #12752:
URL: https://github.com/apache/kafka/pull/12752#discussion_r998077249
##
core/src/test/scala/unit/kafka/server/ProduceRequestTest.scala:
##
@@ -246,6 +248,18 @@ class ProduceRequestTest extends BaseRequestTest {
assertEquals(Errors.UNS
John Krupka created KAFKA-14314:
---
Summary: MirrorSourceConnector throwing NPE during `isCycle` check
Key: KAFKA-14314
URL: https://issues.apache.org/jira/browse/KAFKA-14314
Project: Kafka
Issue
lucasbru commented on PR #12749:
URL: https://github.com/apache/kafka/pull/12749#issuecomment-1282186142
Right, sorry, I misread your comment.
--
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
cadonna commented on PR #12749:
URL: https://github.com/apache/kafka/pull/12749#issuecomment-1282160492
Didn't you want to add a unit test for case `state ==
State.PARTITIONS_ASSIGNED && !stateUpdaterEnabled` in this PR? See
https://github.com/apache/kafka/pull/12749#discussion_r997214392.
cadonna merged PR #12743:
URL: https://github.com/apache/kafka/pull/12743
--
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.
cadonna commented on PR #12743:
URL: https://github.com/apache/kafka/pull/12743#issuecomment-1282155668
Failures are unrelated:
```
Build / JDK 17 and Scala 2.13 /
org.apache.kafka.trogdor.coordinator.CoordinatorTest.testTaskRequestWithOldStartMsGetsUpdated()
```
--
This is an au
cadonna commented on PR #12743:
URL: https://github.com/apache/kafka/pull/12743#issuecomment-1282155000
Yes, of course. Sorry I lost track of this one! Thank you for pinging me!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
lucasbru commented on PR #12743:
URL: https://github.com/apache/kafka/pull/12743#issuecomment-1282152031
@cadonna can we please merge this 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 to the
lucasbru commented on PR #12749:
URL: https://github.com/apache/kafka/pull/12749#issuecomment-1282151422
Makes sense. So @cadonna can we please merge this 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 a
lucasbru opened a new pull request, #12762:
URL: https://github.com/apache/kafka/pull/12762
In two situations, the current code could transition the `ChangelogReader`
to `UpdateStandby` when already in that state, causing and
`InvalidStateException`. Namely these two cases are:
cadonna commented on PR #12749:
URL: https://github.com/apache/kafka/pull/12749#issuecomment-1281970016
`SmokeTestDriverIntegrationTest` seems to fail due to an input topic that
could not be created on the broker. Might by a glitch in this specific run.
Let's monitor that test in the next r
[
https://issues.apache.org/jira/browse/KAFKA-14313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17619308#comment-17619308
]
Luke Chen commented on KAFKA-14313:
---
[~dengziming] , the issue is discussed
[here|htt
[
https://issues.apache.org/jira/browse/KAFKA-14313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17619281#comment-17619281
]
Deng Ziming commented on KAFKA-14313:
-
Hello [~twmb] , Can you also provide your cod
lucasbru commented on PR #12760:
URL: https://github.com/apache/kafka/pull/12760#issuecomment-1281917222
Test failure is unrelated.
A passing system test run for stream_upgrade_test.py is shown on
https://jenkins.confluent.io/job/system-test-kafka-branch-builder/5176/consoleText
--
showuon commented on code in PR #12752:
URL: https://github.com/apache/kafka/pull/12752#discussion_r997795605
##
core/src/test/scala/unit/kafka/server/ProduceRequestTest.scala:
##
@@ -246,6 +248,18 @@ class ProduceRequestTest extends BaseRequestTest {
assertEquals(Errors.UN
96 matches
Mail list logo
