dengziming commented on PR #12318:
URL: https://github.com/apache/kafka/pull/12318#issuecomment-1247658470
@mumrah Do we still need --release after we add --metadata? I will close
this if it's unnecessary or rebase this PR onto trunk if it's still useful.
--
This is an automated message f
[
https://issues.apache.org/jira/browse/KAFKA-7109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen updated KAFKA-7109:
-
Fix Version/s: (was: 3.3.1)
> KafkaConsumer should close its incremental fetch sessions on close
> --
[
https://issues.apache.org/jira/browse/KAFKA-7109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen reopened KAFKA-7109:
--
> KafkaConsumer should close its incremental fetch sessions on close
>
[
https://issues.apache.org/jira/browse/KAFKA-14132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17605087#comment-17605087
]
Christo Lolov commented on KAFKA-14132:
---
Hello [~ChrisEgerton]! I have followed th
[
https://issues.apache.org/jira/browse/KAFKA-14132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Christo Lolov updated KAFKA-14132:
--
Description:
{color:#de350b}Some of the tests below use EasyMock as well. For those migrate
b
[
https://issues.apache.org/jira/browse/KAFKA-14156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao resolved KAFKA-14156.
-
Assignee: Artem Livshits
Resolution: Fixed
Merged the PR to 3.3 and trunk.
> Built-in partitioner
junrao merged PR #12570:
URL: https://github.com/apache/kafka/pull/12570
--
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.o
[
https://issues.apache.org/jira/browse/KAFKA-14234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yan Xue updated KAFKA-14234:
Description:
I deployed the Kafka cluster on Kuberentes and am trying to figure out how
topic deletion wo
Yan Xue created KAFKA-14234:
---
Summary: /admin/delete_topics is not in the list of zookeeper
watchers
Key: KAFKA-14234
URL: https://issues.apache.org/jira/browse/KAFKA-14234
Project: Kafka
Issue Ty
lihaosky commented on code in PR #12638:
URL: https://github.com/apache/kafka/pull/12638#discussion_r971383169
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/ChangelogRegister.java:
##
@@ -31,6 +33,8 @@ public interface ChangelogRegister {
*/
vo
cmccabe commented on code in PR #12636:
URL: https://github.com/apache/kafka/pull/12636#discussion_r971319874
##
metadata/src/main/java/org/apache/kafka/metadata/authorizer/StandardAuthorizer.java:
##
@@ -138,6 +139,15 @@ public List authorize(
return results;
}
mumrah commented on code in PR #12636:
URL: https://github.com/apache/kafka/pull/12636#discussion_r971306933
##
metadata/src/main/java/org/apache/kafka/metadata/authorizer/StandardAuthorizer.java:
##
@@ -138,6 +139,15 @@ public List authorize(
return results;
}
+
artemlivshits commented on PR #12570:
URL: https://github.com/apache/kafka/pull/12570#issuecomment-1247321505
Looked through the failed tests -- seem unrelated (also ran locally - pass).
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on t
cmccabe commented on code in PR #12636:
URL: https://github.com/apache/kafka/pull/12636#discussion_r971280735
##
metadata/src/main/java/org/apache/kafka/metadata/authorizer/StandardAuthorizerData.java:
##
@@ -182,59 +174,58 @@ StandardAuthorizerData copyWithNewConfig(int nodeId,
cmccabe commented on code in PR #12636:
URL: https://github.com/apache/kafka/pull/12636#discussion_r971280346
##
metadata/src/main/java/org/apache/kafka/metadata/authorizer/StandardAuthorizerData.java:
##
@@ -182,59 +174,58 @@ StandardAuthorizerData copyWithNewConfig(int nodeId,
cmccabe commented on code in PR #12636:
URL: https://github.com/apache/kafka/pull/12636#discussion_r971279173
##
metadata/src/main/java/org/apache/kafka/metadata/authorizer/StandardAuthorizer.java:
##
@@ -138,6 +139,15 @@ public List authorize(
return results;
}
R
[
https://issues.apache.org/jira/browse/KAFKA-6221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17604951#comment-17604951
]
Idrissi commented on KAFKA-6221:
Hello , i am facing the same problem with the following
[
https://issues.apache.org/jira/browse/KAFKA-6221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17604951#comment-17604951
]
Idrissi edited comment on KAFKA-6221 at 9/14/22 8:18 PM:
-
Hello ,
[
https://issues.apache.org/jira/browse/KAFKA-6221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17604951#comment-17604951
]
Idrissi edited comment on KAFKA-6221 at 9/14/22 8:18 PM:
-
Hello ,
jolshan opened a new pull request, #12643:
URL: https://github.com/apache/kafka/pull/12643
Changed the integer value for producer ID expiration to a dynamically
configurable value.
Tested that the configuration can be changed dynamically and works as
expected.
I considered add
cmccabe commented on code in PR #12642:
URL: https://github.com/apache/kafka/pull/12642#discussion_r971205378
##
docs/ops.html:
##
@@ -3180,6 +3180,119 @@ 6.10 KRaft
+
+ Configuration
+
+ Process Roles
+
+ In KRaft mode each Kafka server can be configured as a controller, as
cmccabe commented on code in PR #12642:
URL: https://github.com/apache/kafka/pull/12642#discussion_r971204480
##
docs/ops.html:
##
@@ -3180,6 +3180,119 @@ 6.10 KRaft
+
+ Configuration
+
+ Process Roles
+
+ In KRaft mode each Kafka server can be configured as a controller, as
cmccabe commented on code in PR #12642:
URL: https://github.com/apache/kafka/pull/12642#discussion_r971203656
##
docs/ops.html:
##
@@ -3180,6 +3180,119 @@ 6.10 KRaft
+
+ Configuration
+
+ Process Roles
+
+ In KRaft mode each Kafka server can be configured as a controller, as
cmccabe commented on code in PR #12642:
URL: https://github.com/apache/kafka/pull/12642#discussion_r971203144
##
docs/ops.html:
##
@@ -3180,6 +3180,119 @@ 6.10 KRaft
+
+ Configuration
+
+ Process Roles
+
+ In KRaft mode each Kafka server can be configured as a controller, as
cmccabe commented on code in PR #12642:
URL: https://github.com/apache/kafka/pull/12642#discussion_r971201992
##
docs/ops.html:
##
@@ -3180,6 +3180,119 @@ 6.10 KRaft
+
+ Configuration
+
+ Process Roles
+
+ In KRaft mode each Kafka server can be configured as a controller, as
cmccabe commented on code in PR #12642:
URL: https://github.com/apache/kafka/pull/12642#discussion_r971201651
##
docs/ops.html:
##
@@ -3180,6 +3180,119 @@ 6.10 KRaft
+
+ Configuration
+
+ Process Roles
+
+ In KRaft mode each Kafka server can be configured as a controller, as
jsancio opened a new pull request, #12642:
URL: https://github.com/apache/kafka/pull/12642
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including upgra
abbccdda closed pull request #10156: KAFKA-10345: File watch store reloading
URL: https://github.com/apache/kafka/pull/10156
--
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
gitlw commented on PR #12634:
URL: https://github.com/apache/kafka/pull/12634#issuecomment-1247113089
rerun tests please
--
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
nizhikov commented on PR #12632:
URL: https://github.com/apache/kafka/pull/12632#issuecomment-1247109394
I've checked tests failure.
Looks like they are not related to the changes.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to G
mumrah commented on code in PR #12636:
URL: https://github.com/apache/kafka/pull/12636#discussion_r971116340
##
metadata/src/main/java/org/apache/kafka/metadata/authorizer/StandardAuthorizerData.java:
##
@@ -182,59 +174,58 @@ StandardAuthorizerData copyWithNewConfig(int nodeId,
mumrah commented on code in PR #12636:
URL: https://github.com/apache/kafka/pull/12636#discussion_r971108745
##
metadata/src/main/java/org/apache/kafka/metadata/authorizer/StandardAuthorizer.java:
##
@@ -96,18 +97,16 @@ public void completeInitialLoad(Exception e) {
}
akhileshchg commented on code in PR #12636:
URL: https://github.com/apache/kafka/pull/12636#discussion_r971088491
##
metadata/src/main/java/org/apache/kafka/metadata/authorizer/StandardAuthorizerData.java:
##
@@ -109,14 +110,9 @@ public class StandardAuthorizerData {
privat
artemlivshits commented on code in PR #12570:
URL: https://github.com/apache/kafka/pull/12570#discussion_r971097010
##
clients/src/test/java/org/apache/kafka/clients/producer/internals/RecordAccumulatorTest.java:
##
@@ -1129,31 +1129,34 @@ public void onCompletion(RecordMetadata
cmccabe commented on code in PR #12636:
URL: https://github.com/apache/kafka/pull/12636#discussion_r971095900
##
metadata/src/main/java/org/apache/kafka/metadata/authorizer/StandardAuthorizerData.java:
##
@@ -182,59 +173,58 @@ StandardAuthorizerData copyWithNewConfig(int nodeId,
[
https://issues.apache.org/jira/browse/KAFKA-10635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17604862#comment-17604862
]
Nicholas Telford commented on KAFKA-10635:
--
Hi [~guozhang],
I've managed to pu
[
https://issues.apache.org/jira/browse/KAFKA-10635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nicholas Telford updated KAFKA-10635:
-
Attachment: logs.csv
> Streams application fails with OutOfOrderSequenceException after
cmccabe commented on code in PR #12636:
URL: https://github.com/apache/kafka/pull/12636#discussion_r971094152
##
metadata/src/main/java/org/apache/kafka/metadata/authorizer/StandardAuthorizer.java:
##
@@ -96,18 +97,16 @@ public void completeInitialLoad(Exception e) {
}
cmccabe commented on code in PR #12636:
URL: https://github.com/apache/kafka/pull/12636#discussion_r971092861
##
metadata/src/main/java/org/apache/kafka/metadata/authorizer/StandardAuthorizerData.java:
##
@@ -109,14 +110,9 @@ public class StandardAuthorizerData {
private fi
cmccabe commented on PR #12636:
URL: https://github.com/apache/kafka/pull/12636#issuecomment-1247070076
Jenkins went down again. :(
```
java.nio.file.FileSystemException:
/home/jenkins/workspace/Kafka_kafka-pr_PR-12636: No space left on device
```
--
This is an automated mess
cmccabe commented on code in PR #12636:
URL: https://github.com/apache/kafka/pull/12636#discussion_r971091182
##
metadata/src/main/java/org/apache/kafka/metadata/authorizer/StandardAuthorizer.java:
##
@@ -96,18 +97,16 @@ public void completeInitialLoad(Exception e) {
}
vpapavas opened a new pull request, #12641:
URL: https://github.com/apache/kafka/pull/12641
This PR is part of a series implementing the self-join rewriting. As part of
it, we decided to clean up the `TOPOLOGY_OPTIMIZATION_CONFIG` and make it a
list of optimization rules. Acceptable values
guozhangwang commented on code in PR #12638:
URL: https://github.com/apache/kafka/pull/12638#discussion_r971076310
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorStateManager.java:
##
@@ -575,8 +584,10 @@ public void close() throws ProcessorStateE
divijvaidya commented on PR #12639:
URL: https://github.com/apache/kafka/pull/12639#issuecomment-1247027848
Wow! Great deep dive to find the root cause here @showuon 👏
I am curious, how did you narrow down that `Gradle Test Executor 128` is
related to `testReloadUpdatedFilesWithoutCon
[
https://issues.apache.org/jira/browse/KAFKA-10635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17604838#comment-17604838
]
Guozhang Wang commented on KAFKA-10635:
---
Hmm okay I think we'd need to reproduce t
junrao commented on code in PR #12570:
URL: https://github.com/apache/kafka/pull/12570#discussion_r971047147
##
clients/src/test/java/org/apache/kafka/clients/producer/internals/RecordAccumulatorTest.java:
##
@@ -1129,31 +1129,34 @@ public void onCompletion(RecordMetadata metada
jolshan commented on code in PR #12392:
URL: https://github.com/apache/kafka/pull/12392#discussion_r971022152
##
clients/src/test/java/org/apache/kafka/clients/producer/internals/TransactionManagerTest.java:
##
@@ -2594,27 +2596,20 @@ public void testDropCommitOnBatchExpiry() th
guozhangwang commented on code in PR #12555:
URL: https://github.com/apache/kafka/pull/12555#discussion_r971010379
##
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamKStreamSelfJoin.java:
##
@@ -0,0 +1,144 @@
+/*
+ * Licensed to the Apache Software Founda
jsancio merged PR #12640:
URL: https://github.com/apache/kafka/pull/12640
--
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.
mumrah commented on code in PR #12636:
URL: https://github.com/apache/kafka/pull/12636#discussion_r970977191
##
metadata/src/main/java/org/apache/kafka/metadata/authorizer/StandardAuthorizerData.java:
##
@@ -397,18 +387,34 @@ private MatchingAclRule findAclRule(
return
jsancio opened a new pull request, #12640:
URL: https://github.com/apache/kafka/pull/12640
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including upgrade n
jsancio merged PR #12635:
URL: https://github.com/apache/kafka/pull/12635
--
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.
guozhangwang commented on code in PR #12600:
URL: https://github.com/apache/kafka/pull/12600#discussion_r970973727
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java:
##
@@ -421,73 +421,95 @@ private void classifyTasksWithoutStateUpdater(final
philipnee commented on PR #12633:
URL: https://github.com/apache/kafka/pull/12633#issuecomment-1246909476
cc @dajac
--
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 unsu
[
https://issues.apache.org/jira/browse/KAFKA-14132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17604794#comment-17604794
]
Chris Egerton commented on KAFKA-14132:
---
[~christo_lolov] Any preference on how we
[
https://issues.apache.org/jira/browse/KAFKA-10802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17604757#comment-17604757
]
François Rosière edited comment on KAFKA-10802 at 9/14/22 3:02 PM:
---
C0urante merged PR #12615:
URL: https://github.com/apache/kafka/pull/12615
--
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
[
https://issues.apache.org/jira/browse/KAFKA-10802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17604757#comment-17604757
]
François Rosière edited comment on KAFKA-10802 at 9/14/22 2:33 PM:
---
[
https://issues.apache.org/jira/browse/KAFKA-10802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17604757#comment-17604757
]
François Rosière commented on KAFKA-10802:
--
Issue is still present when using K
C0urante commented on PR #11792:
URL: https://github.com/apache/kafka/pull/11792#issuecomment-1246858578
Hi @dplavcic, are you still working on this issue?
--
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
[
https://issues.apache.org/jira/browse/KAFKA-14220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17604716#comment-17604716
]
Chris Egerton commented on KAFKA-14220:
---
[~kumarpritam863] this seemed like a legi
vpapavas commented on code in PR #12555:
URL: https://github.com/apache/kafka/pull/12555#discussion_r970800187
##
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamKStreamSelfJoin.java:
##
@@ -0,0 +1,144 @@
+/*
+ * Licensed to the Apache Software Foundation
vpapavas commented on code in PR #12555:
URL: https://github.com/apache/kafka/pull/12555#discussion_r970805661
##
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamKStreamSelfJoin.java:
##
@@ -0,0 +1,144 @@
+/*
+ * Licensed to the Apache Software Foundation
showuon commented on PR #12639:
URL: https://github.com/apache/kafka/pull/12639#issuecomment-1246762358
@hachikuji @jsancio , please take a look. 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 opened a new pull request, #12639:
URL: https://github.com/apache/kafka/pull/12639
Recently, we got a lot of build failed (and terminated) with core:unitTest
failure. The failed messages look like this:
```
FAILURE: Build failed with an exception.
[2022-09-14T09:51:52.190Z]
vpapavas commented on code in PR #12555:
URL: https://github.com/apache/kafka/pull/12555#discussion_r970800187
##
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamKStreamSelfJoin.java:
##
@@ -0,0 +1,144 @@
+/*
+ * Licensed to the Apache Software Foundation
vpapavas commented on code in PR #12555:
URL: https://github.com/apache/kafka/pull/12555#discussion_r970792491
##
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamKStreamSelfJoin.java:
##
@@ -0,0 +1,144 @@
+/*
+ * Licensed to the Apache Software Foundation
[
https://issues.apache.org/jira/browse/KAFKA-14233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen updated KAFKA-14233:
--
Description:
Recently, we got a lot of build failed (and terminated) with core:unitTest
failure. The
[
https://issues.apache.org/jira/browse/KAFKA-14233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen updated KAFKA-14233:
--
Description:
Recently, we got a lot of build failed (and terminated) with Failed messages
look like t
Luke Chen created KAFKA-14233:
-
Summary: Jenkins build failed with task ':core:unitTest' exit
value 1
Key: KAFKA-14233
URL: https://issues.apache.org/jira/browse/KAFKA-14233
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-7109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen updated KAFKA-7109:
-
Fix Version/s: 3.3.1
> KafkaConsumer should close its incremental fetch sessions on close
> -
showuon merged PR #11516:
URL: https://github.com/apache/kafka/pull/11516
--
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.
showuon commented on PR #11516:
URL: https://github.com/apache/kafka/pull/11516#issuecomment-1246713341
Failed tests are unrelated:
```
Build / JDK 8 and Scala 2.12 /
integration.kafka.server.FetchRequestBetweenDifferentIbpTest.testControllerNewToOldIBP()
Build / JDK 17 and
cadonna commented on code in PR #12600:
URL: https://github.com/apache/kafka/pull/12600#discussion_r970668525
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java:
##
@@ -421,73 +421,95 @@ private void classifyTasksWithoutStateUpdater(final
Map
[
https://issues.apache.org/jira/browse/KAFKA-10635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17604021#comment-17604021
]
Nicholas Telford commented on KAFKA-10635:
--
[~guozhang] both my Kafka brokers a
cadonna commented on code in PR #12600:
URL: https://github.com/apache/kafka/pull/12600#discussion_r970637424
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/Tasks.java:
##
@@ -103,42 +101,75 @@ public void addPendingStandbyTasksToCreate(final
Map
@
cadonna commented on code in PR #12638:
URL: https://github.com/apache/kafka/pull/12638#discussion_r970637017
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/Tasks.java:
##
@@ -169,7 +169,7 @@ public void addPendingActiveTaskToSuspend(final TaskId
taskId)
cadonna commented on code in PR #12638:
URL: https://github.com/apache/kafka/pull/12638#discussion_r970631567
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/ChangelogRegister.java:
##
@@ -31,6 +33,8 @@ public interface ChangelogRegister {
*/
voi
cadonna commented on code in PR #12638:
URL: https://github.com/apache/kafka/pull/12638#discussion_r970630607
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorStateManager.java:
##
@@ -536,7 +543,9 @@ public void flushCache() {
public void clos
cadonna commented on code in PR #12638:
URL: https://github.com/apache/kafka/pull/12638#discussion_r970630206
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorStateManager.java:
##
@@ -209,7 +212,9 @@ void registerStateStores(final List allStores,
cadonna commented on code in PR #12638:
URL: https://github.com/apache/kafka/pull/12638#discussion_r970629341
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorStateManager.java:
##
@@ -575,8 +584,10 @@ public void close() throws ProcessorStateExcept
cadonna commented on code in PR #12638:
URL: https://github.com/apache/kafka/pull/12638#discussion_r970627977
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/DefaultStateUpdater.java:
##
@@ -406,17 +412,21 @@ private void maybeCheckpointUpdatingTasks(final
cadonna commented on code in PR #12638:
URL: https://github.com/apache/kafka/pull/12638#discussion_r970626576
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/DefaultStateUpdater.java:
##
@@ -262,19 +263,19 @@ private List getTasksAndActions() {
pri
cadonna commented on code in PR #12638:
URL: https://github.com/apache/kafka/pull/12638#discussion_r970625278
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/DefaultStateUpdater.java:
##
@@ -98,7 +99,7 @@ public void run() {
while (isRunnin
cadonna commented on PR #12638:
URL: https://github.com/apache/kafka/pull/12638#issuecomment-1246558345
Call for review: @wcarlson5 @lihaosky
--
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 opened a new pull request, #12638:
URL: https://github.com/apache/kafka/pull/12638
Registering and unregistering the changelog topics in the changelog reader
outside of the state updater leads to race conditions between the stream thread
and the state updater thread. Thus, this PR m
naanagon commented on PR #11516:
URL: https://github.com/apache/kafka/pull/11516#issuecomment-1246533634
@divijvaidya Thank you for your suggestion. Noted.
--
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
[
https://issues.apache.org/jira/browse/KAFKA-14220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Pritam Kumar updated KAFKA-14220:
-
Description: (was: Issue:
In case of the revocation of partitions, the updation of "partitio
[
https://issues.apache.org/jira/browse/KAFKA-14220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Pritam Kumar resolved KAFKA-14220.
--
Reviewer: (was: Chris Egerton)
Resolution: Abandoned
> "partition-count" not getting u
[
https://issues.apache.org/jira/browse/KAFKA-14220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Pritam Kumar closed KAFKA-14220.
> "partition-count" not getting updated after revocation of partitions in case
> of Incremental Co-op
[
https://issues.apache.org/jira/browse/KAFKA-14220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Pritam Kumar updated KAFKA-14220:
-
Flags: (was: Patch,Important)
> "partition-count" not getting updated after revocation of part
[
https://issues.apache.org/jira/browse/KAFKA-14220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Pritam Kumar updated KAFKA-14220:
-
Labels: (was: pull-request-available)
> "partition-count" not getting updated after revocation
[ https://issues.apache.org/jira/browse/KAFKA-14220 ]
Pritam Kumar deleted comment on KAFKA-14220:
--
was (Author: JIRAUSER295638):
The following is the patch made and verified:
*https://github.com/apache/kafka/pull/12622*
> "partition-count" no
[ https://issues.apache.org/jira/browse/KAFKA-14220 ]
Pritam Kumar deleted comment on KAFKA-14220:
--
was (Author: JIRAUSER295638):
https://github.com/apache/kafka/pull/12622
> "partition-count" not getting updated after revocation of partitions
[
https://issues.apache.org/jira/browse/KAFKA-14220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Pritam Kumar updated KAFKA-14220:
-
Component/s: (was: KafkaConnect)
> "partition-count" not getting updated after revocation of
kumarpritam863 closed pull request #12622: Update WorkerSinkTask.java
URL: https://github.com/apache/kafka/pull/12622
--
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 unsubsc
nizhikov commented on PR #12632:
URL: https://github.com/apache/kafka/pull/12632#issuecomment-1246427376
@C0urante Thanks for the review. Fixed all your comments.
> Should we also update the system test
I doubt it.
a. We have compatibility tests (which not use streams res
nizhikov commented on code in PR #12632:
URL: https://github.com/apache/kafka/pull/12632#discussion_r970460345
##
docs/streams/developer-guide/app-reset-tool.html:
##
@@ -84,9 +84,11 @@ Step 1: Run the application reset tool
nizhikov commented on code in PR #12632:
URL: https://github.com/apache/kafka/pull/12632#discussion_r970457373
##
core/src/main/scala/kafka/tools/StreamsResetter.java:
##
@@ -213,8 +217,12 @@ private void parseArguments(final String[] args) {
.ofType(String.class)
cadonna merged PR #12600:
URL: https://github.com/apache/kafka/pull/12600
--
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.
1 - 100 of 103 matches
Mail list logo