kaushik srinivas created KAFKA-9934:
---
Summary: Information and doc update needed for support of
AclAuthorizer when protocol is PLAINTEXT
Key: KAFKA-9934
URL: https://issues.apache.org/jira/browse/KAFKA-9934
[
https://issues.apache.org/jira/browse/KAFKA-9921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Georgi Petkov updated KAFKA-9921:
-
Summary: Caching is not working properly with WindowStateStore when
retaining duplicates (was: C
kaushik srinivas created KAFKA-9933:
---
Summary: Need doc update on the AclAuthorizer when SASL_SSL is the
protocol used.
Key: KAFKA-9933
URL: https://issues.apache.org/jira/browse/KAFKA-9933
Project:
C0urante commented on a change in pull request #8554:
URL: https://github.com/apache/kafka/pull/8554#discussion_r417070806
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/util/KafkaBasedLog.java
##
@@ -281,9 +281,18 @@ private void readToLogEnd() {
C0urante commented on pull request #8554:
URL: https://github.com/apache/kafka/pull/8554#issuecomment-620992508
Thanks @kkonstantine! These all seem like reasonable suggestions and I've
applied them all. Ready for the next round when you have time.
ijuma opened a new pull request #8582:
URL: https://github.com/apache/kafka/pull/8582
If a broker contains 8k replicas, we would previously issue 8k ZK calls to
retrieve topic
configs when processing the first LeaderAndIsr request. That should
translate to 0 after
these changes.
Ismael Juma created KAFKA-9932:
--
Summary: First LeaderAndIsrRequest can take long due to
unnecessary ZK read
Key: KAFKA-9932
URL: https://issues.apache.org/jira/browse/KAFKA-9932
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-9932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismael Juma updated KAFKA-9932:
---
Fix Version/s: 2.6.0
> First LeaderAndIsrRequest can take long due to unnecessary ZK read
> -
kkonstantine commented on a change in pull request #8554:
URL: https://github.com/apache/kafka/pull/8554#discussion_r417055199
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/util/KafkaBasedLog.java
##
@@ -281,9 +281,18 @@ private void readToLogEnd() {
vvcephei commented on pull request #8540:
URL: https://github.com/apache/kafka/pull/8540#issuecomment-620976620
Cherry-picked to 2.5 as 9e2785fd1ba0ed16604e01058bae6b60ff9f3d96
This is an automated message from the Apache Git
showuon opened a new pull request #8581:
URL: https://github.com/apache/kafka/pull/8581
1. fix typo: `atleast` -> `at least`
2. add missing `--` to be consistent
3. rephrase a sentence, to make it more clear:
before: `LinkedIn is currently running JDK 1.8 u5 (looking to upgrade
vvcephei commented on pull request #8540:
URL: https://github.com/apache/kafka/pull/8540#issuecomment-620973163
Cherry-pick for 2.5 in progress...
This is an automated message from the Apache Git Service.
To respond to the me
kkonstantine commented on pull request #8204:
URL: https://github.com/apache/kafka/pull/8204#issuecomment-620971604
JDK8 build failed on a relevant test:
https://builds.apache.org/job/kafka-pr-jdk8-scala2.12/2007/testReport/junit/org.apache.kafka.connect.runtime/WorkerTest/testStartAndS
vvcephei commented on pull request #8574:
URL: https://github.com/apache/kafka/pull/8574#issuecomment-620971180
Thanks, @arkins ! Shame is a powerful motivator :)
This is an automated message from the Apache Git Service.
To r
vvcephei commented on pull request #8578:
URL: https://github.com/apache/kafka/pull/8578#issuecomment-620970911
Thanks for the review, @guozhangwang . I've addressed (or responded to) your
comments.
This is an automated mess
vvcephei commented on a change in pull request #8578:
URL: https://github.com/apache/kafka/pull/8578#discussion_r417047054
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/LagFetchIntegrationTest.java
##
@@ -106,7 +108,7 @@ public void before() {
vvcephei commented on a change in pull request #8578:
URL: https://github.com/apache/kafka/pull/8578#discussion_r417046624
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/ResetPartitionTimeIntegrationTest.java
##
@@ -156,7 +157,7 @@ public void
should
ijuma commented on a change in pull request #8579:
URL: https://github.com/apache/kafka/pull/8579#discussion_r417044882
##
File path: core/src/main/scala/kafka/server/AbstractFetcherThread.scala
##
@@ -382,6 +382,11 @@ abstract class AbstractFetcherThread(name: String,
vvcephei commented on a change in pull request #8578:
URL: https://github.com/apache/kafka/pull/8578#discussion_r417044713
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/utils/IntegrationTestUtils.java
##
@@ -145,12 +162,12 @@ public static void clean
kkonstantine commented on pull request #8442:
URL: https://github.com/apache/kafka/pull/8442#issuecomment-620964908
retest this please
This is an automated message from the Apache Git Service.
To respond to the message, pleas
kkonstantine commented on pull request #8442:
URL: https://github.com/apache/kafka/pull/8442#issuecomment-620964776
ok to test
This is an automated message from the Apache Git Service.
To respond to the message, please log on
vvcephei commented on a change in pull request #8578:
URL: https://github.com/apache/kafka/pull/8578#discussion_r417040202
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/OptimizedKTableIntegrationTest.java
##
@@ -215,13 +216,13 @@ public void onRestor
vvcephei commented on pull request #8580:
URL: https://github.com/apache/kafka/pull/8580#issuecomment-620962357
Hey @mjsax , do you have time for a quick review?
This bug seems to have been introduced by
https://github.com/apache/kafka/pull/8440/files#r407722022 , which attempts to
vvcephei opened a new pull request #8580:
URL: https://github.com/apache/kafka/pull/8580
Fixes an attempt to commit potentially non-running tasks while recovering
from task corruption.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
[
https://issues.apache.org/jira/browse/KAFKA-9931?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17094975#comment-17094975
]
Randall Hauch edited comment on KAFKA-9931 at 4/29/20, 1:52 AM:
---
[
https://issues.apache.org/jira/browse/KAFKA-9931?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17094975#comment-17094975
]
Randall Hauch edited comment on KAFKA-9931 at 4/29/20, 1:51 AM:
---
[
https://issues.apache.org/jira/browse/KAFKA-9931?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17094975#comment-17094975
]
Randall Hauch commented on KAFKA-9931:
--
We'll need a KIP for this change, but it sho
[
https://issues.apache.org/jira/browse/KAFKA-9931?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Randall Hauch updated KAFKA-9931:
-
Labels: needs-kip (was: )
> Kafka Connect should accept '-1' as a valid replication factor
> ---
Randall Hauch created KAFKA-9931:
Summary: Kafka Connect should accept '-1' as a valid replication
factor
Key: KAFKA-9931
URL: https://issues.apache.org/jira/browse/KAFKA-9931
Project: Kafka
efeg opened a new pull request #8579:
URL: https://github.com/apache/kafka/pull/8579
When does UnknownTopicOrPartitionException typically occur?
* Upon a topic creation, a follower broker of a new partition starts
replica fetcher before the prospective leader broker of the new partition
Adem Efe Gencer created KAFKA-9930:
--
Summary: Prevent ReplicaFetcherThread from throwing
UnknownTopicOrPartitionException upon topic creation and deletion.
Key: KAFKA-9930
URL: https://issues.apache.org/jira/brow
guozhangwang commented on a change in pull request #8578:
URL: https://github.com/apache/kafka/pull/8578#discussion_r417015562
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/OptimizedKTableIntegrationTest.java
##
@@ -215,13 +216,13 @@ public void onRe
gwenshap commented on pull request #8518:
URL: https://github.com/apache/kafka/pull/8518#issuecomment-620932278
No failures, nice :)
Great update @lbradstreet and thanks for contributing.
This is an automated message from
bseenu commented on a change in pull request #7577:
URL: https://github.com/apache/kafka/pull/7577#discussion_r417002126
##
File path:
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorCheckpointTask.java
##
@@ -190,4 +227,103 @@ public void commitRecord(Sourc
ning2008wisc commented on a change in pull request #7577:
URL: https://github.com/apache/kafka/pull/7577#discussion_r416995009
##
File path:
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorCheckpointTask.java
##
@@ -190,4 +227,103 @@ public void commitRecord
zhaohaidao commented on pull request #8550:
URL: https://github.com/apache/kafka/pull/8550#issuecomment-620915590
@abbccdda Hi, pr updated. Could you continue to review it?
This is an automated message from the Apache Git Ser
ableegoldman commented on pull request #8540:
URL: https://github.com/apache/kafka/pull/8540#issuecomment-620909428
One unrelated failure:
`MetricsDuringTopicCreationDeletionTest.testMetricsDuringTopicCreateDelete`
This is a
Jorge Esteban Quilcate Otoya created KAFKA-9929:
---
Summary: Support reverse iterator on WindowStore
Key: KAFKA-9929
URL: https://issues.apache.org/jira/browse/KAFKA-9929
Project: Kafka
vvcephei commented on a change in pull request #8578:
URL: https://github.com/apache/kafka/pull/8578#discussion_r416969713
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/GlobalThreadShutDownOrderTest.java
##
@@ -101,8 +102,8 @@ public void before() th
vvcephei opened a new pull request #8578:
URL: https://github.com/apache/kafka/pull/8578
The ticket is for a flaky test that failed to clean up topics _after_ the
test, which
isn't strictly necessary for test success.
* alter the "clean up after test" method to never throw an exce
steverod commented on pull request #8542:
URL: https://github.com/apache/kafka/pull/8542#issuecomment-620893016
retest this please
This is an automated message from the Apache Git Service.
To respond to the message, pleas
cmccabe commented on a change in pull request #8569:
URL: https://github.com/apache/kafka/pull/8569#discussion_r416961523
##
File path: core/src/main/scala/kafka/metrics/LinuxIoMetricsCollector.scala
##
@@ -0,0 +1,96 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF)
ijuma commented on pull request #8567:
URL: https://github.com/apache/kafka/pull/8567#issuecomment-620887867
2 jobs passed, 1 unrelated flaky test failed:
>
org.apache.kafka.streams.integration.QueryableStateIntegrationTest.shouldAllowConcurrentAccesses
[
https://issues.apache.org/jira/browse/KAFKA-9921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17094900#comment-17094900
]
Georgi Petkov edited comment on KAFKA-9921 at 4/28/20, 10:23 PM:
--
[
https://issues.apache.org/jira/browse/KAFKA-9928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17094902#comment-17094902
]
Guozhang Wang commented on KAFKA-9928:
--
I found that for the failed run, around the
[
https://issues.apache.org/jira/browse/KAFKA-9921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17094900#comment-17094900
]
Georgi Petkov commented on KAFKA-9921:
--
[~ableegoldman]
Yeah, I agree that probably
cmccabe edited a comment on pull request #8569:
URL: https://github.com/apache/kafka/pull/8569#issuecomment-620884289
> In addition to block-level read/write, would there be a benefit to expose
file system read/write metrics?
It's better to have that discussion on the mailing list.
cmccabe commented on pull request #8569:
URL: https://github.com/apache/kafka/pull/8569#issuecomment-620884289
> In addition to block-level read/write, would there be a benefit to expose
file system read/write metrics?
It's better to have that discussion on the mailing list. This PR is
junrao commented on pull request #8542:
URL: https://github.com/apache/kafka/pull/8542#issuecomment-620880304
@steverod : Does the JDK 8 and Scala 2.12 tests pass for you locally? Not
sure why the jenkins test failed.
This i
guozhangwang commented on pull request #8568:
URL: https://github.com/apache/kafka/pull/8568#issuecomment-620879654
Merged to trunk.
This is an automated message from the Apache Git Service.
To respond to the message, please
junrao commented on pull request #8543:
URL: https://github.com/apache/kafka/pull/8543#issuecomment-620879490
retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please log
vvcephei commented on a change in pull request #8568:
URL: https://github.com/apache/kafka/pull/8568#discussion_r416947800
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/utils/IntegrationTestUtils.java
##
@@ -269,24 +271,20 @@ public static void clean
guozhangwang commented on a change in pull request #8568:
URL: https://github.com/apache/kafka/pull/8568#discussion_r416944392
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/utils/IntegrationTestUtils.java
##
@@ -269,24 +271,20 @@ public static void c
guozhangwang commented on a change in pull request #8568:
URL: https://github.com/apache/kafka/pull/8568#discussion_r416943907
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/StoreUpgradeIntegrationTest.java
##
@@ -337,8 +336,11 @@ public void
shouldP
guozhangwang commented on a change in pull request #8568:
URL: https://github.com/apache/kafka/pull/8568#discussion_r416942992
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/EosIntegrationTest.java
##
@@ -810,21 +808,9 @@ private void writeInputData(f
fantayeneh opened a new pull request #8577:
URL: https://github.com/apache/kafka/pull/8577
using the min, max might make the code a little easier to read.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage a
[
https://issues.apache.org/jira/browse/KAFKA-9875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler reassigned KAFKA-9875:
---
Assignee: John Roesler
> Flaky Test
> SuppressionDurabilityIntegrationTest.shouldRecoverBuf
vvcephei commented on a change in pull request #8568:
URL: https://github.com/apache/kafka/pull/8568#discussion_r416921971
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/EosIntegrationTest.java
##
@@ -810,21 +808,9 @@ private void writeInputData(final
[
https://issues.apache.org/jira/browse/KAFKA-9928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-9928:
--
Assignee: Matthias J. Sax
> Flaky
> GlobalKTableEOSIntegrationTest#shouldKStreamGloba
[
https://issues.apache.org/jira/browse/KAFKA-9928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-9928:
---
Component/s: unit tests
streams
> Flaky
> GlobalKTableEOSIntegrationTest#sh
fantayeneh opened a new pull request #8576:
URL: https://github.com/apache/kafka/pull/8576
small change fix string formatting
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Ve
vvcephei commented on a change in pull request #8541:
URL: https://github.com/apache/kafka/pull/8541#discussion_r416916295
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/HighAvailabilityTaskAssignorTest.java
##
@@ -41,132 +54,107 @@
guozhangwang commented on pull request #8568:
URL: https://github.com/apache/kafka/pull/8568#issuecomment-620847306
I looked at the three failed tests:
* `OptimizedKTableIntegrationTest.shouldApplyUpdatesToStandbyStore` is
actually due to the issue that https://github.com/apache/kafk
vvcephei commented on pull request #8254:
URL: https://github.com/apache/kafka/pull/8254#issuecomment-620847005
Whew! System tests passed:
http://confluent-kafka-branch-builder-system-test-results.s3-us-west-2.amazonaws.com/2020-04-28--001.1588064884--ConcurrencyPractitioner--EMIT-ON-CHANGE
vvcephei commented on pull request #8540:
URL: https://github.com/apache/kafka/pull/8540#issuecomment-620846462
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and u
vvcephei commented on pull request #8540:
URL: https://github.com/apache/kafka/pull/8540#issuecomment-620846265
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and u
guozhangwang commented on a change in pull request #8568:
URL: https://github.com/apache/kafka/pull/8568#discussion_r416910725
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/GlobalKTableEOSIntegrationTest.java
##
@@ -158,8 +158,9 @@ public void should
Guozhang Wang created KAFKA-9928:
Summary: Flaky
GlobalKTableEOSIntegrationTest#shouldKStreamGlobalKTableLeftJoin[exactly_once_beta]
Key: KAFKA-9928
URL: https://issues.apache.org/jira/browse/KAFKA-9928
[
https://issues.apache.org/jira/browse/KAFKA-9921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman updated KAFKA-9921:
---
Fix Version/s: 2.5.1
> Caching is not working properly with WindowStateStore when rat
gwenshap commented on pull request #8518:
URL: https://github.com/apache/kafka/pull/8518#issuecomment-620826970
ok to test
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
[
https://issues.apache.org/jira/browse/KAFKA-9921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17094844#comment-17094844
]
Sophie Blee-Goldman commented on KAFKA-9921:
I'm resolving the ticket because
[
https://issues.apache.org/jira/browse/KAFKA-9921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17094839#comment-17094839
]
Sophie Blee-Goldman commented on KAFKA-9921:
I take it you're using rocksdb,
[
https://issues.apache.org/jira/browse/KAFKA-9921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17094835#comment-17094835
]
Sophie Blee-Goldman commented on KAFKA-9921:
> For 2 puts I would expect 2 en
abbccdda commented on a change in pull request #8518:
URL: https://github.com/apache/kafka/pull/8518#discussion_r416879514
##
File path: tests/kafkatest/tests/core/downgrade_test.py
##
@@ -67,11 +67,18 @@ def setup_services(self, kafka_version, compression_types,
security_prot
kkonstantine commented on a change in pull request #8204:
URL: https://github.com/apache/kafka/pull/8204#discussion_r416866064
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Worker.java
##
@@ -220,6 +220,8 @@ public void stop() {
worker
kkonstantine commented on pull request #8204:
URL: https://github.com/apache/kafka/pull/8204#issuecomment-620803829
ok to test
This is an automated message from the Apache Git Service.
To respond to the message, please log on
[
https://issues.apache.org/jira/browse/KAFKA-9925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17094805#comment-17094805
]
Guozhang Wang commented on KAFKA-9925:
--
Ah yes!! Hope we can get KIP-591 by 2.6 :)
[
https://issues.apache.org/jira/browse/KAFKA-7317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17094800#comment-17094800
]
Matthias J. Sax commented on KAFKA-7317:
Sweet!
> Use collections subscription f
[
https://issues.apache.org/jira/browse/KAFKA-9127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17094801#comment-17094801
]
Sophie Blee-Goldman commented on KAFKA-9127:
Yep, if you can kick off tests o
[
https://issues.apache.org/jira/browse/KAFKA-9925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17094799#comment-17094799
]
Matthias J. Sax commented on KAFKA-9925:
{quote}I'm wondering if now is a good ti
kkonstantine commented on pull request #8204:
URL: https://github.com/apache/kafka/pull/8204#issuecomment-620795402
retest this please
This is an automated message from the Apache Git Service.
To respond to the message, pleas
[
https://issues.apache.org/jira/browse/KAFKA-7317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17094797#comment-17094797
]
Sophie Blee-Goldman commented on KAFKA-7317:
Also fixed via [https://github.c
[
https://issues.apache.org/jira/browse/KAFKA-9127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17094791#comment-17094791
]
Matthias J. Sax commented on KAFKA-9127:
{quote}Does it qualify as a regression w
[
https://issues.apache.org/jira/browse/KAFKA-9127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17092826#comment-17092826
]
Matthias J. Sax edited comment on KAFKA-9127 at 4/28/20, 6:54 PM:
-
[
https://issues.apache.org/jira/browse/KAFKA-7317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17094781#comment-17094781
]
Matthias J. Sax commented on KAFKA-7317:
As reported on SO, when setting number o
[
https://issues.apache.org/jira/browse/KAFKA-9916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17094777#comment-17094777
]
Matthias J. Sax commented on KAFKA-9916:
The original example was slightly differ
guozhangwang commented on pull request #8574:
URL: https://github.com/apache/kafka/pull/8574#issuecomment-620787049
cc @abbccdda @mjsax to take a look?
This is an automated message from the Apache Git Service.
To respond to t
[
https://issues.apache.org/jira/browse/KAFKA-9925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17094772#comment-17094772
]
Guozhang Wang commented on KAFKA-9925:
--
[~vvcephei] Thanks for getting a look into t
guozhangwang commented on pull request #8564:
URL: https://github.com/apache/kafka/pull/8564#issuecomment-620783397
Also cherry-picked to 2.5.
This is an automated message from the Apache Git Service.
To respond to the messag
ableegoldman commented on a change in pull request #8568:
URL: https://github.com/apache/kafka/pull/8568#discussion_r416814163
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/GlobalKTableEOSIntegrationTest.java
##
@@ -158,8 +158,9 @@ public void should
[
https://issues.apache.org/jira/browse/KAFKA-9925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17094729#comment-17094729
]
John Roesler commented on KAFKA-9925:
-
Ok, I've opened [https://github.com/apache/kaf
ableegoldman commented on a change in pull request #8541:
URL: https://github.com/apache/kafka/pull/8541#discussion_r416810713
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/HighAvailabilityTaskAssignorTest.java
##
@@ -41,132 +54,10
ableegoldman commented on a change in pull request #8568:
URL: https://github.com/apache/kafka/pull/8568#discussion_r416809469
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/OptimizedKTableIntegrationTest.java
##
@@ -163,8 +159,10 @@ public void shoul
[
https://issues.apache.org/jira/browse/KAFKA-9923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman updated KAFKA-9923:
---
Fix Version/s: 2.6.0
> Join window store duplicates can be compacted in changelog
>
[
https://issues.apache.org/jira/browse/KAFKA-9923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman updated KAFKA-9923:
---
Priority: Blocker (was: Critical)
> Join window store duplicates can be compacted in
hachikuji commented on pull request #8562:
URL: https://github.com/apache/kafka/pull/8562#issuecomment-620749977
retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please l
hachikuji commented on pull request #8562:
URL: https://github.com/apache/kafka/pull/8562#issuecomment-620749686
ok to test
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
hachikuji commented on pull request #8562:
URL: https://github.com/apache/kafka/pull/8562#issuecomment-620749823
retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please l
pan3793 commented on pull request #7112:
URL: https://github.com/apache/kafka/pull/7112#issuecomment-620746182
I do a new implement at https://github.com/apache/kafka/pull/8575 follow the
[KIP-581](https://cwiki.apache.org/confluence/display/KAFKA/KIP-581:+Value+of+optional+null+field+which
pan3793 opened a new pull request #8575:
URL: https://github.com/apache/kafka/pull/8575
https://issues.apache.org/jira/browse/KAFKA-8713
https://cwiki.apache.org/confluence/display/KAFKA/KIP-581:+Value+of+optional+null+field+which+has+default+value
### Committer Checklist (exc
1 - 100 of 136 matches
Mail list logo
