[
https://issues.apache.org/jira/browse/KAFKA-10800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17331149#comment-17331149
]
Haoran Xuan commented on KAFKA-10800:
-
[~jagsancio] Thanks for the clarification, now I'm clear
ableegoldman commented on a change in pull request #10573:
URL: https://github.com/apache/kafka/pull/10573#discussion_r619559055
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/RecordCollectorTest.java
##
@@ -126,10 +129,10 @@ public void
ableegoldman commented on a change in pull request #10573:
URL: https://github.com/apache/kafka/pull/10573#discussion_r619558964
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/RecordCollectorTest.java
##
@@ -111,6 +113,7 @@
private
ableegoldman commented on a change in pull request #10573:
URL: https://github.com/apache/kafka/pull/10573#discussion_r619558819
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/ActiveTaskCreator.java
##
@@ -115,7 +115,7 @@ public void
ableegoldman commented on a change in pull request #10573:
URL: https://github.com/apache/kafka/pull/10573#discussion_r619558551
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java
##
@@ -603,7 +606,7 @@ boolean runLoop() {
ableegoldman commented on a change in pull request #10573:
URL: https://github.com/apache/kafka/pull/10573#discussion_r619557786
##
File path: streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java
##
@@ -291,23 +293,35 @@
*
* Enabling exactly-once
ableegoldman commented on a change in pull request #10573:
URL: https://github.com/apache/kafka/pull/10573#discussion_r619557404
##
File path: docs/streams/upgrade-guide.html
##
@@ -93,6 +95,12 @@ Upgrade Guide and API Changes
Streams API changes in 3.0.0
+
+
ableegoldman commented on a change in pull request #10573:
URL: https://github.com/apache/kafka/pull/10573#discussion_r619557012
##
File path: docs/streams/upgrade-guide.html
##
@@ -93,6 +95,12 @@ Upgrade Guide and API Changes
Streams API changes in 3.0.0
+
+
ableegoldman commented on a change in pull request #10573:
URL: https://github.com/apache/kafka/pull/10573#discussion_r619556206
##
File path: docs/streams/upgrade-guide.html
##
@@ -93,6 +95,12 @@ Upgrade Guide and API Changes
Streams API changes in 3.0.0
+
+
ableegoldman commented on a change in pull request #10573:
URL: https://github.com/apache/kafka/pull/10573#discussion_r619555279
##
File path: docs/streams/upgrade-guide.html
##
@@ -93,6 +95,12 @@ Upgrade Guide and API Changes
Streams API changes in 3.0.0
+
+
ableegoldman commented on a change in pull request #10573:
URL: https://github.com/apache/kafka/pull/10573#discussion_r619554270
##
File path: docs/streams/upgrade-guide.html
##
@@ -53,17 +53,19 @@ Upgrade Guide and API Changes
-Starting in Kafka Streams
junrao commented on a change in pull request #10271:
URL: https://github.com/apache/kafka/pull/10271#discussion_r619545527
##
File path:
storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/RemoteLogMetadataContext.java
##
@@ -0,0 +1,74 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/KAFKA-12711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17331098#comment-17331098
]
Guozhang Wang commented on KAFKA-12711:
---
On the other hand, I think maybe we do not, at least in
[
https://issues.apache.org/jira/browse/KAFKA-10493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17331097#comment-17331097
]
Guozhang Wang commented on KAFKA-10493:
---
Without KIP-280, it would always be an issue; what I'm
[
https://issues.apache.org/jira/browse/KAFKA-12711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17331095#comment-17331095
]
Guozhang Wang commented on KAFKA-12711:
---
I'm +1 for this feature. Generally speaking, we should
vitojeng commented on pull request #9821:
URL: https://github.com/apache/kafka/pull/9821#issuecomment-825981428
> Merged to trunk, ready for the next PR
Will do, thanks @ableegoldman !
:)
--
This is an automated message from the Apache Git Service.
To respond to the
mjsax commented on a change in pull request #10573:
URL: https://github.com/apache/kafka/pull/10573#discussion_r619504008
##
File path:
clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java
##
@@ -642,7 +647,10 @@ public void beginTransaction() throws
[
https://issues.apache.org/jira/browse/KAFKA-10493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17331042#comment-17331042
]
Matthias J. Sax commented on KAFKA-10493:
-
Not sure if I understand the idea about "restore by
[
https://issues.apache.org/jira/browse/KAFKA-12711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson updated KAFKA-12711:
---
Description:
There should be a native option to set a back off period when replacing a
[
https://issues.apache.org/jira/browse/KAFKA-12711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson updated KAFKA-12711:
---
Summary: Add a back off option to replace thread (was: Add a back off
option to Replace
[
https://issues.apache.org/jira/browse/KAFKA-12711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-12711:
Labels: needs-kip (was: )
> Add a back off option to Replace thread
>
ableegoldman commented on pull request #9821:
URL: https://github.com/apache/kafka/pull/9821#issuecomment-825863470
Merged to trunk, ready for the next PR
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
ableegoldman merged pull request #9821:
URL: https://github.com/apache/kafka/pull/9821
--
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.
For queries about this service,
ableegoldman commented on pull request #9821:
URL: https://github.com/apache/kafka/pull/9821#issuecomment-825862826
Just two unrelated test failures in the build:
`connect.mirror.integration.MirrorConnectorsIntegrationSSLTest.testReplication()`
[
https://issues.apache.org/jira/browse/KAFKA-12710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17330995#comment-17330995
]
A. Sophie Blee-Goldman commented on KAFKA-12710:
Thanks, I'd forgotten about that KIP.
[
https://issues.apache.org/jira/browse/KAFKA-10493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17330987#comment-17330987
]
Guozhang Wang commented on KAFKA-10493:
---
While thinking about
[
https://issues.apache.org/jira/browse/KAFKA-12693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-12693:
--
Labels: streams (was: )
> Consecutive rebalances with zombie instances may cause corrupted
[
https://issues.apache.org/jira/browse/KAFKA-12710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17330979#comment-17330979
]
Guozhang Wang commented on KAFKA-12710:
---
Thanks [~ableegoldman], this seems relevant to
guozhangwang commented on a change in pull request #10587:
URL: https://github.com/apache/kafka/pull/10587#discussion_r619416799
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBGenericOptionsToDbOptionsColumnFamilyOptionsAdapter.java
##
@@
[
https://issues.apache.org/jira/browse/KAFKA-12712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismael Juma updated KAFKA-12712:
Fix Version/s: 3.0.0
> KRaft: Missing controller.quorom.voters config not properly handled
>
[
https://issues.apache.org/jira/browse/KAFKA-10619?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17329915#comment-17329915
]
Soumyajit Sahu edited comment on KAFKA-10619 at 4/23/21, 5:47 PM:
--
Hi
[
https://issues.apache.org/jira/browse/KAFKA-10619?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17329915#comment-17329915
]
Soumyajit Sahu edited comment on KAFKA-10619 at 4/23/21, 5:45 PM:
--
Hi
[
https://issues.apache.org/jira/browse/KAFKA-12698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17330927#comment-17330927
]
Andrew May edited comment on KAFKA-12698 at 4/23/21, 5:14 PM:
--
That
[
https://issues.apache.org/jira/browse/KAFKA-12698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17330927#comment-17330927
]
Andrew May commented on KAFKA-12698:
That vulnerability is a glibc one, so I'm not sure why it's
guozhangwang merged pull request #9640:
URL: https://github.com/apache/kafka/pull/9640
--
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.
For queries about this service,
guozhangwang commented on pull request #9640:
URL: https://github.com/apache/kafka/pull/9640#issuecomment-825795078
LGTM! And merged to trunk. Thanks @highluck
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
Magnus Edenhill created KAFKA-12712:
---
Summary: KRaft: Missing controller.quorom.voters config not
properly handled
Key: KAFKA-12712
URL: https://issues.apache.org/jira/browse/KAFKA-12712
Project:
[
https://issues.apache.org/jira/browse/KAFKA-12691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson closed KAFKA-12691.
--
> TaskMetadata timeSinceIdlingStarted not reporting correctly
>
[
https://issues.apache.org/jira/browse/KAFKA-12711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson updated KAFKA-12711:
---
Description:
There should be a native option to set a back off period when replacing a
Walker Carlson created KAFKA-12711:
--
Summary: Add a back off option to Replace thread
Key: KAFKA-12711
URL: https://issues.apache.org/jira/browse/KAFKA-12711
Project: Kafka
Issue Type:
bruto1 opened a new pull request #10590:
URL: https://github.com/apache/kafka/pull/10590
Allows to use pooled byte buffer implementations to serialize record value
before calling KafkaProducer.send and reclaim the buffer afterwards, thus
reducing unnecessary allocations and GC pressure
vamossagar12 commented on pull request #10542:
URL: https://github.com/apache/kafka/pull/10542#issuecomment-825558068
Thanks @ableegoldman , actually i think i had updated the ticket as well
that we need to include serialisers as well. i have updated the KIP. and sent
it again for
[
https://issues.apache.org/jira/browse/KAFKA-10493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17330116#comment-17330116
]
Matthias J. Sax commented on KAFKA-10493:
-
{quote}What is worse not dropping out-of-order
showuon commented on pull request #9627:
URL: https://github.com/apache/kafka/pull/9627#issuecomment-825451248
@chia7712 , please take a look. Thank you!
--
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
showuon edited a comment on pull request #9627:
URL: https://github.com/apache/kafka/pull/9627#issuecomment-825382213
Failed test cases are unrelated and flaky (all passed in my local env).
Thanks.
`tests/Build/JDK 11 and Scala 2.13` --> all tests passed
```
Build / JDK 15 and
[
https://issues.apache.org/jira/browse/KAFKA-12698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17330046#comment-17330046
]
priya Vijay commented on KAFKA-12698:
-
can someone please provide some insight in to this, Is Kafka
[
https://issues.apache.org/jira/browse/KAFKA-12698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
priya Vijay updated KAFKA-12698:
Summary: CVE-2019-25013 high priority vulnerability reported in Kafka
(was: CVE-2019-25013
highluck commented on pull request #9640:
URL: https://github.com/apache/kafka/pull/9640#issuecomment-825427682
@guozhangwang
Yes, I checked, but the logic was not changed except for
assignActiveToConsumer, so the test is consistent.
There seems to be no problem locally!
--
This
48 matches
Mail list logo
