[
https://issues.apache.org/jira/browse/KAFKA-10287?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17164009#comment-17164009
]
John Roesler commented on KAFKA-10287:
--
>From [~cadonna] 's PR:
> In PR [#8962|htt
soondenana commented on a change in pull request #9054:
URL: https://github.com/apache/kafka/pull/9054#discussion_r459766825
##
File path: core/src/main/scala/kafka/log/LogManager.scala
##
@@ -1151,6 +1149,16 @@ class LogManager(logDirs: Seq[File],
}
}
}
+
+ pri
[
https://issues.apache.org/jira/browse/KAFKA-10287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai reassigned KAFKA-10287:
--
Assignee: Bruno Cadonna (was: Chia-Ping Tsai)
> fix flaky streams/streams_standby_re
[
https://issues.apache.org/jira/browse/KAFKA-10287?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17164012#comment-17164012
]
Chia-Ping Tsai commented on KAFKA-10287:
{quote}
Sorry, I was not aware that you
junrao merged pull request #9059:
URL: https://github.com/apache/kafka/pull/9059
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-10300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao resolved KAFKA-10300.
-
Fix Version/s: 2.7.0
Resolution: Fixed
merged to trunk
> fix flaky core/group_mode_transactions_
ableegoldman commented on a change in pull request #8988:
URL: https://github.com/apache/kafka/pull/8988#discussion_r459768271
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StoreChangelogReader.java
##
@@ -365,72 +368,104 @@ private Changelog
ableegoldman commented on a change in pull request #8988:
URL: https://github.com/apache/kafka/pull/8988#discussion_r459776764
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StoreChangelogReader.java
##
@@ -310,18 +313,14 @@ public void enforc
guozhangwang commented on pull request #9068:
URL: https://github.com/apache/kafka/pull/9068#issuecomment-663282642
@vvcephei @abbccdda
This is an automated message from the Apache Git Service.
To respond to the message, ple
guozhangwang opened a new pull request #9068:
URL: https://github.com/apache/kafka/pull/9068
While debugging a rebalance scenario I found that inside
rejoinNeededOrPending when we trigger rebalance due to metadata or subscription
changes it is not logged, and hence it's actually a bit tric
guozhangwang commented on pull request #9068:
URL: https://github.com/apache/kafka/pull/9068#issuecomment-663282928
test this
This is an automated message from the Apache Git Service.
To respond to the message, please log on
guozhangwang commented on pull request #9068:
URL: https://github.com/apache/kafka/pull/9068#issuecomment-663282973
test this
This is an automated message from the Apache Git Service.
To respond to the message, please log on
mjsax commented on a change in pull request #9047:
URL: https://github.com/apache/kafka/pull/9047#discussion_r459788176
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStateManagerImpl.java
##
@@ -131,11 +135,40 @@ public void setGlobalPr
mjsax commented on a change in pull request #9047:
URL: https://github.com/apache/kafka/pull/9047#discussion_r459790103
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStateManagerImpl.java
##
@@ -131,11 +135,40 @@ public void setGlobalPr
mjsax commented on a change in pull request #9047:
URL: https://github.com/apache/kafka/pull/9047#discussion_r459790323
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStateManagerImpl.java
##
@@ -299,7 +318,17 @@ private void restoreStat
mjsax commented on a change in pull request #9047:
URL: https://github.com/apache/kafka/pull/9047#discussion_r459791370
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStateManagerImpl.java
##
@@ -299,7 +318,17 @@ private void restoreStat
mjsax commented on a change in pull request #9047:
URL: https://github.com/apache/kafka/pull/9047#discussion_r459791741
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStateManagerImpl.java
##
@@ -299,7 +318,17 @@ private void restoreStat
vitojeng opened a new pull request #9069:
URL: https://github.com/apache/kafka/pull/9069
follow-up #8200
KAFKA-5876's PR break into multiple parts, this PR is part 2: apply
UnknownStateStoreException
### Committer Checklist (excluded from commit message)
- [ ] Verify desi
mjsax commented on a change in pull request #9060:
URL: https://github.com/apache/kafka/pull/9060#discussion_r459793713
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopicManager.java
##
@@ -96,13 +104,15 @@ public InternalTopicManage
guozhangwang commented on a change in pull request #9047:
URL: https://github.com/apache/kafka/pull/9047#discussion_r459799708
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStateManagerImpl.java
##
@@ -299,7 +318,17 @@ private void rest
guozhangwang commented on a change in pull request #9060:
URL: https://github.com/apache/kafka/pull/9060#discussion_r459800202
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopicManager.java
##
@@ -154,27 +164,34 @@ public InternalTop
vitojeng commented on a change in pull request #9069:
URL: https://github.com/apache/kafka/pull/9069#discussion_r459805054
##
File path: streams/src/test/java/org/apache/kafka/streams/KafkaStreamsTest.java
##
@@ -693,6 +695,16 @@ public void
shouldNotGetQueryMetadataWithPartit
[
https://issues.apache.org/jira/browse/KAFKA-10284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17164063#comment-17164063
]
Guozhang Wang commented on KAFKA-10284:
---
What [~ableegoldman] described seems alig
huxihx commented on pull request #9051:
URL: https://github.com/apache/kafka/pull/9051#issuecomment-663309863
@rajinisivaram Thanks for the review, merging to trunk
This is an automated message from the Apache Git Service.
To
huxihx merged pull request #9051:
URL: https://github.com/apache/kafka/pull/9051
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-10268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
huxihx resolved KAFKA-10268.
Fix Version/s: 2.7.0
Resolution: Fixed
> dynamic config like "--delete-config log.retention.ms" doe
showuon commented on a change in pull request #9029:
URL: https://github.com/apache/kafka/pull/9029#discussion_r459818087
##
File path:
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorConnectorsIntegrationTest.java
##
@@ -62,6 +65,7 @@
private static fi
vvcephei opened a new pull request #9070:
URL: https://github.com/apache/kafka/pull/9070
Fixes slow release due to establishing a
separate SSH connection per file to copy.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Ve
showuon commented on a change in pull request #9029:
URL: https://github.com/apache/kafka/pull/9029#discussion_r459822704
##
File path:
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorConnectorsIntegrationTest.java
##
@@ -315,9 +319,34 @@ public void testRep
vvcephei commented on pull request #9070:
URL: https://github.com/apache/kafka/pull/9070#issuecomment-663321224
Hey all, after waiting at least 10 hours cumulatively for file uploads (so
far) for the 2.5.1 release candidates, I've been feeling motivated to try and
improve the situation.
huxihx created KAFKA-10305:
--
Summary: Print usage when parsing fails for ConsumerPerformance
Key: KAFKA-10305
URL: https://issues.apache.org/jira/browse/KAFKA-10305
Project: Kafka
Issue Type: Improv
vvcephei commented on a change in pull request #9047:
URL: https://github.com/apache/kafka/pull/9047#discussion_r459827653
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStateManagerImpl.java
##
@@ -131,11 +135,40 @@ public void setGloba
vvcephei commented on a change in pull request #9047:
URL: https://github.com/apache/kafka/pull/9047#discussion_r459827997
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStateManagerImpl.java
##
@@ -299,7 +318,17 @@ private void restoreS
vvcephei commented on a change in pull request #9047:
URL: https://github.com/apache/kafka/pull/9047#discussion_r459827952
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStateManagerImpl.java
##
@@ -299,7 +318,17 @@ private void restoreS
vvcephei commented on a change in pull request #9047:
URL: https://github.com/apache/kafka/pull/9047#discussion_r459827653
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStateManagerImpl.java
##
@@ -131,11 +135,40 @@ public void setGloba
showuon commented on pull request #9029:
URL: https://github.com/apache/kafka/pull/9029#issuecomment-663329158
@mimaison , thanks for your comments. I've updated in this commit:
https://github.com/apache/kafka/pull/9029/commits/c2e2d70c1a2317794ce49292024a977a02159445.
What I did are:
1
mjsax commented on a change in pull request #9047:
URL: https://github.com/apache/kafka/pull/9047#discussion_r459837317
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStateManagerImpl.java
##
@@ -299,7 +318,17 @@ private void restoreStat
ijuma commented on pull request #9065:
URL: https://github.com/apache/kafka/pull/9065#issuecomment-663335011
ok to test
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Git
guozhangwang commented on a change in pull request #8964:
URL: https://github.com/apache/kafka/pull/8964#discussion_r459850212
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorStateManager.java
##
@@ -454,6 +456,41 @@ public void flush(
guozhangwang commented on a change in pull request #8964:
URL: https://github.com/apache/kafka/pull/8964#discussion_r459850831
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractTask.java
##
@@ -49,6 +61,31 @@
this.stateDirectory
guozhangwang commented on a change in pull request #8964:
URL: https://github.com/apache/kafka/pull/8964#discussion_r459853500
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateManagerUtil.java
##
@@ -38,13 +41,39 @@
*/
final class StateM
[
https://issues.apache.org/jira/browse/KAFKA-10284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17164146#comment-17164146
]
Akshay Sharma commented on KAFKA-10284:
---
At initial, Group Coordinator will assign
guozhangwang commented on a change in pull request #8964:
URL: https://github.com/apache/kafka/pull/8964#discussion_r459857477
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java
##
@@ -243,18 +242,24 @@ public void handleAssignmen
guozhangwang commented on a change in pull request #8964:
URL: https://github.com/apache/kafka/pull/8964#discussion_r459858314
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java
##
@@ -466,15 +458,8 @@ public void postCommit() {
guozhangwang commented on a change in pull request #8964:
URL: https://github.com/apache/kafka/pull/8964#discussion_r459859152
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StandbyTask.java
##
@@ -93,8 +93,8 @@ public boolean isActive() {
guozhangwang commented on a change in pull request #8964:
URL: https://github.com/apache/kafka/pull/8964#discussion_r459859723
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java
##
@@ -542,13 +530,22 @@ public void closeCleanAndRec
huxihx opened a new pull request #9071:
URL: https://github.com/apache/kafka/pull/9071
https://issues.apache.org/jira/browse/KAFKA-10305
When `kafka-consumer-perf-test.sh` is executed without required options or
no options at all, only the error message is displayed. It's better off
huxihx commented on pull request #7711:
URL: https://github.com/apache/kafka/pull/7711#issuecomment-663360469
retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please log
101 - 148 of 148 matches
Mail list logo
