tonytony2020 opened a new pull request #8770:
URL: https://github.com/apache/kafka/pull/8770
Fix v2.4.x~v2.5.x console producer script doesn't supports
`--bootstrap-server` option.
We should use `--broker-list` instead.
*More detailed description of your change,
if necessary.
nizhikov commented on a change in pull request #8695:
URL: https://github.com/apache/kafka/pull/8695#discussion_r433091643
##
File path: tests/kafkatest/services/security/security_config.py
##
@@ -259,6 +267,9 @@ def setup_node(self, node):
if self.has_sasl:
nizhikov commented on a change in pull request #8695:
URL: https://github.com/apache/kafka/pull/8695#discussion_r433097896
##
File path: tests/kafkatest/services/kafka/kafka.py
##
@@ -354,15 +358,16 @@ def start_cmd(self, node):
def start_node(self, node, timeout_sec=60)
nizhikov commented on a change in pull request #8695:
URL: https://github.com/apache/kafka/pull/8695#discussion_r433102140
##
File path:
clients/src/test/java/org/apache/kafka/common/network/SslTransportLayerTest.java
##
@@ -580,7 +581,16 @@ public void testTLSDefaults() throw
[
https://issues.apache.org/jira/browse/KAFKA-10067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17120828#comment-17120828
]
Tom Bentley commented on KAFKA-10067:
-
But the same argument applies: "having a publ
[
https://issues.apache.org/jira/browse/KAFKA-9320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nikolay Izhikov updated KAFKA-9320:
---
Attachment: report.txt
> Enable TLSv1.3 by default and disable some of the older protocols
>
[
https://issues.apache.org/jira/browse/KAFKA-9320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17120838#comment-17120838
]
Nikolay Izhikov commented on KAFKA-9320:
I ran the following tests:
* tests/kafk
[
https://issues.apache.org/jira/browse/KAFKA-9320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17120842#comment-17120842
]
Nikolay Izhikov commented on KAFKA-9320:
Log from the failed test:
{noformat}
[2
nizhikov commented on pull request #8695:
URL: https://github.com/apache/kafka/pull/8695#issuecomment-636705289
@ijuma
I ran the following tests:
* tests/kafkatest/tests/tools/log4j_appender_test.py
* tests/kafkatest/tests/core/upgrade_test.py
* tests/kafkatest/tests/core/mi
chia7712 commented on a change in pull request #8769:
URL: https://github.com/apache/kafka/pull/8769#discussion_r433123896
##
File path: core/src/main/scala/kafka/security/authorizer/AclAuthorizer.scala
##
@@ -63,9 +64,14 @@ object AclAuthorizer {
def exists: Boolean = zkV
skaundinya15 commented on pull request #8421:
URL: https://github.com/apache/kafka/pull/8421#issuecomment-636725117
@ijuma @abbccdda Initially the idea was to tackle one client at a time while
making the patches for this KIP. With respect to creating an overarching module
that can be used
[
https://issues.apache.org/jira/browse/KAFKA-10067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17120899#comment-17120899
]
Yanming Zhou commented on KAFKA-10067:
--
I don't think so, all relational database p
[
https://issues.apache.org/jira/browse/KAFKA-10067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17120899#comment-17120899
]
Yanming Zhou edited comment on KAFKA-10067 at 6/1/20, 9:49 AM:
---
[
https://issues.apache.org/jira/browse/KAFKA-560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17120958#comment-17120958
]
Goltseva Taisiia commented on KAFKA-560:
I'm looking for an option on Kafka for au
[
https://issues.apache.org/jira/browse/KAFKA-9320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17120985#comment-17120985
]
Nikolay Izhikov commented on KAFKA-9320:
replication_test after last edits.
{nofo
Dmitry Mischenko created KAFKA-10075:
Summary: Kafka client stucks after Kafka-cluster unavailability
Key: KAFKA-10075
URL: https://issues.apache.org/jira/browse/KAFKA-10075
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-10075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dmitry Mischenko updated KAFKA-10075:
-
Description:
Several times we got an issue with kafka-client.
What happened:
We have K
ijuma commented on pull request #8769:
URL: https://github.com/apache/kafka/pull/8769#issuecomment-636871374
The issue affecting the Scala 2.12 build is unrelated. Looks like Gradle
exited while running Streams tests.
This i
ijuma commented on a change in pull request #8769:
URL: https://github.com/apache/kafka/pull/8769#discussion_r433245510
##
File path: core/src/main/scala/kafka/security/authorizer/AclAuthorizer.scala
##
@@ -63,9 +64,14 @@ object AclAuthorizer {
def exists: Boolean = zkVers
ijuma commented on a change in pull request #8769:
URL: https://github.com/apache/kafka/pull/8769#discussion_r433248217
##
File path: core/src/main/scala/kafka/security/authorizer/AclAuthorizer.scala
##
@@ -63,9 +64,14 @@ object AclAuthorizer {
def exists: Boolean = zkVers
ijuma commented on a change in pull request #8769:
URL: https://github.com/apache/kafka/pull/8769#discussion_r433248217
##
File path: core/src/main/scala/kafka/security/authorizer/AclAuthorizer.scala
##
@@ -63,9 +64,14 @@ object AclAuthorizer {
def exists: Boolean = zkVers
[
https://issues.apache.org/jira/browse/KAFKA-6520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17121035#comment-17121035
]
Vince Mu commented on KAFKA-6520:
-
My approach for this would be to create a new metric,
ijuma merged pull request #8769:
URL: https://github.com/apache/kafka/pull/8769
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
[
https://issues.apache.org/jira/browse/KAFKA-10074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismael Juma resolved KAFKA-10074.
-
Reviewer: Rajini Sivaram
Resolution: Fixed
> Improve performance of `matchingAcls`
> -
ijuma commented on a change in pull request #8695:
URL: https://github.com/apache/kafka/pull/8695#discussion_r433253088
##
File path:
clients/src/test/java/org/apache/kafka/common/network/SslVersionsTransportLayerTest.java
##
@@ -54,21 +54,16 @@
List values = new Arra
astubbs opened a new pull request #8771:
URL: https://github.com/apache/kafka/pull/8771
Improve code to be self documenting, in cases where forwarding of messages
is disabled due to the type of processor being used,
This is
ijuma commented on a change in pull request #8695:
URL: https://github.com/apache/kafka/pull/8695#discussion_r433260716
##
File path:
clients/src/test/java/org/apache/kafka/common/network/SslTransportLayerTest.java
##
@@ -622,6 +632,108 @@ public void testUnsupportedTLSVersion
Ron Dagostino created KAFKA-10076:
-
Summary: Doc prefixed vs. non-prefix configs
Key: KAFKA-10076
URL: https://issues.apache.org/jira/browse/KAFKA-10076
Project: Kafka
Issue Type: Improvement
nizhikov commented on a change in pull request #8695:
URL: https://github.com/apache/kafka/pull/8695#discussion_r433265356
##
File path:
clients/src/test/java/org/apache/kafka/common/network/SslVersionsTransportLayerTest.java
##
@@ -54,21 +54,16 @@
List values = new A
ijuma commented on a change in pull request #8695:
URL: https://github.com/apache/kafka/pull/8695#discussion_r433266555
##
File path:
clients/src/test/java/org/apache/kafka/common/network/SslTransportLayerTest.java
##
@@ -622,6 +632,108 @@ public void testUnsupportedTLSVersion
nizhikov commented on a change in pull request #8695:
URL: https://github.com/apache/kafka/pull/8695#discussion_r433270767
##
File path:
clients/src/test/java/org/apache/kafka/common/network/SslTransportLayerTest.java
##
@@ -622,6 +632,108 @@ public void testUnsupportedTLSVers
nizhikov commented on a change in pull request #8695:
URL: https://github.com/apache/kafka/pull/8695#discussion_r433270767
##
File path:
clients/src/test/java/org/apache/kafka/common/network/SslTransportLayerTest.java
##
@@ -622,6 +632,108 @@ public void testUnsupportedTLSVers
ijuma commented on a change in pull request #8695:
URL: https://github.com/apache/kafka/pull/8695#discussion_r433271076
##
File path:
clients/src/test/java/org/apache/kafka/common/network/SslTransportLayerTest.java
##
@@ -580,7 +581,16 @@ public void testTLSDefaults() throws E
nizhikov commented on a change in pull request #8695:
URL: https://github.com/apache/kafka/pull/8695#discussion_r433272524
##
File path: tests/kafkatest/tests/core/replication_test.py
##
@@ -126,9 +126,11 @@ def min_cluster_size(self):
security_protocol="SASL_SSL",
ijuma commented on a change in pull request #8695:
URL: https://github.com/apache/kafka/pull/8695#discussion_r433274613
##
File path:
clients/src/test/java/org/apache/kafka/common/network/SslTransportLayerTest.java
##
@@ -580,7 +581,16 @@ public void testTLSDefaults() throws E
ijuma commented on a change in pull request #8695:
URL: https://github.com/apache/kafka/pull/8695#discussion_r433279649
##
File path:
clients/src/test/java/org/apache/kafka/common/network/SslTransportLayerTest.java
##
@@ -580,7 +581,16 @@ public void testTLSDefaults() throws E
ijuma commented on a change in pull request #8695:
URL: https://github.com/apache/kafka/pull/8695#discussion_r433279701
##
File path:
clients/src/test/java/org/apache/kafka/common/network/SslTransportLayerTest.java
##
@@ -622,6 +632,108 @@ public void testUnsupportedTLSVersion
ijuma commented on a change in pull request #8695:
URL: https://github.com/apache/kafka/pull/8695#discussion_r433283096
##
File path:
clients/src/test/java/org/apache/kafka/common/network/SslTransportLayerTest.java
##
@@ -622,6 +632,108 @@ public void testUnsupportedTLSVersion
ijuma commented on a change in pull request #8695:
URL: https://github.com/apache/kafka/pull/8695#discussion_r433282708
##
File path:
clients/src/test/java/org/apache/kafka/common/network/SslTransportLayerTest.java
##
@@ -622,6 +632,108 @@ public void testUnsupportedTLSVersion
ijuma commented on a change in pull request #8695:
URL: https://github.com/apache/kafka/pull/8695#discussion_r433283509
##
File path:
clients/src/test/java/org/apache/kafka/common/network/SslVersionsTransportLayerTest.java
##
@@ -54,21 +54,16 @@
List values = new Arra
nizhikov commented on a change in pull request #8695:
URL: https://github.com/apache/kafka/pull/8695#discussion_r433283367
##
File path:
clients/src/test/java/org/apache/kafka/common/network/SslTransportLayerTest.java
##
@@ -622,6 +632,108 @@ public void testUnsupportedTLSVers
vvcephei commented on a change in pull request #8764:
URL: https://github.com/apache/kafka/pull/8764#discussion_r433284161
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/KTableKTableForeignKeyJoinMaterializationIntegrationTest.java
##
@@ -77,11 +83,12
rajinisivaram commented on pull request #7956:
URL: https://github.com/apache/kafka/pull/7956#issuecomment-636928160
@omkreddy Thanks for the review. Moved the comment to AclAuthorizer. Merging
to trunk.
This is an automated
rajinisivaram merged pull request #7956:
URL: https://github.com/apache/kafka/pull/7956
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
vvcephei commented on pull request #7693:
URL: https://github.com/apache/kafka/pull/7693#issuecomment-636933382
I'm seeing some failures on older branches, so I'm cherry-picking back.
Cherry-picked to 2.3. Confirmed the test worked locally:
```
[INFO:2020-06-01 08:43:27,309]: Ru
vvcephei commented on pull request #7693:
URL: https://github.com/apache/kafka/pull/7693#issuecomment-636946808
Cherry picked to 2.2:
```
test_id:
kafkatest.tests.streams.streams_eos_test.StreamsEo
nizhikov commented on a change in pull request #8695:
URL: https://github.com/apache/kafka/pull/8695#discussion_r49180
##
File path:
clients/src/test/java/org/apache/kafka/common/network/SslTransportLayerTest.java
##
@@ -622,6 +632,108 @@ public void testUnsupportedTLSVers
[
https://issues.apache.org/jira/browse/KAFKA-9392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rajini Sivaram resolved KAFKA-9392.
---
Reviewer: Manikumar
Resolution: Fixed
> Document and add test for deleteAcls that match
nizhikov commented on a change in pull request #8695:
URL: https://github.com/apache/kafka/pull/8695#discussion_r433351684
##
File path:
clients/src/test/java/org/apache/kafka/common/network/SslTransportLayerTest.java
##
@@ -622,6 +632,108 @@ public void testUnsupportedTLSVers
[
https://issues.apache.org/jira/browse/KAFKA-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17121149#comment-17121149
]
Boyang Chen commented on KAFKA-9891:
[~mateuszjadczyk] If we commit keyOne, then it *
nizhikov commented on a change in pull request #8695:
URL: https://github.com/apache/kafka/pull/8695#discussion_r433352122
##
File path:
clients/src/test/java/org/apache/kafka/common/network/SslTransportLayerTest.java
##
@@ -580,7 +581,16 @@ public void testTLSDefaults() throw
[
https://issues.apache.org/jira/browse/KAFKA-9717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17121152#comment-17121152
]
Chia-Ping Tsai commented on KAFKA-9717:
---
[~Bataitis] Have you tried the newer kafka
chia7712 commented on a change in pull request #8759:
URL: https://github.com/apache/kafka/pull/8759#discussion_r433364776
##
File path:
streams/test-utils/src/main/java/org/apache/kafka/streams/TopologyTestDriver.java
##
@@ -906,8 +906,8 @@ public void advanceWallClockTime(fi
Andy Coates created KAFKA-10077:
---
Summary: Filter downstream of state-store results in suprious
tombstones
Key: KAFKA-10077
URL: https://issues.apache.org/jira/browse/KAFKA-10077
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-10077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andy Coates updated KAFKA-10077:
Description:
Adding a `filter` call downstream of anything that has a state store, e.g. a
table s
ableegoldman opened a new pull request #8772:
URL: https://github.com/apache/kafka/pull/8772
Followup to https://github.com/apache/kafka/pull/8738, backporting the
javadocs to 2.5
This is an automated message from the Apache
ableegoldman commented on pull request #8738:
URL: https://github.com/apache/kafka/pull/8738#issuecomment-637012071
Fair enough: https://github.com/apache/kafka/pull/8772
This is an automated message from the Apache Git Servi
ableegoldman commented on pull request #8772:
URL: https://github.com/apache/kafka/pull/8772#issuecomment-637012129
@mjsax
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
bdbyrne edited a comment on pull request #8717:
URL: https://github.com/apache/kafka/pull/8717#issuecomment-637016443
> Thanks for the PR @bdbyrne, I'm curious why we don't consider fixing the
`AdminZkClient#validateTopicConfig` thrown exception type, but fix its caller
instead. And in fac
bdbyrne commented on pull request #8717:
URL: https://github.com/apache/kafka/pull/8717#issuecomment-637016443
> Thanks for the PR @bdbyrne, I'm curious why we don't consider fixing the
`AdminZkClient#validateTopicConfig` thrown exception type, but fix its caller
instead. And in fact we ha
[
https://issues.apache.org/jira/browse/KAFKA-9494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17121211#comment-17121211
]
Travis Bischel commented on KAFKA-9494:
---
Thanks!
> Include data type of the config
[
https://issues.apache.org/jira/browse/KAFKA-10010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen resolved KAFKA-10010.
-
Resolution: Fixed
> Should make state store registration idempotent
> --
[
https://issues.apache.org/jira/browse/KAFKA-10011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen resolved KAFKA-10011.
-
Resolution: Fixed
> lockedTaskDirectories should be cleared when task gets closed dirty in
> Ha
twmb commented on pull request #8668:
URL: https://github.com/apache/kafka/pull/8668#issuecomment-637026123
From what I can tell, this looks good to me. This loses one mostly
insignificant "optimization" that does not really affect anything in reality:
prior, if an old-generation member is
[
https://issues.apache.org/jira/browse/KAFKA-6502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17121235#comment-17121235
]
Matthias J. Sax commented on KAFKA-6502:
[~guozhang] I think this issue is fixed
[
https://issues.apache.org/jira/browse/KAFKA-6502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17121235#comment-17121235
]
Matthias J. Sax edited comment on KAFKA-6502 at 6/1/20, 6:30 PM:
--
ijuma commented on a change in pull request #8695:
URL: https://github.com/apache/kafka/pull/8695#discussion_r433413250
##
File path:
clients/src/test/java/org/apache/kafka/common/network/SslTransportLayerTest.java
##
@@ -732,11 +614,8 @@ public void testUnsupportedCiphers() t
vvcephei commented on pull request #7693:
URL: https://github.com/apache/kafka/pull/7693#issuecomment-637046212
Cherry-picked to 2.1:
```
test_id:
kafkatest.tests.streams.streams_eos_test.StreamsEosTest.test_rebalance_complex
status: PASS
run time: 3 minutes 41.565 seco
[
https://issues.apache.org/jira/browse/KAFKA-9821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman updated KAFKA-9821:
---
Component/s: (was: streams)
> Partition may skip assignment with static members a
Sophie Blee-Goldman created KAFKA-10078:
---
Summary: Partition may skip assignment with static members and
incremental rebalances
Key: KAFKA-10078
URL: https://issues.apache.org/jira/browse/KAFKA-10078
[
https://issues.apache.org/jira/browse/KAFKA-9821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman updated KAFKA-9821:
---
Description:
When static membership (KIP-345) and incremental rebalancing (KIP-429) a
[
https://issues.apache.org/jira/browse/KAFKA-10078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman updated KAFKA-10078:
Summary: Stream tasks may skip assignment with static members and
incremental reba
[
https://issues.apache.org/jira/browse/KAFKA-10078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman updated KAFKA-10078:
Fix Version/s: (was: 2.6.0)
> Stream tasks may skip assignment with static mem
[
https://issues.apache.org/jira/browse/KAFKA-9821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman updated KAFKA-9821:
---
Labels: (was: need-kip)
> Stream task may skip assignment with static members and i
[
https://issues.apache.org/jira/browse/KAFKA-9821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman updated KAFKA-9821:
---
Summary: Stream task may skip assignment with static members and
incremental rebalanc
[
https://issues.apache.org/jira/browse/KAFKA-10078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman updated KAFKA-10078:
Component/s: (was: streams)
consumer
> Stream tasks may skip
[
https://issues.apache.org/jira/browse/KAFKA-9821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman reassigned KAFKA-9821:
--
Assignee: Sophie Blee-Goldman
> Stream task may skip assignment with static me
[
https://issues.apache.org/jira/browse/KAFKA-9821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman updated KAFKA-9821:
---
Fix Version/s: 2.6.0
> Stream task may skip assignment with static members and increm
[
https://issues.apache.org/jira/browse/KAFKA-9821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman updated KAFKA-9821:
---
Component/s: (was: consumer)
streams
> Stream task may skip assi
[
https://issues.apache.org/jira/browse/KAFKA-10078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman updated KAFKA-10078:
Summary: Partition may skip assignment with static members and incremental
rebalan
[
https://issues.apache.org/jira/browse/KAFKA-9821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman updated KAFKA-9821:
---
Affects Version/s: 2.4.0
> Stream task may skip assignment with static members and in
[
https://issues.apache.org/jira/browse/KAFKA-9821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman resolved KAFKA-9821.
Resolution: Fixed
> Stream task may skip assignment with static members and increme
[
https://issues.apache.org/jira/browse/KAFKA-10078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman updated KAFKA-10078:
Description:
When static membership (KIP-345) and incremental rebalancing (KIP-429
[
https://issues.apache.org/jira/browse/KAFKA-10078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman reassigned KAFKA-10078:
---
Assignee: (was: Sophie Blee-Goldman)
> Partition may skip assignment wi
[
https://issues.apache.org/jira/browse/KAFKA-9821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman updated KAFKA-9821:
---
Description:
When static membership (KIP-345) and incremental rebalancing (KIP-429) a
[
https://issues.apache.org/jira/browse/KAFKA-6502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17121269#comment-17121269
]
Guozhang Wang commented on KAFKA-6502:
--
I think it is not fixed via KAFKA-6607 since
vvcephei commented on pull request #7693:
URL: https://github.com/apache/kafka/pull/7693#issuecomment-637057829
Cherry-picked to 2.0 (along with #6898)
```
test_id:
kafkatest.tests.streams.streams_eos_test.StreamsEosTest.test_rebalance_complex
status: PASS
run time:
Sophie Blee-Goldman created KAFKA-10079:
---
Summary: Support high availability for in-memory stores
Key: KAFKA-10079
URL: https://issues.apache.org/jira/browse/KAFKA-10079
Project: Kafka
junrao commented on a change in pull request #8680:
URL: https://github.com/apache/kafka/pull/8680#discussion_r432781217
##
File path: core/src/main/scala/kafka/zk/ZkData.scala
##
@@ -22,7 +22,7 @@ import java.util.Properties
import com.fasterxml.jackson.annotation.JsonPrope
guozhangwang commented on pull request #8764:
URL: https://github.com/apache/kafka/pull/8764#issuecomment-637075135
test this please
This is an automated message from the Apache Git Service.
To respond to the message, please
vvcephei commented on pull request #7693:
URL: https://github.com/apache/kafka/pull/7693#issuecomment-637087091
Cherry-picked to 1.1 (along with #6797 and #6898 so that it's possible to
actually run the test in docker)
```
test_id:
kafkatest.tests.streams.streams_eos_test.Stre
[
https://issues.apache.org/jira/browse/KAFKA-10077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andy Coates reassigned KAFKA-10077:
---
Assignee: Andy Coates
> Filter downstream of state-store results in suprious tombstones
> -
vvcephei commented on pull request #7693:
URL: https://github.com/apache/kafka/pull/7693#issuecomment-637093964
Cherry-picked to 1.0 (along with #6797 and #6898)
```
test_id:
kafkatest.tests.streams.streams_eos_test.StreamsEosTest.test_rebalance_complex
status: PASS
run t
[
https://issues.apache.org/jira/browse/KAFKA-10068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-10068:
-
Fix Version/s: 2.6.0
> Verify HighAvailabilityTaskAssignor performance with large clusters and
[
https://issues.apache.org/jira/browse/KAFKA-10068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17121323#comment-17121323
]
John Roesler commented on KAFKA-10068:
--
Thanks, [~ableegoldman] , that is indeed wh
[
https://issues.apache.org/jira/browse/KAFKA-10079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman updated KAFKA-10079:
Summary: Improve thread-level stickiness of stateful tasks (was: Support
high ava
[
https://issues.apache.org/jira/browse/KAFKA-10079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman updated KAFKA-10079:
Description:
Now that KAFKA-9501 is fixed, we should make sure that KIP-441 will w
bellemare commented on a change in pull request #8764:
URL: https://github.com/apache/kafka/pull/8764#discussion_r433486418
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/SinkNode.java
##
@@ -66,10 +66,13 @@ public void init(final InternalProc
vvcephei commented on a change in pull request #8764:
URL: https://github.com/apache/kafka/pull/8764#discussion_r433487031
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionWrapperSerde.java
##
@@ -63,9 +63,9 @@ public Su
bellemare commented on a change in pull request #8764:
URL: https://github.com/apache/kafka/pull/8764#discussion_r433486855
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/KTableKTableForeignKeyJoinMaterializationIntegrationTest.java
##
@@ -94,15 +101,
1 - 100 of 155 matches
Mail list logo
