highluck commented on pull request #9786:
URL: https://github.com/apache/kafka/pull/9786#issuecomment-828285957
ping @chia7712
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 go to the
showuon commented on a change in pull request #10509:
URL: https://github.com/apache/kafka/pull/10509#discussion_r622064430
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignor.java
##
@@ -263,16 +279,59 @@ private boolean
[
https://issues.apache.org/jira/browse/KAFKA-12723?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
loyi updated KAFKA-12723:
-
Description:
The method mergeFrom of {color:#de350b}HashTier{color} maybe has potential NPE
, the attribute
showuon commented on a change in pull request #10509:
URL: https://github.com/apache/kafka/pull/10509#discussion_r622040343
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignor.java
##
@@ -263,16 +279,59 @@ private boolean
[
https://issues.apache.org/jira/browse/KAFKA-12723?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
loyi updated KAFKA-12723:
-
Description:
The method mergeFrom of {color:#de350b}HashTier{color} maybe has potential NPE
, the attribute
showuon commented on a change in pull request #10509:
URL: https://github.com/apache/kafka/pull/10509#discussion_r622064430
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignor.java
##
@@ -263,16 +279,59 @@ private boolean
kowshik commented on a change in pull request #10271:
URL: https://github.com/apache/kafka/pull/10271#discussion_r621909685
##
File path:
raft/src/main/java/org/apache/kafka/raft/metadata/AbstractApiMessageSerde.java
##
@@ -0,0 +1,93 @@
+/*
+ * Licensed to the Apache Software
highluck removed a comment on pull request #9786:
URL: https://github.com/apache/kafka/pull/9786#issuecomment-785059958
ping @chia7712
--
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
showuon commented on a change in pull request #10509:
URL: https://github.com/apache/kafka/pull/10509#discussion_r622040343
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignor.java
##
@@ -263,16 +279,59 @@ private boolean
showuon commented on a change in pull request #10509:
URL: https://github.com/apache/kafka/pull/10509#discussion_r621951920
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignor.java
##
@@ -108,6 +107,8 @@ private boolean
kowshik commented on a change in pull request #10271:
URL: https://github.com/apache/kafka/pull/10271#discussion_r621925315
##
File path:
storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/serialization/RemoteLogMetadataSerde.java
##
@@ -0,0 +1,105 @@
loyi created KAFKA-12723:
Summary: Potential NPE in SnapshottableHashTable.java
Key: KAFKA-12723
URL: https://issues.apache.org/jira/browse/KAFKA-12723
Project: Kafka
Issue Type: Bug
Affects
tombentley commented on pull request #9441:
URL: https://github.com/apache/kafka/pull/9441#issuecomment-828333212
@hachikuji Thanks, I was being slow on the uptake, but what you describe
makes perfect sense. I've moved the logic to the GroupMetadataManager, am using
the max observed epoch
showuon commented on a change in pull request #10509:
URL: https://github.com/apache/kafka/pull/10509#discussion_r622040343
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignor.java
##
@@ -263,16 +279,59 @@ private boolean
[
https://issues.apache.org/jira/browse/KAFKA-12723?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
loyi updated KAFKA-12723:
-
Description:
The method mergeFrom of {color:#de350b}HashTier{color} maybe has potential NPE
, the attribute
saddays opened a new pull request #10601:
URL: https://github.com/apache/kafka/pull/10601
Fix potential NPE ,
[kafka-12723](https://issues.apache.org/jira/browse/KAFKA-12723)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
showuon commented on a change in pull request #10509:
URL: https://github.com/apache/kafka/pull/10509#discussion_r622064430
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignor.java
##
@@ -263,16 +279,59 @@ private boolean
showuon commented on a change in pull request #10509:
URL: https://github.com/apache/kafka/pull/10509#discussion_r622064430
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignor.java
##
@@ -263,16 +279,59 @@ private boolean
ijuma commented on pull request #10466:
URL: https://github.com/apache/kafka/pull/10466#issuecomment-828682155
Unrelated failures, merging to trunk.
--
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
[
https://issues.apache.org/jira/browse/KAFKA-12718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17334964#comment-17334964
]
Matthias J. Sax commented on KAFKA-12718:
-
I was just looking into `suppress()` implementation,
mjsax commented on a change in pull request #10602:
URL: https://github.com/apache/kafka/pull/10602#discussion_r622492083
##
File path:
streams/upgrade-system-tests-28/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.java
##
@@ -0,0 +1,86 @@
+/*
+ * Licensed to
wcarlson5 commented on pull request #10603:
URL: https://github.com/apache/kafka/pull/10603#issuecomment-828769426
This will not work without significant other changes
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
wcarlson5 closed pull request #10603:
URL: https://github.com/apache/kafka/pull/10603
--
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.
For queries about this service,
ijuma merged pull request #10466:
URL: https://github.com/apache/kafka/pull/10466
--
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.
For queries about this service, please
[
https://issues.apache.org/jira/browse/KAFKA-9295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman reopened KAFKA-9295:
---
Still failing, saw this on both the Java 8 and Java 11 build of a PR:
hachikuji commented on a change in pull request #10480:
URL: https://github.com/apache/kafka/pull/10480#discussion_r622470077
##
File path: raft/src/main/java/org/apache/kafka/raft/LeaderState.java
##
@@ -67,6 +74,30 @@ protected LeaderState(
}
hachikuji commented on a change in pull request #10480:
URL: https://github.com/apache/kafka/pull/10480#discussion_r622470077
##
File path: raft/src/main/java/org/apache/kafka/raft/LeaderState.java
##
@@ -67,6 +74,30 @@ protected LeaderState(
}
hachikuji commented on a change in pull request #9590:
URL: https://github.com/apache/kafka/pull/9590#discussion_r622473204
##
File path: core/src/test/scala/integration/kafka/api/PlaintextConsumerTest.scala
##
@@ -1267,6 +1266,64 @@ class PlaintextConsumerTest extends
mjsax commented on a change in pull request #10602:
URL: https://github.com/apache/kafka/pull/10602#discussion_r622492627
##
File path:
streams/upgrade-system-tests-28/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.java
##
@@ -0,0 +1,86 @@
+/*
+ * Licensed to
mjsax commented on pull request #10602:
URL: https://github.com/apache/kafka/pull/10602#issuecomment-828736200
\cc @vvcephei who was RM for 2.8 for tracking.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
[
https://issues.apache.org/jira/browse/KAFKA-8613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17334984#comment-17334984
]
Israel Ekpo commented on KAFKA-8613:
I noticed that the method signature in the KIP had the incorrect
hachikuji commented on a change in pull request #10085:
URL: https://github.com/apache/kafka/pull/10085#discussion_r622494008
##
File path: raft/src/main/java/org/apache/kafka/raft/BatchReader.java
##
@@ -60,19 +61,21 @@
@Override
void close();
-class Batch {
+
ableegoldman merged pull request #10607:
URL: https://github.com/apache/kafka/pull/10607
--
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.
For queries about this service,
ableegoldman opened a new pull request #10607:
URL: https://github.com/apache/kafka/pull/10607
I was just editing something on the release process wiki and noticed that
under the "Cut Branch" section, which it says to skip for bugfix releases,
there's actually a list of files that it then
kowshik commented on a change in pull request #10271:
URL: https://github.com/apache/kafka/pull/10271#discussion_r622606093
##
File path:
storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/serialization/RemoteLogSegmentMetadataTransform.java
##
@@ -0,0
[
https://issues.apache.org/jira/browse/KAFKA-12417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dejan Stojadinović resolved KAFKA-12417.
Resolution: Done
Resolving as done (commit is merged into trunk).
> streams
jolshan commented on a change in pull request #9590:
URL: https://github.com/apache/kafka/pull/9590#discussion_r622456807
##
File path: core/src/test/scala/unit/kafka/log/LogCleanerTest.scala
##
@@ -984,19 +1003,26 @@ class LogCleanerTest {
def distinctValuesBySegment =
hachikuji commented on pull request #9441:
URL: https://github.com/apache/kafka/pull/9441#issuecomment-828703078
@tombentley Thanks for the updates. I made a few small changes in this
patch:
https://github.com/hachikuji/kafka/commit/27ba937cc7b7da230ccc4f0c8220f680c4a542fe.
The main
ableegoldman commented on a change in pull request #10509:
URL: https://github.com/apache/kafka/pull/10509#discussion_r622472215
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignor.java
##
@@ -263,16 +279,59 @@ private
jsancio commented on pull request #10278:
URL: https://github.com/apache/kafka/pull/10278#issuecomment-828720442
@vamossagar12 Can you add a description to the PR? It is helpful when
reviewing this PR to know what strategy you are using to manage the flush
offset and log flush.
--
This
[
https://issues.apache.org/jira/browse/KAFKA-8613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17335015#comment-17335015
]
Israel Ekpo commented on KAFKA-8613:
I have the initial changes (without the Unit tests yet) here
dielhennr closed pull request #10480:
URL: https://github.com/apache/kafka/pull/10480
--
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.
For queries about this service,
A. Sophie Blee-Goldman created KAFKA-12727:
--
Summary: Flaky test
ListConsumerGroupTest.testListConsumerGroupsWithStates
Key: KAFKA-12727
URL: https://issues.apache.org/jira/browse/KAFKA-12727
dejan2609 opened a new pull request #10606:
URL: https://github.com/apache/kafka/pull/10606
**_JIRA ticket:_** https://issues.apache.org/jira/browse/KAFKA-12728
**_Related pull requests:_**
- #10203
- #10466
Note: we will wait for a Gradle 7.0.1 patch ◀️
--
This
ableegoldman commented on a change in pull request #10509:
URL: https://github.com/apache/kafka/pull/10509#discussion_r622474244
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignor.java
##
@@ -263,16 +279,59 @@ private
ableegoldman merged pull request #10573:
URL: https://github.com/apache/kafka/pull/10573
--
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.
For queries about this service,
ableegoldman commented on pull request #10573:
URL: https://github.com/apache/kafka/pull/10573#issuecomment-828752351
Merged to trunk
--
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
jsancio commented on a change in pull request #10593:
URL: https://github.com/apache/kafka/pull/10593#discussion_r622425656
##
File path:
raft/src/test/java/org/apache/kafka/raft/KafkaRaftClientSnapshotTest.java
##
@@ -1335,6 +1313,57 @@ public void
jolshan commented on a change in pull request #9590:
URL: https://github.com/apache/kafka/pull/9590#discussion_r622456807
##
File path: core/src/test/scala/unit/kafka/log/LogCleanerTest.scala
##
@@ -984,19 +1003,26 @@ class LogCleanerTest {
def distinctValuesBySegment =
[
https://issues.apache.org/jira/browse/KAFKA-9295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17334937#comment-17334937
]
A. Sophie Blee-Goldman commented on KAFKA-9295:
---
It's failing on
{noformat}
[
https://issues.apache.org/jira/browse/KAFKA-12724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-12724:
Component/s: system tests
streams
> Add 2.8.0 to system tests and
jolshan commented on a change in pull request #9590:
URL: https://github.com/apache/kafka/pull/9590#discussion_r622505823
##
File path: core/src/test/scala/integration/kafka/api/PlaintextConsumerTest.scala
##
@@ -1267,6 +1266,64 @@ class PlaintextConsumerTest extends
[
https://issues.apache.org/jira/browse/KAFKA-10800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jose Armando Garcia Sancio updated KAFKA-10800:
---
Description:
When the state machine attempts to create a snapshot
wcarlson5 removed a comment on pull request #10603:
URL: https://github.com/apache/kafka/pull/10603#issuecomment-828525217
@ableegoldman @rodesai @cadonna as a rough improvement what do you think? I
don't think that we need to get this perfect right now but I think that any
kowshik commented on a change in pull request #10271:
URL: https://github.com/apache/kafka/pull/10271#discussion_r621909054
##
File path:
raft/src/main/java/org/apache/kafka/raft/metadata/AbstractApiMessageSerde.java
##
@@ -0,0 +1,93 @@
+/*
+ * Licensed to the Apache Software
Dejan Stojadinović created KAFKA-12728:
--
Summary: Update Gradle version: 6.8 -->> 7.0
Key: KAFKA-12728
URL: https://issues.apache.org/jira/browse/KAFKA-12728
Project: Kafka
Issue Type:
jsancio commented on a change in pull request #10480:
URL: https://github.com/apache/kafka/pull/10480#discussion_r622455380
##
File path: raft/src/main/java/org/apache/kafka/raft/LeaderState.java
##
@@ -67,6 +74,30 @@ protected LeaderState(
}
ableegoldman commented on a change in pull request #10597:
URL: https://github.com/apache/kafka/pull/10597#discussion_r622464617
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -344,7 +345,7 @@ private boolean isRunningOrRebalancing() {
jsancio commented on a change in pull request #10480:
URL: https://github.com/apache/kafka/pull/10480#discussion_r622489394
##
File path: raft/src/main/java/org/apache/kafka/raft/LeaderState.java
##
@@ -67,6 +74,30 @@ protected LeaderState(
}
ableegoldman commented on pull request #10573:
URL: https://github.com/apache/kafka/pull/10573#issuecomment-828751235
Tons of flaky test failures, all unrelated. Mostly Connect and Raft, a few
Streams tests that are known to be flaky which I left some thoughts on the
ticket for. Going to
junrao commented on pull request #9944:
URL: https://github.com/apache/kafka/pull/9944#issuecomment-828795518
I think the upgrade case is similar---it's rare and transient. So, we could
choose to have a simpler and less optimized way for handling it. I am not sure
if we trigger metadata
dengziming commented on pull request #10598:
URL: https://github.com/apache/kafka/pull/10598#issuecomment-828185212
> @dengziming nice improvement. LGTM
>
> BTW, line#203
(https://github.com/apache/kafka/blob/trunk/core/src/main/scala/kafka/tools/ConsoleConsumer.scala#L203)
has
dajac commented on a change in pull request #10599:
URL: https://github.com/apache/kafka/pull/10599#discussion_r621881429
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/AbortTransactionResult.java
##
@@ -0,0 +1,52 @@
+/*
+ * Licensed to the Apache Software
dajac commented on a change in pull request #10599:
URL: https://github.com/apache/kafka/pull/10599#discussion_r621882118
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/AbortTransactionSpec.java
##
@@ -0,0 +1,85 @@
+/*
+ * Licensed to the Apache Software
showuon commented on pull request #10547:
URL: https://github.com/apache/kafka/pull/10547#issuecomment-828180085
Failed tests are all un-related. (Not in MirrorMakerIntegrationTest)
```
Build / JDK 11 and Scala 2.13 /
vitojeng commented on a change in pull request #10597:
URL: https://github.com/apache/kafka/pull/10597#discussion_r621901521
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -344,7 +345,7 @@ private boolean isRunningOrRebalancing() {
tombentley commented on pull request #10023:
URL: https://github.com/apache/kafka/pull/10023#issuecomment-828376561
@hachikuji any chance you could review this?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
showuon commented on a change in pull request #10509:
URL: https://github.com/apache/kafka/pull/10509#discussion_r622064430
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignor.java
##
@@ -263,16 +279,59 @@ private boolean
showuon edited a comment on pull request #10509:
URL: https://github.com/apache/kafka/pull/10509#issuecomment-828440406
@ableegoldman , thanks for your great comments! If there's a best reviewer
contest, I'd definitely vote for you! :) I've replied your
`getUnassignedPartitions` comments.
kamalcph opened a new pull request #10602:
URL: https://github.com/apache/kafka/pull/10602
* Ran `./gradlew streams:testAll` to verify the streams upgrade test.
* Ran individual system test in my local setup.
### Committer Checklist (excluded from commit message)
- [ ] Verify
kamalcph commented on a change in pull request #10602:
URL: https://github.com/apache/kafka/pull/10602#discussion_r622198249
##
File path:
streams/upgrade-system-tests-28/src/test/java/org/apache/kafka/streams/tests/SmokeTestClient.java
##
@@ -0,0 +1,299 @@
+/*
+ * Licensed
kamalcph commented on pull request #10602:
URL: https://github.com/apache/kafka/pull/10602#issuecomment-828471522
@chia7712 @mjsax @ijuma
Ping for review
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
showuon commented on a change in pull request #10509:
URL: https://github.com/apache/kafka/pull/10509#discussion_r622064430
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignor.java
##
@@ -263,16 +279,59 @@ private boolean
showuon commented on a change in pull request #10509:
URL: https://github.com/apache/kafka/pull/10509#discussion_r622064430
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignor.java
##
@@ -263,16 +279,59 @@ private boolean
[
https://issues.apache.org/jira/browse/KAFKA-12724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kamal Chandraprakash updated KAFKA-12724:
-
Description: Kafka v2.8.0 is released. We should add this version to the
system
Kamal Chandraprakash created KAFKA-12724:
Summary: Add 2.8.0 to system tests and streams upgrade tests
Key: KAFKA-12724
URL: https://issues.apache.org/jira/browse/KAFKA-12724
Project: Kafka
showuon commented on a change in pull request #10509:
URL: https://github.com/apache/kafka/pull/10509#discussion_r622040343
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignor.java
##
@@ -263,16 +279,59 @@ private boolean
showuon commented on a change in pull request #10509:
URL: https://github.com/apache/kafka/pull/10509#discussion_r622064430
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignor.java
##
@@ -263,16 +279,59 @@ private boolean
showuon commented on pull request #10509:
URL: https://github.com/apache/kafka/pull/10509#issuecomment-828440406
@ableegoldman , thanks for your great comments! If there's a best reviewer
contest, I'd definitely vote for you! :) I've replied the
`getUnassignedPartitions` comments. Please
showuon commented on a change in pull request #10509:
URL: https://github.com/apache/kafka/pull/10509#discussion_r622040343
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignor.java
##
@@ -263,16 +279,59 @@ private boolean
showuon commented on a change in pull request #10509:
URL: https://github.com/apache/kafka/pull/10509#discussion_r622210601
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignor.java
##
@@ -263,16 +279,59 @@ private boolean
guozhangwang merged pull request #10462:
URL: https://github.com/apache/kafka/pull/10462
--
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.
For queries about this service,
[
https://issues.apache.org/jira/browse/KAFKA-7572?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wenhao Ji reassigned KAFKA-7572:
Assignee: Wenhao Ji
> Producer should not send requests with negative partition id
>
showuon commented on a change in pull request #10509:
URL: https://github.com/apache/kafka/pull/10509#discussion_r622707404
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignor.java
##
@@ -163,127 +159,179 @@ private boolean
[
https://issues.apache.org/jira/browse/KAFKA-12718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17335118#comment-17335118
]
Bernardo Yusti commented on KAFKA-12718:
Hi [~mjsax] ,
I would like to help out with this
[
https://issues.apache.org/jira/browse/KAFKA-12729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luws updated KAFKA-12729:
-
Attachment: image-2021-04-29-11-35-52-191.png
> controller leader keep disconnected and block the cluster
>
[
https://issues.apache.org/jira/browse/KAFKA-12729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luws updated KAFKA-12729:
-
Description:
kafka version. 2.12-2.1.1
after zk flash disconnected
then broker6 become the controller leader
[
https://issues.apache.org/jira/browse/KAFKA-12729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luws updated KAFKA-12729:
-
Attachment: image-2021-04-29-11-35-26-994.png
> controller leader keep disconnected and block the cluster
>
[
https://issues.apache.org/jira/browse/KAFKA-12729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luws updated KAFKA-12729:
-
Attachment: image-2021-04-29-11-35-41-393.png
> controller leader keep disconnected and block the cluster
>
[
https://issues.apache.org/jira/browse/KAFKA-12729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luws updated KAFKA-12729:
-
Description:
kafka version. 2.12-2.1.1
after zk flash disconnected
then broker6 become the controller leader
ableegoldman opened a new pull request #10608:
URL: https://github.com/apache/kafka/pull/10608
Minor followup to https://github.com/apache/kafka/pull/10342 that I noticed
while working on the NamedTopology stuff. Cleans up a few things:
1. We no longer need locking for the global
ableegoldman commented on a change in pull request #10608:
URL: https://github.com/apache/kafka/pull/10608#discussion_r622718411
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/StateDirectoryTest.java
##
@@ -315,7 +314,7 @@ public void
ableegoldman commented on a change in pull request #10608:
URL: https://github.com/apache/kafka/pull/10608#discussion_r622718411
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/StateDirectoryTest.java
##
@@ -315,7 +314,7 @@ public void
ableegoldman commented on pull request #10608:
URL: https://github.com/apache/kafka/pull/10608#issuecomment-828927542
call for review any of @wcarlson5 @lct45 @cadonna @guozhangwang @mjsax
@vvcephei @rodesai
--
This is an automated message from the Apache Git Service.
To respond to the
showuon commented on a change in pull request #10509:
URL: https://github.com/apache/kafka/pull/10509#discussion_r622670757
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignor.java
##
@@ -263,16 +279,59 @@ private boolean
showuon commented on pull request #10598:
URL: https://github.com/apache/kafka/pull/10598#issuecomment-828879776
@chia7712 , I've updated my github profile. It's `show...@gmail.com`. Haha~
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
showuon commented on a change in pull request #10509:
URL: https://github.com/apache/kafka/pull/10509#discussion_r622705781
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignor.java
##
@@ -163,127 +159,179 @@ private boolean
[
https://issues.apache.org/jira/browse/KAFKA-12729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luws updated KAFKA-12729:
-
Attachment: image-2021-04-29-11-33-24-303.png
> controller leader keep disconnected and block the cluster
>
[
https://issues.apache.org/jira/browse/KAFKA-12729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luws updated KAFKA-12729:
-
Attachment: image-2021-04-29-11-33-53-048.png
> controller leader keep disconnected and block the cluster
>
[
https://issues.apache.org/jira/browse/KAFKA-12729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luws updated KAFKA-12729:
-
Attachment: image-2021-04-29-11-34-18-654.png
> controller leader keep disconnected and block the cluster
>
1 - 100 of 148 matches
Mail list logo
