dajac commented on code in PR #12901:
URL: https://github.com/apache/kafka/pull/12901#discussion_r1069047687
##
core/src/main/scala/kafka/server/KafkaApis.scala:
##
@@ -2464,90 +2464,108 @@ class KafkaApis(val requestChannel: RequestChannel,
}
}
- def
dajac commented on PR #12901:
URL: https://github.com/apache/kafka/pull/12901#issuecomment-1381438609
Failed tests are not related.
--
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
cmccabe commented on code in PR #13108:
URL: https://github.com/apache/kafka/pull/13108#discussion_r1068983515
##
metadata/src/main/java/org/apache/kafka/image/MetadataProvenance.java:
##
@@ -28,30 +29,30 @@
public final class MetadataProvenance {
public static final
[
https://issues.apache.org/jira/browse/KAFKA-14568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismael Juma resolved KAFKA-14568.
-
Resolution: Fixed
> Move FetchDataInfo and related to storage module
>
ijuma merged PR #13085:
URL: https://github.com/apache/kafka/pull/13085
--
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:
ijuma commented on PR #13085:
URL: https://github.com/apache/kafka/pull/13085#issuecomment-1381334743
JDK 8 and 11 builds passed, 17 had 2 unrelated failures.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
jeffkbkim commented on code in PR #12901:
URL: https://github.com/apache/kafka/pull/12901#discussion_r1068928367
##
core/src/main/scala/kafka/server/KafkaApis.scala:
##
@@ -2464,90 +2464,108 @@ class KafkaApis(val requestChannel: RequestChannel,
}
}
- def
[
https://issues.apache.org/jira/browse/KAFKA-14459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17676431#comment-17676431
]
Sujay Hegde commented on KAFKA-14459:
-
Hi [~ableegoldman] .
Sure will have a look and get back
jsancio commented on code in PR #13108:
URL: https://github.com/apache/kafka/pull/13108#discussion_r1068830987
##
metadata/src/main/java/org/apache/kafka/image/MetadataProvenance.java:
##
@@ -28,30 +29,30 @@
public final class MetadataProvenance {
public static final
jsancio opened a new pull request, #13108:
URL: https://github.com/apache/kafka/pull/13108
The KRaft client expects the offset of the snapshot id to be an end offset.
End offsets are exclusive. The MetadataProvenance type was createing a snapshot
id using the last contained offset which is
jolshan commented on code in PR #13107:
URL: https://github.com/apache/kafka/pull/13107#discussion_r1068804579
##
core/src/main/scala/kafka/controller/ControllerChannelManager.scala:
##
@@ -436,17 +436,22 @@ abstract class
AbstractControllerBrokerRequestBatch(config:
[
https://issues.apache.org/jira/browse/KAFKA-14612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson resolved KAFKA-14612.
-
Fix Version/s: 3.4.0
Resolution: Fixed
> Topic config records written to log
ijuma commented on code in PR #13085:
URL: https://github.com/apache/kafka/pull/13085#discussion_r1068799278
##
storage/src/main/java/org/apache/kafka/server/log/internals/FetchParams.java:
##
@@ -0,0 +1,125 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
ijuma commented on code in PR #13085:
URL: https://github.com/apache/kafka/pull/13085#discussion_r1068798767
##
core/src/test/scala/unit/kafka/server/ReplicaAlterLogDirsThreadTest.scala:
##
@@ -276,25 +276,22 @@ class ReplicaAlterLogDirsThreadTest {
val callbackCaptor:
ijuma commented on code in PR #13085:
URL: https://github.com/apache/kafka/pull/13085#discussion_r1068799077
##
storage/src/main/java/org/apache/kafka/server/log/internals/FetchDataInfo.java:
##
@@ -0,0 +1,78 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
[
https://issues.apache.org/jira/browse/KAFKA-14618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
José Armando García Sancio reassigned KAFKA-14618:
--
Assignee: José Armando García Sancio (was: Jason Gustafson)
hachikuji merged PR #13104:
URL: https://github.com/apache/kafka/pull/13104
--
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-14565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17676359#comment-17676359
]
Terry Beard edited comment on KAFKA-14565 at 1/13/23 12:12 AM:
---
hachikuji commented on code in PR #13107:
URL: https://github.com/apache/kafka/pull/13107#discussion_r1068783227
##
core/src/main/scala/kafka/controller/ControllerChannelManager.scala:
##
@@ -436,17 +436,22 @@ abstract class
AbstractControllerBrokerRequestBatch(config:
hachikuji commented on code in PR #13107:
URL: https://github.com/apache/kafka/pull/13107#discussion_r1068783227
##
core/src/main/scala/kafka/controller/ControllerChannelManager.scala:
##
@@ -436,17 +436,22 @@ abstract class
AbstractControllerBrokerRequestBatch(config:
mjsax closed pull request #9328: MINOR: Add deleteDir for streams quickstart
test
URL: https://github.com/apache/kafka/pull/9328
--
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
mjsax commented on PR #9328:
URL: https://github.com/apache/kafka/pull/9328#issuecomment-1381110829
Closing as stale.
--
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
jolshan commented on code in PR #13107:
URL: https://github.com/apache/kafka/pull/13107#discussion_r1068766335
##
core/src/main/scala/kafka/controller/ControllerChannelManager.scala:
##
@@ -436,17 +436,22 @@ abstract class
AbstractControllerBrokerRequestBatch(config:
José Armando García Sancio created KAFKA-14620:
--
Summary: Add a type for SnapshotId
Key: KAFKA-14620
URL: https://issues.apache.org/jira/browse/KAFKA-14620
Project: Kafka
Issue
José Armando García Sancio created KAFKA-14619:
--
Summary: KRaft validate snapshot id are at batch boundries
Key: KAFKA-14619
URL: https://issues.apache.org/jira/browse/KAFKA-14619
[
https://issues.apache.org/jira/browse/KAFKA-14618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
José Armando García Sancio updated KAFKA-14618:
---
Description: We implemented new snapshot generation logic here:
[
https://issues.apache.org/jira/browse/KAFKA-14618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
José Armando García Sancio updated KAFKA-14618:
---
Description: We implemented new snapshot generation logic here:
hachikuji opened a new pull request, #13107:
URL: https://github.com/apache/kafka/pull/13107
When a reassignment is cancelled, we need to delete the partition state of
adding replicas. Failing to do so causes "stray" partitions which take up disk
space and can cause topicId conflicts if
mjsax commented on PR #12608:
URL: https://github.com/apache/kafka/pull/12608#issuecomment-1381081214
@Danny02 -- Are you still interested to finish this PR?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
Jason Gustafson created KAFKA-14618:
---
Summary: Off by one error in generated snapshot IDs causes
misaligned fetching
Key: KAFKA-14618
URL: https://issues.apache.org/jira/browse/KAFKA-14618
Project:
mjsax commented on PR #11047:
URL: https://github.com/apache/kafka/pull/11047#issuecomment-1381080907
@tang7526 -- are you still interested to finish this PR?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
mjsax commented on code in PR #12742:
URL: https://github.com/apache/kafka/pull/12742#discussion_r1068740650
##
streams/src/main/java/org/apache/kafka/streams/Topology.java:
##
@@ -737,6 +737,85 @@ public synchronized Topology addStateStore(final
StoreBuilder storeBuilder,
[
https://issues.apache.org/jira/browse/KAFKA-14565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17676359#comment-17676359
]
Terry Beard edited comment on KAFKA-14565 at 1/12/23 10:33 PM:
---
[
https://issues.apache.org/jira/browse/KAFKA-14565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17676359#comment-17676359
]
Terry Beard commented on KAFKA-14565:
-
[~ChrisEgerton] I understood you the first time. However,
[
https://issues.apache.org/jira/browse/KAFKA-14617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Calvin Liu reassigned KAFKA-14617:
--
Assignee: Calvin Liu
> Replicas with stale broker epoch should not be allowed to join the
Calvin Liu created KAFKA-14617:
--
Summary: Replicas with stale broker epoch should not be allowed to
join the ISR
Key: KAFKA-14617
URL: https://issues.apache.org/jira/browse/KAFKA-14617
Project: Kafka
dajac commented on PR #12797:
URL: https://github.com/apache/kafka/pull/12797#issuecomment-1380988519
Should we add unit tests?
--
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
hachikuji closed pull request #12271: KAFKA-13972; Ensure that replicas are
stopped after cancelled reassignment
URL: https://github.com/apache/kafka/pull/12271
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
hachikuji commented on PR #12271:
URL: https://github.com/apache/kafka/pull/12271#issuecomment-1380969366
I'm going to close this PR and submit a new one which is tailored a little
more closely to the problem with cancellation. I think there's not much
appetite at the moment for a big
C0urante commented on code in PR #12941:
URL: https://github.com/apache/kafka/pull/12941#discussion_r1068558694
##
docs/connect.html:
##
@@ -369,6 +369,114 @@ Error Reportin
# Tolerate all errors.
errors.tolerance=all
+Exactly-once
support
+
+Kafka Connect is
C0urante commented on PR #13106:
URL: https://github.com/apache/kafka/pull/13106#issuecomment-1380913304
cc @mjsax
--
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
C0urante opened a new pull request, #13106:
URL: https://github.com/apache/kafka/pull/13106
Filed in response to
[discussion](https://github.com/apache/kafka/pull/12941#discussion_r1057921805)
on the PR that added docs for exactly-once support in Connect.
--
This is an automated message
dajac commented on code in PR #12901:
URL: https://github.com/apache/kafka/pull/12901#discussion_r1068554964
##
core/src/main/scala/kafka/coordinator/group/GroupCoordinatorAdapter.scala:
##
@@ -397,19 +389,24 @@ class GroupCoordinatorAdapter(
request:
andymg3 commented on code in PR #13104:
URL: https://github.com/apache/kafka/pull/13104#discussion_r1068539671
##
metadata/src/test/java/org/apache/kafka/controller/ReplicationControlManagerTest.java:
##
@@ -605,6 +617,45 @@ public void testCreateTopicsWithConfigs() throws
hachikuji commented on code in PR #13104:
URL: https://github.com/apache/kafka/pull/13104#discussion_r1068504478
##
metadata/src/test/java/org/apache/kafka/controller/ReplicationControlManagerTest.java:
##
@@ -605,6 +617,45 @@ public void testCreateTopicsWithConfigs() throws
sjetha commented on PR #12331:
URL: https://github.com/apache/kafka/pull/12331#issuecomment-1380820361
This is a really important fix for Windows. Can someone help move this
along, please?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
jolshan commented on code in PR #12901:
URL: https://github.com/apache/kafka/pull/12901#discussion_r1068469845
##
core/src/main/scala/kafka/coordinator/group/GroupCoordinatorAdapter.scala:
##
@@ -397,19 +389,24 @@ class GroupCoordinatorAdapter(
request:
dajac commented on code in PR #12902:
URL: https://github.com/apache/kafka/pull/12902#discussion_r1068450233
##
core/src/main/scala/kafka/server/KafkaApis.scala:
##
@@ -3110,61 +3110,69 @@ class KafkaApis(val requestChannel: RequestChannel,
}
}
- def
cmccabe merged PR #13089:
URL: https://github.com/apache/kafka/pull/13089
--
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-14603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17676282#comment-17676282
]
Ivan Yurchenko commented on KAFKA-14603:
Thank you [~satish.duggana]. I'll move PR out of the
cmccabe commented on PR #13089:
URL: https://github.com/apache/kafka/pull/13089#issuecomment-1380795169
> One question I had is, do we see interrupts in production environments, or
just on Jenkins? I would expect KafkaEventQueue to normally get shutdown
cleanly via the normal shutdown
dajac commented on PR #12901:
URL: https://github.com/apache/kafka/pull/12901#issuecomment-1380781953
@jolshan @jeffkbkim Updated the PR.
--
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
[
https://issues.apache.org/jira/browse/KAFKA-14615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17676268#comment-17676268
]
Kamalesh Palanisamy commented on KAFKA-14615:
-
Oh okay. How do I find out Jira tasks related
dajac merged PR #12886:
URL: https://github.com/apache/kafka/pull/12886
--
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 commented on PR #12886:
URL: https://github.com/apache/kafka/pull/12886#issuecomment-1380731056
I will go ahead and merge it. I can do follow-ups if needed.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
dajac commented on PR #12886:
URL: https://github.com/apache/kafka/pull/12886#issuecomment-1380727110
Failed tests are not related.
--
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
jolshan commented on PR #12886:
URL: https://github.com/apache/kafka/pull/12886#issuecomment-1380723669
Still looks good to me
--
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
[
https://issues.apache.org/jira/browse/KAFKA-14611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17676260#comment-17676260
]
David Arthur commented on KAFKA-14611:
--
The commit for this fix was incorrectly labelled with
[
https://issues.apache.org/jira/browse/KAFKA-14611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Arthur resolved KAFKA-14611.
--
Resolution: Fixed
> ZK broker should not send epoch during registration
>
[
https://issues.apache.org/jira/browse/KAFKA-14611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Arthur updated KAFKA-14611:
-
Fix Version/s: 3.5.0
> ZK broker should not send epoch during registration
>
[
https://issues.apache.org/jira/browse/KAFKA-14615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17676256#comment-17676256
]
Divij Vaidya commented on KAFKA-14615:
--
Hey Kamalesh
Thank you for your interest in making this
ijuma commented on PR #13098:
URL: https://github.com/apache/kafka/pull/13098#issuecomment-1380693617
Yay for deleting code. Worth explaining in the PR why we can delete this now.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
ijuma commented on PR #11743:
URL: https://github.com/apache/kafka/pull/11743#issuecomment-1380691131
@woja Good call out. Would you like to submit a PR to fix it? cc @omkreddy
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
woja commented on PR #11743:
URL: https://github.com/apache/kafka/pull/11743#issuecomment-1380686527
(apologies if this is not the place for this - if not please forward this or
redirect me!)
Since this is included in 3.2.0 (and cherry picked to 3.1) the cve list
(here
andymg3 commented on code in PR #13104:
URL: https://github.com/apache/kafka/pull/13104#discussion_r1067622366
##
metadata/src/test/java/org/apache/kafka/controller/ReplicationControlManagerTest.java:
##
@@ -605,6 +617,45 @@ public void testCreateTopicsWithConfigs() throws
[
https://issues.apache.org/jira/browse/KAFKA-14615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17676239#comment-17676239
]
Kamalesh Palanisamy commented on KAFKA-14615:
-
[~divijvaidya] I am looking into this issue
[
https://issues.apache.org/jira/browse/KAFKA-14615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kamalesh Palanisamy reassigned KAFKA-14615:
---
Assignee: Kamalesh Palanisamy
> Use sizeCompare(Iterable[_]) to compare
dajac commented on code in PR #12901:
URL: https://github.com/apache/kafka/pull/12901#discussion_r1068262843
##
core/src/test/scala/unit/kafka/coordinator/group/GroupCoordinatorAdapterTest.scala:
##
@@ -58,7 +62,7 @@ class GroupCoordinatorAdapterTest {
dajac commented on code in PR #12901:
URL: https://github.com/apache/kafka/pull/12901#discussion_r1068262236
##
core/src/main/scala/kafka/server/KafkaApis.scala:
##
@@ -2464,90 +2464,108 @@ class KafkaApis(val requestChannel: RequestChannel,
}
}
- def
dajac commented on PR #12886:
URL: https://github.com/apache/kafka/pull/12886#issuecomment-1380487750
@jeffkbkim @jolshan I updated the PR.
--
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
dajac commented on code in PR #12886:
URL: https://github.com/apache/kafka/pull/12886#discussion_r1068220054
##
core/src/main/scala/kafka/coordinator/group/GroupCoordinatorAdapter.scala:
##
@@ -234,4 +240,78 @@ class GroupCoordinatorAdapter(
}
[
https://issues.apache.org/jira/browse/KAFKA-14616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Omnia Ibrahim updated KAFKA-14616:
--
Description:
We are facing an odd situation when we delete and recreate a topic while broker
[
https://issues.apache.org/jira/browse/KAFKA-14616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Omnia Ibrahim updated KAFKA-14616:
--
Description:
We are facing an odd situation when we delete and recreate a topic while broker
dajac commented on code in PR #12886:
URL: https://github.com/apache/kafka/pull/12886#discussion_r1068171485
##
clients/src/main/java/org/apache/kafka/common/requests/OffsetCommitResponse.java:
##
@@ -116,4 +118,80 @@ public void maybeSetThrottleTimeMs(int throttleTimeMs) {
dajac commented on code in PR #12886:
URL: https://github.com/apache/kafka/pull/12886#discussion_r1068168361
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinator.java:
##
@@ -164,5 +166,20 @@
CompletableFuture> fetch
String groupId,
[
https://issues.apache.org/jira/browse/KAFKA-14616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Omnia Ibrahim updated KAFKA-14616:
--
Description:
We are facing an odd situation when we delete and recreate a topic while broker
[
https://issues.apache.org/jira/browse/KAFKA-14616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Omnia Ibrahim updated KAFKA-14616:
--
Description:
We are facing an odd situation when we delete and recreate a topic while broker
[
https://issues.apache.org/jira/browse/KAFKA-14616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Omnia Ibrahim updated KAFKA-14616:
--
Description:
We are facing an odd situation when we delete and recreate a topic while broker
[
https://issues.apache.org/jira/browse/KAFKA-14616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Omnia Ibrahim updated KAFKA-14616:
--
Description:
We are facing an odd situation when we delete and recreate a topic while broker
Omnia Ibrahim created KAFKA-14616:
-
Summary: Topic recreation with offline broker causes permanent URPs
Key: KAFKA-14616
URL: https://issues.apache.org/jira/browse/KAFKA-14616
Project: Kafka
cadonna commented on code in PR #13025:
URL: https://github.com/apache/kafka/pull/13025#discussion_r1068096858
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/DefaultStateUpdater.java:
##
@@ -411,6 +422,7 @@ private void checkAllUpdatingTaskStates(final
cadonna merged PR #13017:
URL: https://github.com/apache/kafka/pull/13017
--
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-14199?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17675946#comment-17675946
]
Christo Lolov commented on KAFKA-14199:
---
There has been no further request for help on this
[
https://issues.apache.org/jira/browse/KAFKA-14199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Christo Lolov resolved KAFKA-14199.
---
Resolution: Fixed
> Installed kafka in ubuntu and not able to access in browser.
>
[
https://issues.apache.org/jira/browse/KAFKA-13805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Christo Lolov resolved KAFKA-13805.
---
Resolution: Fixed
> Upgrade vulnerable dependencies march 2022
>
[
https://issues.apache.org/jira/browse/KAFKA-13805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17675945#comment-17675945
]
Christo Lolov commented on KAFKA-13805:
---
Both 2.8.2 and 3.0.2 have since been released and as far
tinaselenge commented on code in PR #13102:
URL: https://github.com/apache/kafka/pull/13102#discussion_r1067964100
##
raft/src/test/java/org/apache/kafka/raft/FileBasedStateStoreTest.java:
##
@@ -90,6 +98,43 @@ public void testWriteElectionState() throws IOException {
clolov commented on code in PR #13096:
URL: https://github.com/apache/kafka/pull/13096#discussion_r1067909965
##
core/src/main/scala/kafka/server/FetchSession.scala:
##
@@ -705,10 +705,7 @@ class FetchSessionCache(private val maxEntries: Int,
}
def remove(sessionId:
clolov commented on code in PR #13094:
URL: https://github.com/apache/kafka/pull/13094#discussion_r1067891312
##
clients/src/test/java/org/apache/kafka/clients/producer/internals/RecordAccumulatorTest.java:
##
@@ -331,17 +331,15 @@ public void testStressfulSituation() throws
lucasbru commented on code in PR #13025:
URL: https://github.com/apache/kafka/pull/13025#discussion_r1067891929
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/DefaultStateUpdater.java:
##
@@ -276,6 +276,11 @@ private void addTask(final Task task) {
90 matches
Mail list logo
