[
https://issues.apache.org/jira/browse/KAFKA-10879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhifeng.peng updated KAFKA-10879:
-
Attachment: kafka.jstack
> ReplicaFetcherThread crash when cluster doing reassign
>
[
https://issues.apache.org/jira/browse/KAFKA-10879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhifeng.peng updated KAFKA-10879:
-
Description:
[2020-12-21 12:01:28,110] ERROR [ReplicaFetcher replicaId=3, leaderId=6,
fetcherId
chia7712 commented on pull request #9520:
URL: https://github.com/apache/kafka/pull/9520#issuecomment-750005283
@ijuma the latest commit replaces all ExpectedException or @Test(expected =
Exception.class) by assertThrows. It seems to me we can get closer to junit 5
if this PR is got into t
chia7712 edited a comment on pull request #9520:
URL: https://github.com/apache/kafka/pull/9520#issuecomment-750005283
@ijuma the latest commit replaces all ExpectedException or @Test(expected =
Exception.class) by assertThrows. It seems to me we can get closer to junit 5
if this PR is got
Wenbing Shen created KAFKA-10886:
Summary: Kafka crashed in windows environment2
Key: KAFKA-10886
URL: https://issues.apache.org/jira/browse/KAFKA-10886
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-10886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wenbing Shen updated KAFKA-10886:
-
Description:
I tried using the [Kafka-9458|https://issues.apache.org/jira/browse/KAFKA-9458]
pa
[
https://issues.apache.org/jira/browse/KAFKA-10886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wenbing Shen updated KAFKA-10886:
-
External issue URL: (was:
https://issues.apache.org/jira/browse/KAFKA-9458)
> Kafka crashed i
[
https://issues.apache.org/jira/browse/KAFKA-10886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17253993#comment-17253993
]
Wenbing Shen edited comment on KAFKA-10886 at 12/23/20, 9:49 AM:
-
[
https://issues.apache.org/jira/browse/KAFKA-9458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17251530#comment-17251530
]
Wenbing Shen edited comment on KAFKA-9458 at 12/23/20, 9:53 AM:
---
chia7712 edited a comment on pull request #9520:
URL: https://github.com/apache/kafka/pull/9520#issuecomment-750005283
@ijuma the latest commit replaces all ExpectedException or @Test(expected =
Exception.class) by assertThrows. It seems to me we can get closer to junit 5
if this PR is got
ijuma commented on pull request #9520:
URL: https://github.com/apache/kafka/pull/9520#issuecomment-750345209
@chia7712 Thanks. I was about halfway through the review of the second to
last commit. :) Let's get this PR over the line and not change it further
please. Yes, I had filed a few JI
ijuma edited a comment on pull request #9520:
URL: https://github.com/apache/kafka/pull/9520#issuecomment-750345209
@chia7712 Thanks. I was about halfway through the review of the second to
last commit. :) Let's get this PR over the line and not change it further
please. Yes, I had filed a
chia7712 commented on pull request #9520:
URL: https://github.com/apache/kafka/pull/9520#issuecomment-750351742
> I was about halfway through the review of the second to last commit. :)
Let's get this PR over the line and not change it further please.
I am so sorry my force push obs
chia7712 commented on pull request #9520:
URL: https://github.com/apache/kafka/pull/9520#issuecomment-750355111
> Feel free to take one or more of the other ones. core would be a good
candidate perhaps.
I’d like to take over both core module and stream module :)
---
[
https://issues.apache.org/jira/browse/KAFKA-6579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17254130#comment-17254130
]
Stanislav Pak commented on KAFKA-6579:
--
This looks non-trivial based on previous att
chia7712 commented on a change in pull request #9776:
URL: https://github.com/apache/kafka/pull/9776#discussion_r548031919
##
File path:
clients/src/test/java/org/apache/kafka/common/protocol/types/ProtocolSerializationTest.java
##
@@ -414,7 +416,7 @@ public void
testReadWhen
chia7712 merged pull request #9782:
URL: https://github.com/apache/kafka/pull/9782
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
chia7712 merged pull request #9783:
URL: https://github.com/apache/kafka/pull/9783
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-10815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai resolved KAFKA-10815.
Resolution: Fixed
> EosTestDriver#verifyAllTransactionFinished should break loop if all
>
chia7712 merged pull request #9763:
URL: https://github.com/apache/kafka/pull/9763
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-7342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai reassigned KAFKA-7342:
-
Assignee: Chia-Ping Tsai (was: Ismael Juma)
> Migrate streams modules to JUnit 5
>
[
https://issues.apache.org/jira/browse/KAFKA-7341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai reassigned KAFKA-7341:
-
Assignee: Chia-Ping Tsai (was: Ismael Juma)
> Migrate core module to JUnit 5
>
Chia-Ping Tsai created KAFKA-10887:
--
Summary: Migrate log4j-appender module to Junit 5
Key: KAFKA-10887
URL: https://issues.apache.org/jira/browse/KAFKA-10887
Project: Kafka
Issue Type: Sub-
[
https://issues.apache.org/jira/browse/KAFKA-10887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai updated KAFKA-10887:
---
Summary: Migrate log4j-appender module to JUnit 5 (was: Migrate
log4j-appender module to Ju
bbejeck commented on pull request #9774:
URL: https://github.com/apache/kafka/pull/9774#issuecomment-750411633
System tests passed
This is an automated message from the Apache Git Service.
To respond to the message, please lo
mjsax commented on pull request #9706:
URL: https://github.com/apache/kafka/pull/9706#issuecomment-750433680
@chia7712 -- thanks for getting this into 2.7 and 2.6. (Btw: there is no
need to do PRs. You can also cherry-pick and push directly.)
--
chia7712 commented on pull request #9706:
URL: https://github.com/apache/kafka/pull/9706#issuecomment-750436117
> thanks for getting this into 2.7 and 2.6. (Btw: there is no need to do
PRs. You can also cherry-pick and push directly.)
Thanks for kind reminder!
-
mjsax commented on pull request #9733:
URL: https://github.com/apache/kafka/pull/9733#issuecomment-750436773
Thanks for the input! The test behavior is slightly different in `2.6`
compared to `2.7/trunk` though and thus, I am not sure if we can apply the same
reasoning (that is also the re
mjsax commented on a change in pull request #9733:
URL: https://github.com/apache/kafka/pull/9733#discussion_r548160122
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/EosBetaUpgradeIntegrationTest.java
##
@@ -246,18 +261,19 @@ public void shouldUpgrad
[
https://issues.apache.org/jira/browse/KAFKA-10815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-10815:
Fix Version/s: (was: 2.6.1)
2.6.2
> EosTestDriver#verifyAllTransact
mjsax commented on a change in pull request #9606:
URL: https://github.com/apache/kafka/pull/9606#discussion_r548180364
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindowedCogroupedKStream.java
##
@@ -77,7 +77,8 @@
* {@link StreamsConfig#CACH
mjsax merged pull request #9668:
URL: https://github.com/apache/kafka/pull/9668
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-10876?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17254244#comment-17254244
]
Chris Egerton commented on KAFKA-10876:
---
[~xakassi] they're definitely related, bu
C0urante opened a new pull request #9784:
URL: https://github.com/apache/kafka/pull/9784
If a connector fails on startup, the original cause of the error gets
discarded by the framework and the only message that gets logged looks like
this:
```
[2020-12-04 16:46:30,464] ERROR [Wo
fml2 commented on a change in pull request #9606:
URL: https://github.com/apache/kafka/pull/9606#discussion_r548280588
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindowedCogroupedKStream.java
##
@@ -77,7 +77,8 @@
* {@link StreamsConfig#CACHE
fml2 commented on a change in pull request #9606:
URL: https://github.com/apache/kafka/pull/9606#discussion_r548280702
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindowedKStream.java
##
@@ -67,7 +67,8 @@
* {@link StreamsConfig#CACHE_MAX_BYTE
mjsax merged pull request #9606:
URL: https://github.com/apache/kafka/pull/9606
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
mjsax commented on pull request #9606:
URL: https://github.com/apache/kafka/pull/9606#issuecomment-750589950
Thanks for updating the PR. Merged to `trunk`.
This is an automated message from the Apache Git Service.
To respond
[
https://issues.apache.org/jira/browse/KAFKA-10722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-10722:
---
Assignee: fml2
> Timestamped store is used even if not desired
> --
[
https://issues.apache.org/jira/browse/KAFKA-10722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-10722.
-
Fix Version/s: 2.8.0
Resolution: Fixed
Added you to the list of contributors and
[
https://issues.apache.org/jira/browse/KAFKA-10886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wenbing Shen reassigned KAFKA-10886:
Assignee: Wenbing Shen
> Kafka crashed in windows environment2
>
[
https://issues.apache.org/jira/browse/KAFKA-10886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wenbing Shen reassigned KAFKA-10886:
Assignee: (was: Wenbing Shen)
> Kafka crashed in windows environment2
> -
[
https://issues.apache.org/jira/browse/KAFKA-10887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17254369#comment-17254369
]
GeordieMai commented on KAFKA-10887:
[~chia7712] can I take this ? It seems to be a
[
https://issues.apache.org/jira/browse/KAFKA-10887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17254369#comment-17254369
]
GeordieMai edited comment on KAFKA-10887 at 12/24/20, 2:30 AM:
---
[
https://issues.apache.org/jira/browse/KAFKA-10887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17254390#comment-17254390
]
Chia-Ping Tsai commented on KAFKA-10887:
[~Geordie] sure. Go ahead!
> Migrate l
[
https://issues.apache.org/jira/browse/KAFKA-10887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai reassigned KAFKA-10887:
--
Assignee: GeordieMai (was: Chia-Ping Tsai)
> Migrate log4j-appender module to JUnit
g1geordie commented on a change in pull request #9776:
URL: https://github.com/apache/kafka/pull/9776#discussion_r548375097
##
File path:
clients/src/test/java/org/apache/kafka/common/protocol/types/ProtocolSerializationTest.java
##
@@ -414,7 +416,7 @@ public void
testReadWhe
chia7712 commented on a change in pull request #9776:
URL: https://github.com/apache/kafka/pull/9776#discussion_r548375460
##
File path:
clients/src/test/java/org/apache/kafka/common/protocol/types/ProtocolSerializationTest.java
##
@@ -414,7 +416,7 @@ public void
testReadWhen
chia7712 commented on a change in pull request #9778:
URL: https://github.com/apache/kafka/pull/9778#discussion_r548375601
##
File path: core/src/test/scala/unit/kafka/server/ClientQuotasRequestTest.scala
##
@@ -212,7 +214,9 @@ class ClientQuotasRequestTest extends BaseRequestT
[
https://issues.apache.org/jira/browse/KAFKA-10871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17254408#comment-17254408
]
Rohit Deshpande commented on KAFKA-10871:
-
got it thanks [~mjsax] i will go ahea
[
https://issues.apache.org/jira/browse/KAFKA-10871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rohit Deshpande resolved KAFKA-10871.
-
Resolution: Not A Bug
> StreamTask shouldn't take WallClockTime as input parameter in pr
showuon commented on a change in pull request #9733:
URL: https://github.com/apache/kafka/pull/9733#discussion_r548399660
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/EosBetaUpgradeIntegrationTest.java
##
@@ -246,18 +261,19 @@ public void shouldUpgr
showuon commented on a change in pull request #9733:
URL: https://github.com/apache/kafka/pull/9733#discussion_r548399660
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/EosBetaUpgradeIntegrationTest.java
##
@@ -246,18 +261,19 @@ public void shouldUpgr
showuon commented on a change in pull request #9733:
URL: https://github.com/apache/kafka/pull/9733#discussion_r548399660
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/EosBetaUpgradeIntegrationTest.java
##
@@ -246,18 +261,19 @@ public void shouldUpgr
g1geordie opened a new pull request #9785:
URL: https://github.com/apache/kafka/pull/9785
Migrate log4j-appender module to JUnit 5
This is an automated message from the Apache Git Service.
To respond to the message, please lo
g1geordie commented on a change in pull request #9778:
URL: https://github.com/apache/kafka/pull/9778#discussion_r548427248
##
File path: core/src/test/scala/unit/kafka/server/ClientQuotasRequestTest.scala
##
@@ -212,7 +214,9 @@ class ClientQuotasRequestTest extends BaseRequest
[
https://issues.apache.org/jira/browse/KAFKA-10885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
GeordieMai updated KAFKA-10885:
---
Description:
{quote}private void assumeAtLeastV2OrNotZstd(byte magic)
Unknown macro: \{ assumeTrue(c
57 matches
Mail list logo
