C0urante commented on pull request #9669:
URL: https://github.com/apache/kafka/pull/9669#issuecomment-736896160
Thanks, Nigel.
@chia7712 @rhauch @kkonstantine would you like to take a look?
This is an automated message
chia7712 commented on pull request #9666:
URL: https://github.com/apache/kafka/pull/9666#issuecomment-736902424
> guess you were trying to get this working instead?
#9652
Removing travis test is ok to me.
This
abbccdda commented on a change in pull request #9564:
URL: https://github.com/apache/kafka/pull/9564#discussion_r533814137
##
File path: core/src/main/scala/kafka/server/AlterIsrManager.scala
##
@@ -88,20 +88,33 @@ class AlterIsrManagerImpl(val controllerChannelManager:
Broker
hachikuji commented on pull request #9666:
URL: https://github.com/apache/kafka/pull/9666#issuecomment-736910631
@chia7712 Nice that you got it working! I think there is value running a
subset of system tests automatically. It might even encourage us to write more
system tests if we can ge
jsancio commented on a change in pull request #9512:
URL: https://github.com/apache/kafka/pull/9512#discussion_r533828329
##
File path: raft/src/main/java/org/apache/kafka/raft/RaftClient.java
##
@@ -100,4 +102,15 @@ default void handleResign() {}
*/
CompletableFutur
A. Sophie Blee-Goldman created KAFKA-10793:
--
Summary: Race condition in FindCoordinatorFuture permanently
severs connection to group coordinator
Key: KAFKA-10793
URL: https://issues.apache.org/jira/browse
jsancio commented on a change in pull request #9512:
URL: https://github.com/apache/kafka/pull/9512#discussion_r533829583
##
File path: raft/src/main/java/org/apache/kafka/snapshot/Snapshots.java
##
@@ -0,0 +1,67 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under
jsancio commented on a change in pull request #9512:
URL: https://github.com/apache/kafka/pull/9512#discussion_r533833428
##
File path: raft/src/main/java/org/apache/kafka/snapshot/Snapshots.java
##
@@ -0,0 +1,67 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under
jsancio commented on a change in pull request #9512:
URL: https://github.com/apache/kafka/pull/9512#discussion_r533835857
##
File path: raft/src/main/java/org/apache/kafka/raft/ReplicatedLog.java
##
@@ -149,6 +152,29 @@ default OptionalLong truncateToEndOffset(OffsetAndEpoch
e
[
https://issues.apache.org/jira/browse/KAFKA-10793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17241976#comment-17241976
]
A. Sophie Blee-Goldman commented on KAFKA-10793:
At this point we can on
[
https://issues.apache.org/jira/browse/KAFKA-10793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17241976#comment-17241976
]
A. Sophie Blee-Goldman edited comment on KAFKA-10793 at 12/2/20, 1:37 AM:
[
https://issues.apache.org/jira/browse/KAFKA-10793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17241976#comment-17241976
]
A. Sophie Blee-Goldman edited comment on KAFKA-10793 at 12/2/20, 1:37 AM:
[
https://issues.apache.org/jira/browse/KAFKA-10793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17241976#comment-17241976
]
A. Sophie Blee-Goldman edited comment on KAFKA-10793 at 12/2/20, 1:37 AM:
[
https://issues.apache.org/jira/browse/KAFKA-10780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dengziming resolved KAFKA-10780.
Resolution: Won't Do
KIP-500 will replace all this code.
> Rewrite ControllerZNode struct with a
[
https://issues.apache.org/jira/browse/KAFKA-10793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17241985#comment-17241985
]
lqjacklee commented on KAFKA-10793:
---
[~ableegoldman] I want to check whether the heart
[
https://issues.apache.org/jira/browse/KAFKA-10793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17241987#comment-17241987
]
A. Sophie Blee-Goldman commented on KAFKA-10793:
So that's our best gues
[
https://issues.apache.org/jira/browse/KAFKA-10688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17241992#comment-17241992
]
Guozhang Wang commented on KAFKA-10688:
---
Had some more discussions with [~cadonna]
[
https://issues.apache.org/jira/browse/KAFKA-10793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17241976#comment-17241976
]
A. Sophie Blee-Goldman edited comment on KAFKA-10793 at 12/2/20, 2:26 AM:
[
https://issues.apache.org/jira/browse/KAFKA-10793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17241976#comment-17241976
]
A. Sophie Blee-Goldman edited comment on KAFKA-10793 at 12/2/20, 2:30 AM:
chia7712 commented on pull request #9666:
URL: https://github.com/apache/kafka/pull/9666#issuecomment-736948097
> Nice that you got it working! I think there is value running a subset of
system tests automatically. It might even encourage us to write more system
tests if we can get the fee
ableegoldman opened a new pull request #9671:
URL: https://github.com/apache/kafka/pull/9671
A race condition between the consumer and hb thread can lead to a failed but
non-null `findCoordinatorFuture`, causing the AbstractCoordinator to wait
endlessly on the request which it thinks is st
highluck commented on a change in pull request #8965:
URL: https://github.com/apache/kafka/pull/8965#discussion_r533863847
##
File path: docs/streams/developer-guide/dsl-api.html
##
@@ -3393,6 +3393,10 @@ KTable-KTable
Foreign-Key
but this
limeng created KAFKA-10794:
--
Summary: Replica leader election is too slow in the case of too
many partitions
Key: KAFKA-10794
URL: https://issues.apache.org/jira/browse/KAFKA-10794
Project: Kafka
I
[
https://issues.apache.org/jira/browse/KAFKA-9263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai updated KAFKA-9263:
--
Summary: The new hw is added to incorrect log when
ReplicaAlterLogDirsThread is replacing log
[
https://issues.apache.org/jira/browse/KAFKA-9263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai reassigned KAFKA-9263:
-
Assignee: Chia-Ping Tsai
> The new hw is added to incorrect log when ReplicaAlterLogDir
[
https://issues.apache.org/jira/browse/KAFKA-9263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17242016#comment-17242016
]
Chia-Ping Tsai commented on KAFKA-9263:
---
PlaintextAdminIntegrationTest.testLogStart
chia7712 merged pull request #9423:
URL: https://github.com/apache/kafka/pull/9423
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 t
[
https://issues.apache.org/jira/browse/KAFKA-9263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai resolved KAFKA-9263.
---
Fix Version/s: 2.8.0
Resolution: Fixed
> The new hw is added to incorrect log when Re
showuon opened a new pull request #9672:
URL: https://github.com/apache/kafka/pull/9672
work in progress for Eos test(don't review)
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
-
ableegoldman commented on pull request #9671:
URL: https://github.com/apache/kafka/pull/9671#issuecomment-736964914
Waiting to add tests until I get some sanity checks on this proposal
This is an automated message from the Ap
ableegoldman commented on a change in pull request #9609:
URL: https://github.com/apache/kafka/pull/9609#discussion_r533876280
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/SourceGraphNode.java
##
@@ -0,0 +1,71 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/KAFKA-10794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
limeng updated KAFKA-10794:
---
Description:
There is more than 6000 topics and 300 brokers in my kafka cluster, and we set
the config:'aut
[
https://issues.apache.org/jira/browse/KAFKA-10794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
limeng updated KAFKA-10794:
---
Attachment: clipboard_image_1606806581629.png
> Replica leader election is too slow in the case of too many
[
https://issues.apache.org/jira/browse/KAFKA-10794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
limeng updated KAFKA-10794:
---
Description:
There is more than 6000 topics and 300 brokers in my kafka cluster, and we set
the config:'aut
[
https://issues.apache.org/jira/browse/KAFKA-10794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
limeng updated KAFKA-10794:
---
Attachment: 截屏2020-12-02 上午11.43.48.png
> Replica leader election is too slow in the case of too many partit
ableegoldman commented on a change in pull request #9615:
URL: https://github.com/apache/kafka/pull/9615#discussion_r533878767
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -870,43 +899,73 @@ private KafkaStreams(final InternalTopologyBuil
[
https://issues.apache.org/jira/browse/KAFKA-10772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17242025#comment-17242025
]
A. Sophie Blee-Goldman commented on KAFKA-10772:
Hm, the leadership chan
junrao commented on pull request #8826:
URL: https://github.com/apache/kafka/pull/8826#issuecomment-736983541
@chia7712 : There are 6 failures in the system test run. Are they related
to this PR?
http://confluent-kafka-branch-builder-system-test-results.s3-us-west-2.amazonaws.com/2
d8tltanc commented on a change in pull request #9485:
URL: https://github.com/apache/kafka/pull/9485#discussion_r533765909
##
File path:
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/acl/AclAuthorizerBenchmark.java
##
@@ -69,33 +70,39 @@
@BenchmarkMode(Mode.AverageTime)
d8tltanc commented on a change in pull request #9485:
URL: https://github.com/apache/kafka/pull/9485#discussion_r533765909
##
File path:
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/acl/AclAuthorizerBenchmark.java
##
@@ -69,33 +70,39 @@
@BenchmarkMode(Mode.AverageTime)
[
https://issues.apache.org/jira/browse/KAFKA-10665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen reassigned KAFKA-10665:
-
Assignee: Luke Chen
> Flaky Test
> StreamTableJoinTopologyOptimizationIntegrationTest.shouldDo
[
https://issues.apache.org/jira/browse/KAFKA-10665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17242063#comment-17242063
]
Luke Chen commented on KAFKA-10665:
---
org.apache.kafka.streams.integration.StreamTableJ
[
https://issues.apache.org/jira/browse/KAFKA-10665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17242062#comment-17242062
]
Luke Chen commented on KAFKA-10665:
---
org.apache.kafka.streams.integration.StreamTableJ
d8tltanc commented on a change in pull request #9485:
URL: https://github.com/apache/kafka/pull/9485#discussion_r533915036
##
File path:
clients/src/main/java/org/apache/kafka/server/authorizer/Authorizer.java
##
@@ -139,4 +152,125 @@
* @return Iterator for ACL bindings,
d8tltanc commented on a change in pull request #9485:
URL: https://github.com/apache/kafka/pull/9485#discussion_r533915142
##
File path:
clients/src/main/java/org/apache/kafka/server/authorizer/Authorizer.java
##
@@ -139,4 +152,125 @@
* @return Iterator for ACL bindings,
d8tltanc commented on a change in pull request #9485:
URL: https://github.com/apache/kafka/pull/9485#discussion_r533915261
##
File path:
clients/src/main/java/org/apache/kafka/server/authorizer/Authorizer.java
##
@@ -139,4 +152,125 @@
* @return Iterator for ACL bindings,
d8tltanc commented on a change in pull request #9485:
URL: https://github.com/apache/kafka/pull/9485#discussion_r533916889
##
File path:
clients/src/main/java/org/apache/kafka/server/authorizer/Authorizer.java
##
@@ -139,4 +152,125 @@
* @return Iterator for ACL bindings,
d8tltanc commented on a change in pull request #9485:
URL: https://github.com/apache/kafka/pull/9485#discussion_r533919425
##
File path: core/src/main/scala/kafka/security/authorizer/AclAuthorizer.scala
##
@@ -304,6 +308,122 @@ class AclAuthorizer extends Authorizer with Loggin
d8tltanc commented on a change in pull request #9485:
URL: https://github.com/apache/kafka/pull/9485#discussion_r533922526
##
File path:
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/acl/AclAuthorizerBenchmark.java
##
@@ -115,45 +122,62 @@ private void setFieldValue(Object
[
https://issues.apache.org/jira/browse/KAFKA-10289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai reassigned KAFKA-10289:
--
Assignee: Chia-Ping Tsai
> fix flaky connect/connect_distributed_test.py
> --
[
https://issues.apache.org/jira/browse/KAFKA-10289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai updated KAFKA-10289:
---
Summary: fix failed connect_distributed_test.py.test_bounce (was: fix
flaky connect/connect
[
https://issues.apache.org/jira/browse/KAFKA-10289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai updated KAFKA-10289:
---
Summary: fix failed connect_distributed_test.py
(ConnectDistributedTest.test_bounce) (was:
chia7712 opened a new pull request #9673:
URL: https://github.com/apache/kafka/pull/9673
issue: https://issues.apache.org/jira/browse/KAFKA-10289
In Python 3, ```filter``` functions return iterators rather than ```list```
so it can traverse only once. Hence, the following loop only s
chia7712 commented on pull request #8826:
URL: https://github.com/apache/kafka/pull/8826#issuecomment-737028662
> There are 6 failures in the system test run. Are they related to this PR?
They are unrelated to this PR and I have opened a PR to fix them (#9673)
--
[
https://issues.apache.org/jira/browse/KAFKA-10794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
limeng updated KAFKA-10794:
---
Description:
There is more than 6000 topics and 300 brokers in my kafka cluster, and we
frequently run kafk
[
https://issues.apache.org/jira/browse/KAFKA-10794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
limeng updated KAFKA-10794:
---
Attachment: 截屏2020-12-01 下午2.36.19.png
> Replica leader election is too slow in the case of too many partiti
[
https://issues.apache.org/jira/browse/KAFKA-10794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
limeng updated KAFKA-10794:
---
Attachment: image-2020-12-02-15-23-43-384.png
> Replica leader election is too slow in the case of too many
[
https://issues.apache.org/jira/browse/KAFKA-10794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
limeng updated KAFKA-10794:
---
Description:
There is more than 6000 topics and 300 brokers in my kafka cluster, and we
frequently run kafk
[
https://issues.apache.org/jira/browse/KAFKA-10636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
feyman reassigned KAFKA-10636:
--
Assignee: feyman
> Bypass log validation for writes to raft log
> ---
showuon opened a new pull request #9674:
URL: https://github.com/apache/kafka/pull/9674
The flaky tests are because we forgot to close the kafkaStreams before
purgeLocalStreamsState, so that sometimes there will be some tmp files be
created during streams running/removing (ex: `checkpoint.
showuon commented on a change in pull request #9674:
URL: https://github.com/apache/kafka/pull/9674#discussion_r533956676
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/StreamTableJoinTopologyOptimizationIntegrationTest.java
##
@@ -149,9 +153,7 @@ pub
[
https://issues.apache.org/jira/browse/KAFKA-10636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17242122#comment-17242122
]
feyman commented on KAFKA-10636:
Hi, [~hachikuji] . I would like to take this task, plea
showuon commented on a change in pull request #9674:
URL: https://github.com/apache/kafka/pull/9674#discussion_r533956768
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/StreamTableJoinTopologyOptimizationIntegrationTest.java
##
@@ -221,7 +223,7 @@ pri
showuon commented on pull request #9674:
URL: https://github.com/apache/kafka/pull/9674#issuecomment-737056995
@bbejeck @vvcephei @lkokhreidze , please help review this PR. Thanks.
This is an automated message from the Apache
101 - 164 of 164 matches
Mail list logo