ableegoldman opened a new pull request #11591:
URL: https://github.com/apache/kafka/pull/11591
Fix for one of the causes of failure in the NamedTopologyIntegrationTest:
`org.apache.kafka.streams.errors.StreamsException:
java.lang.IllegalStateException: Must initialize prevActiveTasks from
[
https://issues.apache.org/jira/browse/KAFKA-13500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17456955#comment-17456955
]
Matthias J. Sax edited comment on KAFKA-13500 at 12/10/21, 8:32 AM:
--
[
https://issues.apache.org/jira/browse/KAFKA-13500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17456955#comment-17456955
]
Matthias J. Sax commented on KAFKA-13500:
-
Not 100% sure: for individual configs
vamossagar12 opened a new pull request #11592:
URL: https://github.com/apache/kafka/pull/11592
There are certain scenario in which Kafka Streams wipes out local state and
rebuilt it from scratch. This is a thread local cleanup, ie, no rebalance is
triggered, and we end up with an offline t
Matthias J. Sax created KAFKA-13530:
---
Summary: Flaky test ReplicaManagerTest
Key: KAFKA-13530
URL: https://issues.apache.org/jira/browse/KAFKA-13530
Project: Kafka
Issue Type: Test
[
https://issues.apache.org/jira/browse/KAFKA-12377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17456966#comment-17456966
]
Matthias J. Sax commented on KAFKA-12377:
-
Failed again.
> Flaky Test SaslAuthe
[
https://issues.apache.org/jira/browse/KAFKA-12319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17456967#comment-17456967
]
Matthias J. Sax commented on KAFKA-12319:
-
Failed again.
> Flaky test
> Connec
[
https://issues.apache.org/jira/browse/KAFKA-13530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17456968#comment-17456968
]
Matthias J. Sax commented on KAFKA-13530:
-
Failed a second time.
> Flaky test R
[
https://issues.apache.org/jira/browse/KAFKA-13514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17456970#comment-17456970
]
Matthias J. Sax commented on KAFKA-13514:
-
Failed again. [~ableegoldman] Could y
[
https://issues.apache.org/jira/browse/KAFKA-12377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17456973#comment-17456973
]
Matthias J. Sax commented on KAFKA-12377:
-
One more.
> Flaky Test SaslAuthentic
[
https://issues.apache.org/jira/browse/KAFKA-12377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17456976#comment-17456976
]
Matthias J. Sax commented on KAFKA-12377:
-
And one more.
> Flaky Test SaslAuthe
[
https://issues.apache.org/jira/browse/KAFKA-13530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17456978#comment-17456978
]
Matthias J. Sax commented on KAFKA-13530:
-
And one more.
> Flaky test ReplicaMa
[
https://issues.apache.org/jira/browse/KAFKA-13514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17456982#comment-17456982
]
Matthias J. Sax commented on KAFKA-13514:
-
And one more.
> Flakey test StickyAs
[
https://issues.apache.org/jira/browse/KAFKA-13530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17456981#comment-17456981
]
Matthias J. Sax commented on KAFKA-13530:
-
And again.
> Flaky test ReplicaManag
[
https://issues.apache.org/jira/browse/KAFKA-12933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-12933.
-
Resolution: Fixed
> Flaky test
> ReassignPartitionsIntegrationTest.testReassignmentWith
Matthias J. Sax created KAFKA-13531:
---
Summary: Flaky test NamedTopologyIntegrationTest
Key: KAFKA-13531
URL: https://issues.apache.org/jira/browse/KAFKA-13531
Project: Kafka
Issue Type: Tes
[
https://issues.apache.org/jira/browse/KAFKA-12377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17456986#comment-17456986
]
Matthias J. Sax commented on KAFKA-12377:
-
One more on 3.1 branch.
> Flaky Test
Matthias J. Sax created KAFKA-13532:
---
Summary: Flaky test
KafkaStreamsTest.testInitializesAndDestroysMetricsReporters
Key: KAFKA-13532
URL: https://issues.apache.org/jira/browse/KAFKA-13532
Project:
[
https://issues.apache.org/jira/browse/KAFKA-12377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17456989#comment-17456989
]
Matthias J. Sax commented on KAFKA-12377:
-
One more.
> Flaky Test SaslAuthentic
[
https://issues.apache.org/jira/browse/KAFKA-13530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17456990#comment-17456990
]
Matthias J. Sax commented on KAFKA-13530:
-
+1
> Flaky test ReplicaManagerTest
>
[
https://issues.apache.org/jira/browse/KAFKA-8115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17456991#comment-17456991
]
Matthias J. Sax commented on KAFKA-8115:
Failed again.
> Flaky Test CoordinatorT
[
https://issues.apache.org/jira/browse/KAFKA-13530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17456992#comment-17456992
]
Matthias J. Sax commented on KAFKA-13530:
-
Again.
> Flaky test ReplicaManagerTe
[
https://issues.apache.org/jira/browse/KAFKA-8115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17456993#comment-17456993
]
Matthias J. Sax commented on KAFKA-8115:
One more on 3.1.
> Flaky Test Coordinat
[
https://issues.apache.org/jira/browse/KAFKA-8115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17456993#comment-17456993
]
Matthias J. Sax edited comment on KAFKA-8115 at 12/10/21, 9:14 AM:
[
https://issues.apache.org/jira/browse/KAFKA-13388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17457016#comment-17457016
]
David Jacot commented on KAFKA-13388:
-
I had a look at the code as well. [~david.mao
patrickstuedi commented on a change in pull request #11581:
URL: https://github.com/apache/kafka/pull/11581#discussion_r766603920
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/StoreQueryUtils.java
##
@@ -62,4 +71,32 @@ public static void updatePo
vpapavas commented on a change in pull request #11581:
URL: https://github.com/apache/kafka/pull/11581#discussion_r766726224
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/StoreQueryUtils.java
##
@@ -62,4 +71,28 @@ public static void updatePositio
vpapavas commented on a change in pull request #11581:
URL: https://github.com/apache/kafka/pull/11581#discussion_r766731204
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/utils/IntegrationTestUtils.java
##
@@ -125,22 +128,81 @@
final long de
[
https://issues.apache.org/jira/browse/KAFKA-13388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Mao updated KAFKA-13388:
--
Priority: Critical (was: Minor)
> Kafka Producer nodes stuck in CHECKING_API_VERSIONS
> -
[
https://issues.apache.org/jira/browse/KAFKA-13388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17457216#comment-17457216
]
David Mao commented on KAFKA-13388:
---
We should probably bump up the priority of this J
Chris Egerton created KAFKA-13533:
-
Summary: Task resources are not cleaned up if task initialization
fails
Key: KAFKA-13533
URL: https://issues.apache.org/jira/browse/KAFKA-13533
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-13388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17457216#comment-17457216
]
David Mao edited comment on KAFKA-13388 at 12/10/21, 4:43 PM:
[
https://issues.apache.org/jira/browse/KAFKA-13388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17457274#comment-17457274
]
David Jacot commented on KAFKA-13388:
-
I can think of a few ways to fix this:
1) We
[
https://issues.apache.org/jira/browse/KAFKA-13530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17457275#comment-17457275
]
Justine Olshan commented on KAFKA-13530:
Hey Matthias. Thanks for bringing this
jsancio commented on pull request #11536:
URL: https://github.com/apache/kafka/pull/11536#issuecomment-991143098
@dajac I made some changes after you reviewed. Does it LGTM?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
jsancio edited a comment on pull request #11536:
URL: https://github.com/apache/kafka/pull/11536#issuecomment-991143098
@dajac I made some changes after you reviewed. Does it look good to you?
--
This is an automated message from the Apache Git Service.
To respond to the message, please l
soumiksamanta commented on pull request #7898:
URL: https://github.com/apache/kafka/pull/7898#issuecomment-991150391
Will this PR solve
[CVE-2021-44228](https://github.com/advisories/GHSA-jfh8-c2jp-5v3q)?
--
This is an automated message from the Apache Git Service.
To respond to the mess
mimaison commented on a change in pull request #11560:
URL: https://github.com/apache/kafka/pull/11560#discussion_r766857004
##
File path: core/src/main/scala/kafka/network/SocketServer.scala
##
@@ -841,16 +974,17 @@ private[kafka] class Processor(val id: Int,
Option(metri
mimaison merged pull request #11393:
URL: https://github.com/apache/kafka/pull/11393
--
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
guozhangwang commented on a change in pull request #11581:
URL: https://github.com/apache/kafka/pull/11581#discussion_r766893813
##
File path:
streams/src/main/java/org/apache/kafka/streams/query/StateQueryResult.java
##
@@ -97,11 +97,15 @@ public void addResult(final int part
guozhangwang commented on a change in pull request #11581:
URL: https://github.com/apache/kafka/pull/11581#discussion_r766899186
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/CachingKeyValueStore.java
##
@@ -107,10 +107,10 @@ private void putAndM
svudutala-vmware commented on pull request #7898:
URL: https://github.com/apache/kafka/pull/7898#issuecomment-991209328
> Will this PR solve
[CVE-2021-44228](https://github.com/advisories/GHSA-jfh8-c2jp-5v3q)?
@soumiksamanta
https://github.com/apache/kafka/blob/bd3038383265f7bb850c0
jsancio closed pull request #11536:
URL: https://github.com/apache/kafka/pull/11536
--
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.
jsancio commented on pull request #11536:
URL: https://github.com/apache/kafka/pull/11536#issuecomment-991216638
Merged as
https://github.com/apache/kafka/commit/0c01ab67a034a9454fdd1e0c791c56c5466d9ff4
--
This is an automated message from the Apache Git Service.
To respond to the messag
Sai Kiran Vudutala created KAFKA-13534:
--
Summary: Upgrade Log4j to 2.15.0 - CVE-2021-44228
Key: KAFKA-13534
URL: https://issues.apache.org/jira/browse/KAFKA-13534
Project: Kafka
Issue Ty
omkreddy commented on pull request #11506:
URL: https://github.com/apache/kafka/pull/11506#issuecomment-991217959
Pls raise a Kafka JIRA (https://issues.apache.org/jira/projects/KAFKA/) for
any issue.
--
This is an automated message from the Apache Git Service.
To respond to the message,
omkreddy closed pull request #11506:
URL: https://github.com/apache/kafka/pull/11506
--
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
omkreddy commented on pull request #11507:
URL: https://github.com/apache/kafka/pull/11507#issuecomment-991218175
Pls raise a Kafka JIRA (https://issues.apache.org/jira/projects/KAFKA/) for
any issue.
--
This is an automated message from the Apache Git Service.
To respond to the message,
omkreddy closed pull request #11507:
URL: https://github.com/apache/kafka/pull/11507
--
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-13534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sai Kiran Vudutala updated KAFKA-13534:
---
Description:
Log4j has an RCE vulnerability, see
[https://www.lunasec.io/docs/blog/
[
https://issues.apache.org/jira/browse/KAFKA-13534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sai Kiran Vudutala updated KAFKA-13534:
---
Issue Type: Task (was: Improvement)
> Upgrade Log4j to 2.15.0 - CVE-2021-44228
> --
jsancio commented on a change in pull request #11593:
URL: https://github.com/apache/kafka/pull/11593#discussion_r766913504
##
File path:
metadata/src/test/java/org/apache/kafka/controller/ClusterControlManagerTest.java
##
@@ -84,6 +90,27 @@ public void testReplay() {
wcarlson5 closed pull request #11570:
URL: https://github.com/apache/kafka/pull/11570
--
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
[
https://issues.apache.org/jira/browse/KAFKA-6616?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17457334#comment-17457334
]
Jose Armando Garcia Sancio commented on KAFKA-6616:
---
[~vpopov89] I am g
[
https://issues.apache.org/jira/browse/KAFKA-6616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jose Armando Garcia Sancio reassigned KAFKA-6616:
-
Assignee: Jose Armando Garcia Sancio (was: Viktor Popov)
> kafk
[
https://issues.apache.org/jira/browse/KAFKA-13500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17457338#comment-17457338
]
Guozhang Wang commented on KAFKA-13500:
---
Sounds good!
> add a new `standby.produc
ableegoldman commented on pull request #11591:
URL: https://github.com/apache/kafka/pull/11591#issuecomment-991243851
The check before was essentially about two things, (a) sanity check that the
ClientState methods are executed in the correct order since the task
initialization ended up be
guozhangwang commented on pull request #11589:
URL: https://github.com/apache/kafka/pull/11589#issuecomment-991249843
Re-trigger the jenkins jobs.
--
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
ableegoldman commented on pull request #11591:
URL: https://github.com/apache/kafka/pull/11591#issuecomment-991253330
All tests failures unrelated: `ReplicaManagerTest.[1] usesTopicIds=true`
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
guozhangwang commented on a change in pull request #11591:
URL: https://github.com/apache/kafka/pull/11591#discussion_r766944544
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/ClientStateTest.java
##
@@ -406,12 +428,31 @@ public voi
ableegoldman commented on a change in pull request #11591:
URL: https://github.com/apache/kafka/pull/11591#discussion_r766945306
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/ClientStateTest.java
##
@@ -406,12 +428,31 @@ public voi
svudutala-vmware edited a comment on pull request #7898:
URL: https://github.com/apache/kafka/pull/7898#issuecomment-991209328
> Will this PR solve
[CVE-2021-44228](https://github.com/advisories/GHSA-jfh8-c2jp-5v3q)?
@soumiksamanta
https://github.com/apache/kafka/blob/bd3038383265f7
cmccabe merged pull request #11577:
URL: https://github.com/apache/kafka/pull/11577
--
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.
hachikuji merged pull request #11503:
URL: https://github.com/apache/kafka/pull/11503
--
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
ableegoldman commented on pull request #11591:
URL: https://github.com/apache/kafka/pull/11591#issuecomment-991345183
Two unrelated test failures in `.LeaderElectionCommandTest.[1] Type=Raft,
Name=testAllTopicPartition, Security=PLAINTEXT`, one failure in related
`NamedTopologyIntegrationT
ableegoldman merged pull request #11591:
URL: https://github.com/apache/kafka/pull/11591
--
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
vvcephei commented on a change in pull request #11581:
URL: https://github.com/apache/kafka/pull/11581#discussion_r767028987
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/StoreQueryUtils.java
##
@@ -62,4 +71,28 @@ public static void updatePositio
vvcephei commented on a change in pull request #11581:
URL: https://github.com/apache/kafka/pull/11581#discussion_r767030936
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/CachingKeyValueStore.java
##
@@ -107,10 +107,10 @@ private void putAndMaybe
vvcephei commented on a change in pull request #11581:
URL: https://github.com/apache/kafka/pull/11581#discussion_r767031044
##
File path:
streams/src/main/java/org/apache/kafka/streams/query/StateQueryResult.java
##
@@ -97,11 +97,15 @@ public void addResult(final int partitio
guozhangwang commented on a change in pull request #11581:
URL: https://github.com/apache/kafka/pull/11581#discussion_r767034399
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/CachingKeyValueStore.java
##
@@ -107,10 +107,10 @@ private void putAndM
cmccabe commented on pull request #11593:
URL: https://github.com/apache/kafka/pull/11593#issuecomment-991360698
> What should be the broker behavior if cannot register because of an
invalid cluster id? Looking at the current code it looks like the broker will
continue to retry. Inconsiste
cmccabe commented on pull request #11544:
URL: https://github.com/apache/kafka/pull/11544#issuecomment-991372206
merged
--
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
cmccabe closed pull request #11544:
URL: https://github.com/apache/kafka/pull/11544
--
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-13500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17457487#comment-17457487
]
Matthias J. Sax commented on KAFKA-13500:
-
Right... My bad.
> Consider adding a
vvcephei commented on pull request #11581:
URL: https://github.com/apache/kafka/pull/11581#issuecomment-991497134
The test failures are unrelated:
```
Build / JDK 11 and Scala 2.13 /
kafka.security.authorizer.AclAuthorizerWithZkSaslTest.testAclUpdateWithSessionExpiration()
| 16 s
vvcephei merged pull request #11581:
URL: https://github.com/apache/kafka/pull/11581
--
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
vvcephei commented on pull request #11581:
URL: https://github.com/apache/kafka/pull/11581#issuecomment-991498463
Thanks for the reviews, all!
--
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
Akansh Shandilya created KAFKA-13535:
Summary: Workaround for mitigating CVE-2021-44228 Kafka
Key: KAFKA-13535
URL: https://issues.apache.org/jira/browse/KAFKA-13535
Project: Kafka
Issue
78 matches
Mail list logo
