Matthias J. Sax created KAFKA-13296:
---
Summary: Verify old assignment within StreamsPartitionAssignor
Key: KAFKA-13296
URL: https://issues.apache.org/jira/browse/KAFKA-13296
Project: Kafka
I
dongjinleekr commented on pull request #10678:
URL: https://github.com/apache/kafka/pull/10678#issuecomment-918854190
Rebased onto the latest trunk. cc/ @cadonna
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
dongjinleekr opened a new pull request #11324:
URL: https://github.com/apache/kafka/pull/11324
`netty-codec` `4.1.62.Final` has the following security vulnerabilities,
which in turn effects `netty-transport-native-epoll` Apache Kafka depends on.
-
[CVE-2021-37136](https://github.com
[
https://issues.apache.org/jira/browse/KAFKA-13292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
NEERAJ VAIDYA reopened KAFKA-13292:
---
As indicated in my previous comments.
> InvalidPidMappingException: The producer attempted to u
[
https://issues.apache.org/jira/browse/KAFKA-13292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17414732#comment-17414732
]
NEERAJ VAIDYA edited comment on KAFKA-13292 at 9/14/21, 5:49 AM:
-
[
https://issues.apache.org/jira/browse/KAFKA-13292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17414732#comment-17414732
]
NEERAJ VAIDYA commented on KAFKA-13292:
---
Thanks [~mjsax] for the reference to the
ableegoldman commented on pull request #11283:
URL: https://github.com/apache/kafka/pull/11283#issuecomment-918706779
@guozhangwang can you cherrypick this back to 2.8 at least? Maybe also 2.7
if there aren't any conflicts (seems like it should be a smooth merge but 🤷‍♀️ )
--
This is an
[
https://issues.apache.org/jira/browse/KAFKA-13295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17414652#comment-17414652
]
A. Sophie Blee-Goldman commented on KAFKA-13295:
Note that https://issue
A. Sophie Blee-Goldman created KAFKA-13295:
--
Summary: Long restoration times for new tasks can lead to
transaction timeouts
Key: KAFKA-13295
URL: https://issues.apache.org/jira/browse/KAFKA-13295
mjsax commented on a change in pull request #11252:
URL: https://github.com/apache/kafka/pull/11252#discussion_r707817999
##
File path:
streams/src/test/java/org/apache/kafka/streams/state/internals/ListValueStoreTest.java
##
@@ -0,0 +1,174 @@
+/*
+ * Licensed to the Apache So
mjsax commented on a change in pull request #11252:
URL: https://github.com/apache/kafka/pull/11252#discussion_r707817999
##
File path:
streams/src/test/java/org/apache/kafka/streams/state/internals/ListValueStoreTest.java
##
@@ -0,0 +1,174 @@
+/*
+ * Licensed to the Apache So
guozhangwang commented on a change in pull request #11252:
URL: https://github.com/apache/kafka/pull/11252#discussion_r707812546
##
File path:
streams/src/test/java/org/apache/kafka/streams/state/internals/ListValueStoreTest.java
##
@@ -0,0 +1,174 @@
+/*
+ * Licensed to the Ap
guozhangwang commented on a change in pull request #11252:
URL: https://github.com/apache/kafka/pull/11252#discussion_r707810706
##
File path:
streams/src/test/java/org/apache/kafka/streams/state/internals/TimestampedTimestampedKeyAndJoinSideSerializerTest.java
##
@@ -24,49 +2
hachikuji commented on pull request #11080:
URL: https://github.com/apache/kafka/pull/11080#issuecomment-918658119
@ccding I kicked off a new build since it has been a while since the PR was
submitted. Assuming tests are ok, I will merge shortly. Thanks for your
patience.
--
This is an
ijuma commented on a change in pull request #11080:
URL: https://github.com/apache/kafka/pull/11080#discussion_r707781491
##
File path:
clients/src/main/java/org/apache/kafka/common/record/DefaultRecord.java
##
@@ -293,7 +293,9 @@ public static DefaultRecord readFrom(ByteBuffe
jolshan commented on a change in pull request #11170:
URL: https://github.com/apache/kafka/pull/11170#discussion_r707742261
##
File path: core/src/main/scala/kafka/server/ReplicaManager.scala
##
@@ -1755,6 +1765,78 @@ class ReplicaManager(val config: KafkaConfig,
partition
hachikuji commented on a change in pull request #11080:
URL: https://github.com/apache/kafka/pull/11080#discussion_r707728626
##
File path:
clients/src/main/java/org/apache/kafka/common/record/DefaultRecord.java
##
@@ -293,7 +293,9 @@ public static DefaultRecord readFrom(ByteB
hachikuji commented on a change in pull request #11080:
URL: https://github.com/apache/kafka/pull/11080#discussion_r707728626
##
File path:
clients/src/main/java/org/apache/kafka/common/record/DefaultRecord.java
##
@@ -293,7 +293,9 @@ public static DefaultRecord readFrom(ByteB
hachikuji commented on a change in pull request #11080:
URL: https://github.com/apache/kafka/pull/11080#discussion_r707728626
##
File path:
clients/src/main/java/org/apache/kafka/common/record/DefaultRecord.java
##
@@ -293,7 +293,9 @@ public static DefaultRecord readFrom(ByteB
jolshan commented on a change in pull request #11170:
URL: https://github.com/apache/kafka/pull/11170#discussion_r707726453
##
File path: core/src/main/scala/kafka/server/ReplicaManager.scala
##
@@ -1755,6 +1765,78 @@ class ReplicaManager(val config: KafkaConfig,
partition
guozhangwang commented on pull request #11292:
URL: https://github.com/apache/kafka/pull/11292#issuecomment-918599583
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 specifi
guozhangwang merged pull request #11292:
URL: https://github.com/apache/kafka/pull/11292
--
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
guozhangwang commented on pull request #11292:
URL: https://github.com/apache/kafka/pull/11292#issuecomment-918598714
> Hope that's clear.
> I also updated in the PR description.
> Thank you.
Thanks!
--
This is an automated message from the Apache Git Service.
To respond to t
guozhangwang commented on pull request #11283:
URL: https://github.com/apache/kafka/pull/11283#issuecomment-918584383
cc @kkonstantine , this is a critical bug fix hence I'm cherry-picking to
3.0 as well. If RC2 is voted through then it will fall on 3.0.1, otherwise if
we vote for another
guozhangwang merged pull request #11283:
URL: https://github.com/apache/kafka/pull/11283
--
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
guozhangwang commented on pull request #11283:
URL: https://github.com/apache/kafka/pull/11283#issuecomment-918582404
I checked the failures of the new run and they are not related to the new
tests. Merging to trunk now.
--
This is an automated message from the Apache Git Service.
To res
mumrah commented on a change in pull request #11186:
URL: https://github.com/apache/kafka/pull/11186#discussion_r707674451
##
File path:
core/src/main/scala/kafka/server/metadata/BrokerMetadataPublisher.scala
##
@@ -117,6 +117,8 @@ class BrokerMetadataPublisher(conf: KafkaConf
hachikuji commented on a change in pull request #11186:
URL: https://github.com/apache/kafka/pull/11186#discussion_r707673948
##
File path:
core/src/main/scala/kafka/server/metadata/BrokerMetadataPublisher.scala
##
@@ -117,6 +117,8 @@ class BrokerMetadataPublisher(conf: KafkaC
mumrah commented on a change in pull request #11186:
URL: https://github.com/apache/kafka/pull/11186#discussion_r707654639
##
File path:
core/src/main/scala/kafka/server/metadata/BrokerMetadataPublisher.scala
##
@@ -117,6 +117,8 @@ class BrokerMetadataPublisher(conf: KafkaConf
hutchiko commented on pull request #11283:
URL: https://github.com/apache/kafka/pull/11283#issuecomment-918537415
@guozhangwang @ableegoldman unfortunately I could never reproduce the CI
failures however I have pushed up a refactor of the method which I think was
responsible for the flakin
C0urante commented on pull request #11323:
URL: https://github.com/apache/kafka/pull/11323#issuecomment-918482406
CC @rhauch; hopefully this is fairly close to what you had in mind.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Gi
C0urante commented on pull request #10112:
URL: https://github.com/apache/kafka/pull/10112#issuecomment-918481881
@rhauch (and, if interested, @hachikuji) new PR is up:
https://github.com/apache/kafka/pull/11323
--
This is an automated message from the Apache Git Service.
To respond to t
C0urante opened a new pull request #11323:
URL: https://github.com/apache/kafka/pull/11323
[Jira](https://issues.apache.org/jira/browse/KAFKA-12226)
Replaces https://github.com/apache/kafka/pull/10112
Replaces the current batch-based logic for offset commits with a dynamic,
no
cmccabe removed a comment on pull request #11320:
URL: https://github.com/apache/kafka/pull/11320#issuecomment-918440709
Updates:
- Use deprecated converter class in order to support Scala 2.12
--
This is an automated message from the Apache Git Service.
To respond to the message, plea
cmccabe commented on pull request #11320:
URL: https://github.com/apache/kafka/pull/11320#issuecomment-918440670
--
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 unsubscr
[
https://issues.apache.org/jira/browse/KAFKA-13292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-13292.
-
Resolution: Invalid
Closing this as "invalid" as it seems to be a question, not a bug re
[
https://issues.apache.org/jira/browse/KAFKA-13292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17414431#comment-17414431
]
Matthias J. Sax commented on KAFKA-13292:
-
[https://cwiki.apache.org/confluence/
cmccabe merged pull request #11312:
URL: https://github.com/apache/kafka/pull/11312
--
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-13293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17414272#comment-17414272
]
Elliot West commented on KAFKA-13293:
-
[~rsivaram] thank you for the clarification.
[
https://issues.apache.org/jira/browse/KAFKA-13293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17414263#comment-17414263
]
Rajini Sivaram commented on KAFKA-13293:
[~teabot] Sorry, I should have said `re
[
https://issues.apache.org/jira/browse/KAFKA-13294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Utkarsh Khare reassigned KAFKA-13294:
-
Assignee: Utkarsh Khare
> Upgrade Netty to 4.1.68 for CVE fixes
> -
[
https://issues.apache.org/jira/browse/KAFKA-13293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17414227#comment-17414227
]
Elliot West edited comment on KAFKA-13293 at 9/13/21, 2:16 PM:
---
[
https://issues.apache.org/jira/browse/KAFKA-13293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17414227#comment-17414227
]
Elliot West edited comment on KAFKA-13293 at 9/13/21, 2:15 PM:
---
[
https://issues.apache.org/jira/browse/KAFKA-13293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17414227#comment-17414227
]
Elliot West commented on KAFKA-13293:
-
[~rsivaram]Â on point 2, would that actually w
[
https://issues.apache.org/jira/browse/KAFKA-13293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17414217#comment-17414217
]
Rajini Sivaram commented on KAFKA-13293:
[~teabot] Yes, agree that it will be us
[
https://issues.apache.org/jira/browse/KAFKA-12751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17414212#comment-17414212
]
Rajini Sivaram commented on KAFKA-12751:
The bug only happens in an unusual case
C0urante closed pull request #10112:
URL: https://github.com/apache/kafka/pull/10112
--
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-13293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17414192#comment-17414192
]
Elliot West edited comment on KAFKA-13293 at 9/13/21, 1:13 PM:
---
[
https://issues.apache.org/jira/browse/KAFKA-13293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17414192#comment-17414192
]
Elliot West edited comment on KAFKA-13293 at 9/13/21, 1:12 PM:
---
[
https://issues.apache.org/jira/browse/KAFKA-13293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17414192#comment-17414192
]
Elliot West commented on KAFKA-13293:
-
Hey [~rsivaram]Â - thank you for your reply. Â
[
https://issues.apache.org/jira/browse/KAFKA-12751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17414181#comment-17414181
]
priya Vijay commented on KAFKA-12751:
-
[~rsivaram]Â We are currently using kafka 2.8Â
[
https://issues.apache.org/jira/browse/KAFKA-13294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Utkarsh Khare updated KAFKA-13294:
--
Summary: Upgrade Netty to 4.1.68 for CVE fixes (was: Upgrade Netty to
4.1.68)
> Upgrade Nett
[
https://issues.apache.org/jira/browse/KAFKA-13294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17414176#comment-17414176
]
Utkarsh Khare commented on KAFKA-13294:
---
I can push a PR for updating netty.Â
> U
Utkarsh Khare created KAFKA-13294:
-
Summary: Upgrade Netty to 4.1.68
Key: KAFKA-13294
URL: https://issues.apache.org/jira/browse/KAFKA-13294
Project: Kafka
Issue Type: Bug
Component
[
https://issues.apache.org/jira/browse/KAFKA-13293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17414137#comment-17414137
]
Rajini Sivaram commented on KAFKA-13293:
[~teabot] Which client (and configs) do
msillence opened a new pull request #11322:
URL: https://github.com/apache/kafka/pull/11322
smt to rename schemas based on regex
example configuration:
```
"transforms.regexSchema.regex": ".*\\.([^.]*)\\.(Value|Key)",
"transforms.regexSchema.replacement": "com.com
[
https://issues.apache.org/jira/browse/KAFKA-9569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Satish Duggana resolved KAFKA-9569.
---
Resolution: Fixed
> RemoteStorageManager implementation for HDFS storage.
> -
Elliot West created KAFKA-13293:
---
Summary: Support client reload of PEM certificates
Key: KAFKA-13293
URL: https://issues.apache.org/jira/browse/KAFKA-13293
Project: Kafka
Issue Type: Improveme
[
https://issues.apache.org/jira/browse/KAFKA-10338?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17414070#comment-17414070
]
Elliot West commented on KAFKA-10338:
-
[~rsivaram], I've created KAFKA-13293 to addr
[
https://issues.apache.org/jira/browse/KAFKA-13287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna resolved KAFKA-13287.
---
Resolution: Fixed
> Upgrade RocksDB to 6.22.1.1
> ---
>
>
cadonna merged pull request #11317:
URL: https://github.com/apache/kafka/pull/11317
--
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.
61 matches
Mail list logo
