satishd commented on a change in pull request #10579:
URL: https://github.com/apache/kafka/pull/10579#discussion_r670947570
##
File path:
storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/TopicBasedRemoteLogMetadataManager.java
##
@@ -0,0 +1,484 @@
+/*
satishd commented on a change in pull request #11058:
URL: https://github.com/apache/kafka/pull/11058#discussion_r670940501
##
File path:
storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/CommittedOffsetsFile.java
##
@@ -0,0 +1,86 @@
+/*
+ * Licensed
satishd commented on pull request #11058:
URL: https://github.com/apache/kafka/pull/11058#issuecomment-881150696
This is built on top of https://github.com/apache/kafka/pull/10579. We can
review and merge once #10579 is merged.
--
This is an automated message from the Apache Git
satishd commented on pull request #11060:
URL: https://github.com/apache/kafka/pull/11060#issuecomment-881150117
@junrao This is a minor refactoring. `SnapshotFile` can be reused by default
RLMM for storing committed offsets for remote log metadata topic.
--
This is an automated
dengziming commented on pull request #9577:
URL: https://github.com/apache/kafka/pull/9577#issuecomment-881129535
ping @mumrah
--
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
dengziming removed a comment on pull request #9577:
URL: https://github.com/apache/kafka/pull/9577#issuecomment-851110147
ping @mumrah @cmccabe , this PR is similar to KIP-497, I wish this can be
finished before KAFKA 3.0.0.
--
This is an automated message from the Apache Git Service.
showuon commented on a change in pull request #11026:
URL: https://github.com/apache/kafka/pull/11026#discussion_r670917051
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/internals/ListConsumerGroupOffsetsHandler.java
##
@@ -82,14 +93,17 @@ public String
showuon commented on a change in pull request #11026:
URL: https://github.com/apache/kafka/pull/11026#discussion_r670917051
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/internals/ListConsumerGroupOffsetsHandler.java
##
@@ -82,14 +93,17 @@ public String
ableegoldman commented on pull request #10921:
URL: https://github.com/apache/kafka/pull/10921#issuecomment-881110915
By the way, I filed a ticket for this. I think it's actually a pretty
serious bug so we should have a JIRA for it. I'm also going to propose it as a
blocker for the 3.0
A. Sophie Blee-Goldman created KAFKA-13096:
--
Summary: QueryableStoreProvider is not updated when threads are
added/removed/replaced rendering IQ impossible
Key: KAFKA-13096
URL:
cmccabe commented on pull request #11067:
URL: https://github.com/apache/kafka/pull/11067#issuecomment-881088751
In the ZK-based broker code in `KafkaServer.scala`, the configs are logged
from here:
```
at
[
https://issues.apache.org/jira/browse/KAFKA-13092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao resolved KAFKA-13092.
-
Fix Version/s: 3.0.0
Resolution: Fixed
merged the PR to 3.0 and trunk.
> Perf regression in
junrao merged pull request #11065:
URL: https://github.com/apache/kafka/pull/11065
--
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:
cmccabe opened a new pull request #11067:
URL: https://github.com/apache/kafka/pull/11067
--
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:
hachikuji merged pull request #10952:
URL: https://github.com/apache/kafka/pull/10952
--
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:
rondagostino commented on pull request #11066:
URL: https://github.com/apache/kafka/pull/11066#issuecomment-881063696
Maybe rename `ReplicaManagerMetricNamesTest` to `ClusterMetricNamesTest` so
that it isn't specific to `ReplicaManager`? We could define it like this:
```
rondagostino commented on pull request #11066:
URL: https://github.com/apache/kafka/pull/11066#issuecomment-881062140
> Can we do the integration test approach, but have it be part of
RaftClusterTest.scala?
I think we would only be testing for the KRaft case if we did that, and I
ijuma commented on pull request #11036:
URL: https://github.com/apache/kafka/pull/11036#issuecomment-881058902
JDK 16 build had a bit of flakiness, but the rest looked good. I kicked off
another build just in case.
--
This is an automated message from the Apache Git Service.
To respond
cmccabe commented on pull request #11066:
URL: https://github.com/apache/kafka/pull/11066#issuecomment-881054973
Can we do the integration test approach, but have it be part of
`RaftClusterTest.scala`? It seems weird to have a new test file just for this
one test.
We could also
ijuma commented on pull request #11059:
URL: https://github.com/apache/kafka/pull/11059#issuecomment-881052050
Cherry-picking to 3.0 as well.
--
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
ijuma merged pull request #11059:
URL: https://github.com/apache/kafka/pull/11059
--
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:
junrao commented on a change in pull request #10579:
URL: https://github.com/apache/kafka/pull/10579#discussion_r670820515
##
File path:
storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/TopicBasedRemoteLogMetadataManagerConfig.java
##
@@ -0,0 +1,197
rondagostino commented on pull request #11066:
URL: https://github.com/apache/kafka/pull/11066#issuecomment-881031042
I've implemented the test in 2 separate ways, and we should choose which one
to keep.
1. A standard unit test, in `ReplicaManagerTest`
2. A parameterized test
rondagostino opened a new pull request #11066:
URL: https://github.com/apache/kafka/pull/11066
This patch closes a test gap where we do not check ReplicaManager metrics
remain as expected. There was a bug in 2.8 where the metrics moved under a
different class name for the KRaft case.
jolshan opened a new pull request #11065:
URL: https://github.com/apache/kafka/pull/11065
cherry-pick of 584213ed20d679b11206b67c5a65035347632f07
Only conflicts were in Log.scala where the new flush code was near some log
refactor changes in trunk. I kept the code the same and only
junrao commented on pull request #11056:
URL: https://github.com/apache/kafka/pull/11056#issuecomment-881012624
@jolshan : The PR doesn't apply cleanly to 3.0. Could you provide a separate
PR for 3.0? Thanks.
--
This is an automated message from the Apache Git Service.
To respond to the
junrao merged pull request #11056:
URL: https://github.com/apache/kafka/pull/11056
--
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:
mjsax commented on a change in pull request #11063:
URL: https://github.com/apache/kafka/pull/11063#discussion_r670792151
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/WindowedChangelogRetentionIntegrationTest.java
##
@@ -0,0 +1,365 @@
+/*
+ *
dajac commented on a change in pull request #11026:
URL: https://github.com/apache/kafka/pull/11026#discussion_r670798256
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/internals/ListConsumerGroupOffsetsHandler.java
##
@@ -110,40 +124,96 @@ public String
cmccabe opened a new pull request #11064:
URL: https://github.com/apache/kafka/pull/11064
--
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:
cadonna commented on pull request #11063:
URL: https://github.com/apache/kafka/pull/11063#issuecomment-880982426
It is expected that the tests fail since #10953 is not merged yet. Once
#10953 is merged and this PR is rebased on trunk the test should not fail
anymore.
--
This is an
cadonna opened a new pull request #11063:
URL: https://github.com/apache/kafka/pull/11063
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including upgrade
jolshan commented on a change in pull request #10952:
URL: https://github.com/apache/kafka/pull/10952#discussion_r670769638
##
File path: clients/src/main/java/org/apache/kafka/clients/Metadata.java
##
@@ -377,6 +397,12 @@ else if (metadata.error() ==
hachikuji commented on a change in pull request #10952:
URL: https://github.com/apache/kafka/pull/10952#discussion_r670748649
##
File path: clients/src/main/java/org/apache/kafka/clients/Metadata.java
##
@@ -377,6 +397,12 @@ else if (metadata.error() ==
dajac commented on a change in pull request #11026:
URL: https://github.com/apache/kafka/pull/11026#discussion_r670737002
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/internals/ListConsumerGroupOffsetsHandler.java
##
@@ -82,14 +93,17 @@ public String
cmccabe merged pull request #10753:
URL: https://github.com/apache/kafka/pull/10753
--
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:
tang7526 commented on pull request #11062:
URL: https://github.com/apache/kafka/pull/11062#issuecomment-880920746
@cadonna Could you help to review this PR? thanks.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
tang7526 opened a new pull request #11062:
URL: https://github.com/apache/kafka/pull/11062
https://issues.apache.org/jira/browse/KAFKA-13094
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build
[
https://issues.apache.org/jira/browse/KAFKA-13094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chun-Hao Tang reassigned KAFKA-13094:
-
Assignee: Chun-Hao Tang
> Session windows do not consider user-specified grace when
vvcephei commented on pull request #9616:
URL: https://github.com/apache/kafka/pull/9616#issuecomment-880914082
Implemented in:
a92b986c855592d630fbabf49d1e9a160ad5b230
4d28391480fd8c547a63af119bba67fceb5d2ede
fdcf8fbf72bee9e672d0790cdbe5539846f7dc8e
vvcephei closed pull request #9616:
URL: https://github.com/apache/kafka/pull/9616
--
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:
[
https://issues.apache.org/jira/browse/KAFKA-13095?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Colin McCabe reassigned KAFKA-13095:
Assignee: David Arthur
> TransactionsTest is failing in kraft mode
>
[
https://issues.apache.org/jira/browse/KAFKA-13095?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismael Juma updated KAFKA-13095:
Fix Version/s: 3.0.0
> TransactionsTest is failing in kraft mode
>
guozhangwang commented on pull request #10941:
URL: https://github.com/apache/kafka/pull/10941#issuecomment-880901349
Merged to trunk; cherry-picked to 3.0.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
guozhangwang merged pull request #10941:
URL: https://github.com/apache/kafka/pull/10941
--
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:
Colin McCabe created KAFKA-13095:
Summary: TransactionsTest is failing in kraft mode
Key: KAFKA-13095
URL: https://issues.apache.org/jira/browse/KAFKA-13095
Project: Kafka
Issue Type: Bug
mjsax commented on a change in pull request #10941:
URL: https://github.com/apache/kafka/pull/10941#discussion_r670688025
##
File path: docs/streams/upgrade-guide.html
##
@@ -117,6 +117,21 @@ Streams API
We removed the default implementation of
cadonna opened a new pull request #11061:
URL: https://github.com/apache/kafka/pull/11061
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including
jolshan commented on a change in pull request #10952:
URL: https://github.com/apache/kafka/pull/10952#discussion_r670658031
##
File path: clients/src/test/java/org/apache/kafka/clients/MetadataTest.java
##
@@ -845,6 +887,7 @@ protected boolean retainTopic(String topic, boolean
cmccabe commented on a change in pull request #10753:
URL: https://github.com/apache/kafka/pull/10753#discussion_r670654509
##
File path:
metadata/src/main/java/org/apache/kafka/controller/PartitionReassignmentRevert.java
##
@@ -0,0 +1,105 @@
+/*
+ * Licensed to the Apache
junrao commented on a change in pull request #10753:
URL: https://github.com/apache/kafka/pull/10753#discussion_r670647614
##
File path:
metadata/src/main/java/org/apache/kafka/controller/PartitionChangeBuilder.java
##
@@ -0,0 +1,243 @@
+/*
+ * Licensed to the Apache Software
jolshan commented on a change in pull request #10952:
URL: https://github.com/apache/kafka/pull/10952#discussion_r670630904
##
File path: clients/src/test/java/org/apache/kafka/clients/MetadataTest.java
##
@@ -371,6 +372,43 @@ public void testUpdateLastEpoch() {
junrao commented on a change in pull request #10753:
URL: https://github.com/apache/kafka/pull/10753#discussion_r670609446
##
File path:
metadata/src/main/java/org/apache/kafka/controller/PartitionReassignmentRevert.java
##
@@ -0,0 +1,105 @@
+/*
+ * Licensed to the Apache
satishd opened a new pull request #11060:
URL: https://github.com/apache/kafka/pull/11060
MAJOR Refactored the existing CheckpointFile in core module and moved to
server common module and introduced it as SnapshotFile.
- Refactored CheckpointFile to server/common module as a Java class
dajac commented on pull request #11035:
URL: https://github.com/apache/kafka/pull/11035#issuecomment-880820784
Merged to trunk and 3.0. cc @kkonstantine
--
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
dajac merged pull request #11035:
URL: https://github.com/apache/kafka/pull/11035
--
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:
jsancio commented on a change in pull request #11054:
URL: https://github.com/apache/kafka/pull/11054#discussion_r670583303
##
File path: raft/src/main/java/org/apache/kafka/raft/ReplicatedLog.java
##
@@ -280,11 +280,19 @@ default long truncateToEndOffset(OffsetAndEpoch
jolshan commented on a change in pull request #10952:
URL: https://github.com/apache/kafka/pull/10952#discussion_r670562472
##
File path: clients/src/test/java/org/apache/kafka/clients/MetadataTest.java
##
@@ -874,18 +921,69 @@ protected boolean retainTopic(String topic,
jolshan commented on a change in pull request #10952:
URL: https://github.com/apache/kafka/pull/10952#discussion_r670560488
##
File path: clients/src/test/java/org/apache/kafka/clients/MetadataTest.java
##
@@ -845,6 +887,7 @@ protected boolean retainTopic(String topic, boolean
jolshan commented on a change in pull request #10952:
URL: https://github.com/apache/kafka/pull/10952#discussion_r670559157
##
File path: clients/src/main/java/org/apache/kafka/clients/Metadata.java
##
@@ -377,6 +397,12 @@ else if (metadata.error() ==
jolshan commented on a change in pull request #10952:
URL: https://github.com/apache/kafka/pull/10952#discussion_r670558097
##
File path: clients/src/main/java/org/apache/kafka/clients/MetadataCache.java
##
@@ -130,13 +150,36 @@ MetadataCache mergeWith(String newClusterId,
ijuma commented on a change in pull request #11036:
URL: https://github.com/apache/kafka/pull/11036#discussion_r670557926
##
File path: core/src/main/scala/kafka/log/LogManager.scala
##
@@ -253,9 +259,10 @@ class LogManager(logDirs: Seq[File],
jolshan commented on a change in pull request #10952:
URL: https://github.com/apache/kafka/pull/10952#discussion_r670557719
##
File path: clients/src/main/java/org/apache/kafka/clients/MetadataCache.java
##
@@ -69,13 +73,20 @@ private MetadataCache(String clusterId,
jolshan commented on a change in pull request #10952:
URL: https://github.com/apache/kafka/pull/10952#discussion_r670557519
##
File path: clients/src/main/java/org/apache/kafka/clients/Metadata.java
##
@@ -377,6 +397,12 @@ else if (metadata.error() ==
ijuma commented on a change in pull request #11036:
URL: https://github.com/apache/kafka/pull/11036#discussion_r670555452
##
File path: core/src/main/scala/kafka/log/LogManager.scala
##
@@ -253,9 +259,10 @@ class LogManager(logDirs: Seq[File],
jolshan commented on a change in pull request #10952:
URL: https://github.com/apache/kafka/pull/10952#discussion_r670553966
##
File path: clients/src/main/java/org/apache/kafka/clients/Metadata.java
##
@@ -316,20 +325,29 @@ private MetadataCache
jolshan commented on a change in pull request #10952:
URL: https://github.com/apache/kafka/pull/10952#discussion_r670554176
##
File path: clients/src/main/java/org/apache/kafka/clients/Metadata.java
##
@@ -216,6 +217,14 @@ public synchronized boolean updateRequested() {
jolshan commented on a change in pull request #10952:
URL: https://github.com/apache/kafka/pull/10952#discussion_r670553369
##
File path: clients/src/main/java/org/apache/kafka/clients/Metadata.java
##
@@ -377,6 +397,12 @@ else if (metadata.error() ==
mumrah commented on a change in pull request #11036:
URL: https://github.com/apache/kafka/pull/11036#discussion_r670506521
##
File path: core/src/main/scala/kafka/log/LogConfig.scala
##
@@ -479,4 +501,31 @@ object LogConfig {
logProps.put(MessageDownConversionEnableProp,
dajac commented on pull request #11035:
URL: https://github.com/apache/kafka/pull/11035#issuecomment-880762486
Failures are not related:
```
Build / JDK 16 and Scala 2.13 / testCloseDuringRebalance() –
kafka.api.ConsumerBounceTest
4s
Build / JDK 16 and Scala 2.13 /
ijuma opened a new pull request #11059:
URL: https://github.com/apache/kafka/pull/11059
Update the readme to note the deprecation. We will also mention the
deprecation
in the downloads page when the release is done.
### Committer Checklist (excluded from commit message)
- [ ]
showuon commented on a change in pull request #11026:
URL: https://github.com/apache/kafka/pull/11026#discussion_r670488214
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/internals/ListConsumerGroupOffsetsHandler.java
##
@@ -110,40 +124,96 @@ public String
showuon commented on a change in pull request #11026:
URL: https://github.com/apache/kafka/pull/11026#discussion_r670487440
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/internals/ListConsumerGroupOffsetsHandler.java
##
@@ -110,41 +112,97 @@ public String
cadonna edited a comment on pull request #10953:
URL: https://github.com/apache/kafka/pull/10953#issuecomment-880699127
Filed the following tickets for the session window bug:
https://issues.apache.org/jira/browse/KAFKA-13094
--
This is an automated message from the Apache Git Service.
cadonna commented on pull request #10953:
URL: https://github.com/apache/kafka/pull/10953#issuecomment-880699127
Opened the following PR for the session window bug:
https://issues.apache.org/jira/browse/KAFKA-13094
--
This is an automated message from the Apache Git Service.
To respond
[
https://issues.apache.org/jira/browse/KAFKA-13094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna updated KAFKA-13094:
--
Description:
Session windows use internally method {{maintainMs()}} to compute the retention
[
https://issues.apache.org/jira/browse/KAFKA-13094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna updated KAFKA-13094:
--
Description:
Session windows use internally method {{maintainMs()}} to compute the retention
[
https://issues.apache.org/jira/browse/KAFKA-13094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna updated KAFKA-13094:
--
Description:
Session windows use internally method {{maintainMs()}} to compute the retention
Bruno Cadonna created KAFKA-13094:
-
Summary: Session windows do not consider user-specified grace when
computing retention time for changelog
Key: KAFKA-13094
URL:
[
https://issues.apache.org/jira/browse/KAFKA-12655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17381342#comment-17381342
]
amit commented on KAFKA-12655:
--
Seems like this was not back-ported to 2.7.1. Can someone confirm?
>
Ismael Juma created KAFKA-13093:
---
Summary: KIP-724: Log compaction should write new segments with
record version v2
Key: KAFKA-13093
URL: https://issues.apache.org/jira/browse/KAFKA-13093
Project:
[
https://issues.apache.org/jira/browse/KAFKA-12944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismael Juma updated KAFKA-12944:
Description: (was: If IBP is 3.0 or higher.)
> KIP-724: Assume message format version is 3.0
[
https://issues.apache.org/jira/browse/KAFKA-12944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismael Juma updated KAFKA-12944:
Summary: KIP-724: Assume message format version is 3.0 when IBP is 3.0 or
higher (was: KIP-724:
dajac commented on a change in pull request #11026:
URL: https://github.com/apache/kafka/pull/11026#discussion_r670436565
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/internals/ListConsumerGroupOffsetsHandler.java
##
@@ -110,41 +112,97 @@ public String
showuon commented on pull request #11035:
URL: https://github.com/apache/kafka/pull/11035#issuecomment-880662479
Thank you. it have been running for whole day. :)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
cadonna commented on a change in pull request #10953:
URL: https://github.com/apache/kafka/pull/10953#discussion_r670424875
##
File path:
streams/src/test/java/org/apache/kafka/streams/kstream/SessionWindowsTest.java
##
@@ -57,6 +57,13 @@ public void
cadonna commented on a change in pull request #10953:
URL: https://github.com/apache/kafka/pull/10953#discussion_r670424591
##
File path:
streams/src/test/java/org/apache/kafka/streams/kstream/JoinWindowsTest.java
##
@@ -117,6 +118,13 @@ public void
dajac commented on pull request #11021:
URL: https://github.com/apache/kafka/pull/11021#issuecomment-880661583
Merged to trunk and to 3.0. cc @kkonstantine
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
dajac merged pull request #11021:
URL: https://github.com/apache/kafka/pull/11021
--
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:
dajac commented on pull request #11021:
URL: https://github.com/apache/kafka/pull/11021#issuecomment-880660679
Failures are not related:
```
Build / JDK 16 and Scala 2.13 / shouldBeAbleToQueryFilterState –
org.apache.kafka.streams.integration.QueryableStateIntegrationTest
43s
dajac commented on pull request #11035:
URL: https://github.com/apache/kafka/pull/11035#issuecomment-880657706
I've re-triggered Jenkins.
--
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
cadonna commented on a change in pull request #10953:
URL: https://github.com/apache/kafka/pull/10953#discussion_r670414694
##
File path:
streams/src/test/java/org/apache/kafka/streams/kstream/JoinWindowsTest.java
##
@@ -117,6 +118,13 @@ public void
dajac commented on pull request #11022:
URL: https://github.com/apache/kafka/pull/11022#issuecomment-880652697
Merged to trunk and to 3.0. cc @kkonstantine
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
dajac merged pull request #11022:
URL: https://github.com/apache/kafka/pull/11022
--
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:
dajac commented on pull request #11022:
URL: https://github.com/apache/kafka/pull/11022#issuecomment-880650309
Failures are not related:
```
Build / JDK 8 and Scala 2.12 / testUnauthorizedDeleteTopicsWithDescribe() –
kafka.api.AuthorizerIntegrationTest
1m 7s
Build / JDK 8 and
dajac commented on pull request #11019:
URL: https://github.com/apache/kafka/pull/11019#issuecomment-880648532
Merged to trunk and to 3.0. cc @kkonstantine
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
dajac merged pull request #11019:
URL: https://github.com/apache/kafka/pull/11019
--
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:
dajac commented on pull request #11019:
URL: https://github.com/apache/kafka/pull/11019#issuecomment-880645547
Failures are not related:
```
Build / JDK 11 and Scala 2.13 / testCommitTransactionTimeout() –
kafka.api.TransactionsTest
12s
Build / JDK 11 and Scala 2.13 /
tombentley commented on pull request #10945:
URL: https://github.com/apache/kafka/pull/10945#issuecomment-880614825
@rhauch / @kkonstantine do you want to take a look too? If not I'll go ahead
and merge.
--
This is an automated message from the Apache Git Service.
To respond to the
cadonna commented on a change in pull request #10953:
URL: https://github.com/apache/kafka/pull/10953#discussion_r670352776
##
File path:
streams/src/test/java/org/apache/kafka/streams/kstream/JoinWindowsTest.java
##
@@ -117,6 +118,13 @@ public void
1 - 100 of 110 matches
Mail list logo
