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
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
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-991497134
The test failures are unrelated:
```
Build / JDK 11 and Scala 2.13 /
kafka.security.authorizer.AclAuthorizerWithZkSaslTest.testAclUpdateWithSessionExpiration()
| 16 s
[
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
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.
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 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
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
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
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_r767028987
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/StoreQueryUtils.java
##
@@ -62,4 +71,28 @@ public static void updatePositio
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
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
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
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.
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
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
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 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 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-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
[
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
[
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-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
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
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() {
[
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
> --
[
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/
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
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 #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 #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,
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
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
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.
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
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
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
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
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
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
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
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
[
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
[
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-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:
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 commented on KAFKA-13388:
---
We should probably bump up the priority of this J
[
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
> -
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
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
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
[
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
[
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-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-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=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=17456990#comment-17456990
]
Matthias J. Sax commented on KAFKA-13530:
-
+1
> Flaky test ReplicaManagerTest
>
[
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
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=17456986#comment-17456986
]
Matthias J. Sax commented on KAFKA-12377:
-
One more on 3.1 branch.
> Flaky Test
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-12933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-12933.
-
Resolution: Fixed
> Flaky test
> ReassignPartitionsIntegrationTest.testReassignmentWith
[
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-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=17456978#comment-17456978
]
Matthias J. Sax commented on KAFKA-13530:
-
And one more.
> Flaky test ReplicaMa
[
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-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-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-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-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-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
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
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
[
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
[
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:
--
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
78 matches
Mail list logo
