socutes commented on pull request #11138:
URL: https://github.com/apache/kafka/pull/11138#issuecomment-895843976
@dengziming
--
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
Jiri Syrovy created KAFKA-13185:
---
Summary: Kafka Connect should clear messageBatch after rewind
Key: KAFKA-13185
URL: https://issues.apache.org/jira/browse/KAFKA-13185
Project: Kafka
Issue Type
showuon opened a new pull request #11195:
URL: https://github.com/apache/kafka/pull/11195
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including upgra
showuon commented on a change in pull request #11195:
URL: https://github.com/apache/kafka/pull/11195#discussion_r685829914
##
File path: streams/src/main/java/org/apache/kafka/streams/kstream/Branched.java
##
@@ -143,6 +143,7 @@ protected Branched(final Branched branched) {
showuon commented on a change in pull request #11195:
URL: https://github.com/apache/kafka/pull/11195#discussion_r685830364
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/BranchedKStream.java
##
@@ -69,7 +69,8 @@
* .branch(predicate1, Branched.as("b
showuon commented on a change in pull request #11195:
URL: https://github.com/apache/kafka/pull/11195#discussion_r685830975
##
File path:
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamSplitTest.java
##
@@ -104,40 +105,45 @@ public void testResultingMa
showuon commented on pull request #11195:
URL: https://github.com/apache/kafka/pull/11195#issuecomment-895858000
@inponomarev @mjsax @vvcephei , please help review this PR. Thanks.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Git
xjrk58 opened a new pull request #11196:
URL: https://github.com/apache/kafka/pull/11196
*Clear messages left to be committed after rewind*
*Test strategy*
Current test suite still works.
### Committer Checklist (excluded from commit message)
- [x] Verify design and imple
showuon commented on a change in pull request #11138:
URL: https://github.com/apache/kafka/pull/11138#discussion_r685850971
##
File path: raft/src/main/java/org/apache/kafka/snapshot/SnapshotWriter.java
##
@@ -17,218 +17,67 @@
package org.apache.kafka.snapshot;
-import org
cadonna commented on a change in pull request #10851:
URL: https://github.com/apache/kafka/pull/10851#discussion_r685816278
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/StandbyTaskAssignor.java
##
@@ -0,0 +1,41 @@
+/*
+ * Licensed
satishd opened a new pull request #11197:
URL: https://github.com/apache/kafka/pull/11197
28x TS changes
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (i
dengziming commented on pull request #11198:
URL: https://github.com/apache/kafka/pull/11198#issuecomment-895926203
@niket-goel Do you set the compression type by accident? also cc @cmccabe
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
dengziming opened a new pull request #11198:
URL: https://github.com/apache/kafka/pull/11198
*More detailed description of your change*
The compression type of metadata topic is `CompressionType.NONE`, but we
still need to get it from only parameter, see code for details.
--
This
Chao created KAFKA-13186:
Summary: Proposal for commented code
Key: KAFKA-13186
URL: https://issues.apache.org/jira/browse/KAFKA-13186
Project: Kafka
Issue Type: Wish
Reporter: Chao
Hel
satishd closed pull request #11197:
URL: https://github.com/apache/kafka/pull/11197
--
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.
YI-CHEN WANG created KAFKA-13187:
Summary: Replace EasyMock and PowerMock with Mockito for
DistributedHerderTest
Key: KAFKA-13187
URL: https://issues.apache.org/jira/browse/KAFKA-13187
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-13164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-13164:
Fix Version/s: 3.0.1
2.8.1
> State store is attached to wrong node in t
[
https://issues.apache.org/jira/browse/KAFKA-13164?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17396777#comment-17396777
]
Matthias J. Sax commented on KAFKA-13164:
-
Marked for 2.8.1 and 3.0.1 – think we
[
https://issues.apache.org/jira/browse/KAFKA-13155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson resolved KAFKA-13155.
-
Resolution: Fixed
> ConcurrentModificationException in TransactionalMessageCopier
>
hachikuji merged pull request #11164:
URL: https://github.com/apache/kafka/pull/11164
--
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-unsubsc
jsancio commented on a change in pull request #11189:
URL: https://github.com/apache/kafka/pull/11189#discussion_r686152042
##
File path: core/src/test/scala/unit/kafka/server/ReplicaManagerTest.scala
##
@@ -1084,40 +1090,46 @@ class ReplicaManagerTest {
topicPartition,
dajac merged pull request #10895:
URL: https://github.com/apache/kafka/pull/10895
--
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...
[
https://issues.apache.org/jira/browse/KAFKA-12890?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot updated KAFKA-12890:
Fix Version/s: 2.8.1
> Consumer group stuck in `CompletingRebalance`
> ---
hachikuji merged pull request #11189:
URL: https://github.com/apache/kafka/pull/11189
--
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-unsubsc
guozhangwang merged pull request #11155:
URL: https://github.com/apache/kafka/pull/11155
--
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-unsu
[
https://issues.apache.org/jira/browse/KAFKA-13161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson resolved KAFKA-13161.
-
Resolution: Fixed
> Follower leader and ISR state not updated after partition change in
[
https://issues.apache.org/jira/browse/KAFKA-12644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantine Karantasis updated KAFKA-12644:
---
Fix Version/s: (was: 3.0.0)
3.0.1
3
[
https://issues.apache.org/jira/browse/KAFKA-12644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17396873#comment-17396873
]
Konstantine Karantasis commented on KAFKA-12644:
Given that at this poin
[
https://issues.apache.org/jira/browse/KAFKA-13170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-13170:
---
Assignee: Guozhang Wang
> Flaky Test InternalTopicManagerTest.shouldRetryDeleteTopi
mjsax merged pull request #11195:
URL: https://github.com/apache/kafka/pull/11195
--
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...
mjsax commented on pull request #11195:
URL: https://github.com/apache/kafka/pull/11195#issuecomment-896302677
Thanks for the PR @showuon! Merged to `trunk` and cherry-picked to `3.0` and
`2.8` branches.
--
This is an automated message from the Apache Git Service.
To respond to the messa
Lucas Wang created KAFKA-13188:
--
Summary: Release the memory back into MemoryPool
Key: KAFKA-13188
URL: https://issues.apache.org/jira/browse/KAFKA-13188
Project: Kafka
Issue Type: Improvement
hachikuji commented on a change in pull request #11191:
URL: https://github.com/apache/kafka/pull/11191#discussion_r686135001
##
File path:
metadata/src/main/java/org/apache/kafka/controller/BrokerHeartbeatManager.java
##
@@ -419,6 +419,27 @@ long nextCheckTimeNs() {
[
https://issues.apache.org/jira/browse/KAFKA-13170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-13170.
---
Fix Version/s: 3.1.0
Resolution: Fixed
> Flaky Test InternalTopicManagerTest.shouldRe
niket-goel commented on a change in pull request #11191:
URL: https://github.com/apache/kafka/pull/11191#discussion_r686343189
##
File path:
metadata/src/test/java/org/apache/kafka/controller/QuorumControllerTest.java
##
@@ -173,6 +176,112 @@ private void
testDelayedConfigura
niket-goel closed pull request #11142:
URL: https://github.com/apache/kafka/pull/11142
--
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-unsubs
Niket Goel created KAFKA-13190:
--
Summary: Revisit the CreateTopic API behavior when number of
Unfenced Brokers available for placement is less than min_isr
Key: KAFKA-13190
URL: https://issues.apache.org/jira/browse/
Niket Goel created KAFKA-13189:
--
Summary: Revisit the CreateTopic API behavior when number of
Unfenced Brokers available for placement is less than min_isr
Key: KAFKA-13189
URL: https://issues.apache.org/jira/browse/
[
https://issues.apache.org/jira/browse/KAFKA-13189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Niket Goel resolved KAFKA-13189.
Resolution: Fixed
> Revisit the CreateTopic API behavior when number of Unfenced Brokers
> availa
JoeCqupt commented on pull request #11089:
URL: https://github.com/apache/kafka/pull/11089#issuecomment-896475447
@ijuma
--
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
showuon commented on a change in pull request #11191:
URL: https://github.com/apache/kafka/pull/11191#discussion_r686463360
##
File path:
metadata/src/test/java/org/apache/kafka/controller/ReplicationControlManagerTest.java
##
@@ -208,6 +212,24 @@ void unfenceBrokers(Integer..
niket-goel commented on pull request #11191:
URL: https://github.com/apache/kafka/pull/11191#issuecomment-896508951
@showuon -- Thanks for looking at the PR. Will address the comments and
publish an update.
--
This is an automated message from the Apache Git Service.
To respond to the me
niket-goel commented on a change in pull request #11191:
URL: https://github.com/apache/kafka/pull/11191#discussion_r686498956
##
File path:
metadata/src/test/java/org/apache/kafka/controller/QuorumControllerTest.java
##
@@ -173,6 +175,127 @@ private void
testDelayedConfigura
socutes commented on a change in pull request #11138:
URL: https://github.com/apache/kafka/pull/11138#discussion_r686544266
##
File path: raft/src/main/java/org/apache/kafka/snapshot/SnapshotWriter.java
##
@@ -17,218 +17,67 @@
package org.apache.kafka.snapshot;
-import org
socutes commented on a change in pull request #11138:
URL: https://github.com/apache/kafka/pull/11138#discussion_r686544266
##
File path: raft/src/main/java/org/apache/kafka/snapshot/SnapshotWriter.java
##
@@ -17,218 +17,67 @@
package org.apache.kafka.snapshot;
-import org
45 matches
Mail list logo
