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.
[
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
> ---
>
>
[
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
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-9569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Satish Duggana resolved KAFKA-9569.
---
Resolution: Fixed
> RemoteStorageManager implementation for HDFS storage.
> -
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-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
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-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
[
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-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-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-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 edited comment on KAFKA-13293 at 9/13/21, 1:13 PM:
---
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-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
[
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-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=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 edited comment on KAFKA-13293 at 9/13/21, 2:16 PM:
---
[
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=17414263#comment-17414263
]
Rajini Sivaram commented on KAFKA-13293:
[~teabot] Sorry, I should have said `re
[
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.
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-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/
[
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
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
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
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
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 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
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
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
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_r707674451
##
File path:
core/src/main/scala/kafka/server/metadata/BrokerMetadataPublisher.scala
##
@@ -117,6 +117,8 @@ class BrokerMetadataPublisher(conf: KafkaConf
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
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-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 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 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-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
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
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_r707742261
##
File path: core/src/main/scala/kafka/server/ReplicaManager.scala
##
@@ -1755,6 +1765,78 @@ class ReplicaManager(val config: KafkaConfig,
partition
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
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
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
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
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
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
[
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
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-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
[
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:all-tabpanel
]
NEERAJ VAIDYA reopened KAFKA-13292:
---
As indicated in my previous comments.
> InvalidPidMappingException: The producer attempted to u
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
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
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
61 matches
Mail list logo
