omkreddy commented on pull request #8808:
URL: https://github.com/apache/kafka/pull/8808#issuecomment-655879846
retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please
ableegoldman commented on a change in pull request #8996:
URL: https://github.com/apache/kafka/pull/8996#discussion_r451945495
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorStateManager.java
##
@@ -224,6 +224,9 @@ void
vvcephei commented on a change in pull request #8994:
URL: https://github.com/apache/kafka/pull/8994#discussion_r451939499
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java
##
@@ -1140,4 +1166,12 @@ public static void
vvcephei commented on a change in pull request #8994:
URL: https://github.com/apache/kafka/pull/8994#discussion_r451939231
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java
##
@@ -766,6 +769,24 @@ void runOnce() {
vvcephei commented on a change in pull request #8994:
URL: https://github.com/apache/kafka/pull/8994#discussion_r451939108
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java
##
@@ -137,7 +138,7 @@
STARTING(2, 3, 5),
vvcephei commented on a change in pull request #8994:
URL: https://github.com/apache/kafka/pull/8994#discussion_r451938891
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java
##
@@ -95,7 +96,7 @@
* | |
vvcephei commented on a change in pull request #8994:
URL: https://github.com/apache/kafka/pull/8994#discussion_r451938167
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java
##
@@ -193,6 +197,28 @@ private void
vvcephei commented on a change in pull request #8994:
URL: https://github.com/apache/kafka/pull/8994#discussion_r451938104
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java
##
@@ -193,6 +197,28 @@ private void
vvcephei commented on a change in pull request #8994:
URL: https://github.com/apache/kafka/pull/8994#discussion_r451937935
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java
##
@@ -766,6 +769,24 @@ void runOnce() {
apovzner commented on a change in pull request #8977:
URL: https://github.com/apache/kafka/pull/8977#discussion_r451937131
##
File path:
clients/src/main/java/org/apache/kafka/common/metrics/stats/TokenBucket.java
##
@@ -0,0 +1,127 @@
+/*
+ * Licensed to the Apache Software
apovzner commented on a change in pull request #8977:
URL: https://github.com/apache/kafka/pull/8977#discussion_r451932855
##
File path:
clients/src/main/java/org/apache/kafka/common/metrics/stats/TokenBucket.java
##
@@ -0,0 +1,127 @@
+/*
+ * Licensed to the Apache Software
apovzner commented on a change in pull request #8977:
URL: https://github.com/apache/kafka/pull/8977#discussion_r451932855
##
File path:
clients/src/main/java/org/apache/kafka/common/metrics/stats/TokenBucket.java
##
@@ -0,0 +1,127 @@
+/*
+ * Licensed to the Apache Software
apovzner commented on a change in pull request #8977:
URL: https://github.com/apache/kafka/pull/8977#discussion_r451932855
##
File path:
clients/src/main/java/org/apache/kafka/common/metrics/stats/TokenBucket.java
##
@@ -0,0 +1,127 @@
+/*
+ * Licensed to the Apache Software
apovzner commented on a change in pull request #8977:
URL: https://github.com/apache/kafka/pull/8977#discussion_r451932855
##
File path:
clients/src/main/java/org/apache/kafka/common/metrics/stats/TokenBucket.java
##
@@ -0,0 +1,127 @@
+/*
+ * Licensed to the Apache Software
apovzner commented on a change in pull request #8977:
URL: https://github.com/apache/kafka/pull/8977#discussion_r451932855
##
File path:
clients/src/main/java/org/apache/kafka/common/metrics/stats/TokenBucket.java
##
@@ -0,0 +1,127 @@
+/*
+ * Licensed to the Apache Software
mjsax commented on a change in pull request #8996:
URL: https://github.com/apache/kafka/pull/8996#discussion_r451928170
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorStateManagerTest.java
##
@@ -784,7 +784,7 @@ public void close() {
mjsax commented on a change in pull request #8996:
URL: https://github.com/apache/kafka/pull/8996#discussion_r451927714
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateManagerUtil.java
##
@@ -104,17 +104,16 @@ static void
mjsax commented on a change in pull request #8996:
URL: https://github.com/apache/kafka/pull/8996#discussion_r451927097
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorStateManager.java
##
@@ -224,6 +224,9 @@ void
mjsax commented on a change in pull request #8996:
URL: https://github.com/apache/kafka/pull/8996#discussion_r451926665
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorStateManager.java
##
@@ -224,6 +224,9 @@ void
ableegoldman commented on a change in pull request #8996:
URL: https://github.com/apache/kafka/pull/8996#discussion_r451925626
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateManagerUtil.java
##
@@ -104,17 +104,16 @@ static void
ableegoldman commented on a change in pull request #8997:
URL: https://github.com/apache/kafka/pull/8997#discussion_r451915598
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignor.java
##
@@ -725,8 +725,10 @@ private
ableegoldman commented on a change in pull request #8996:
URL: https://github.com/apache/kafka/pull/8996#discussion_r451922421
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorStateManagerTest.java
##
@@ -784,7 +784,7 @@ public void
ableegoldman commented on a change in pull request #8996:
URL: https://github.com/apache/kafka/pull/8996#discussion_r451922040
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorStateManager.java
##
@@ -224,6 +224,9 @@ void
[
https://issues.apache.org/jira/browse/KAFKA-8940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17154113#comment-17154113
]
Sophie Blee-Goldman commented on KAFKA-8940:
Failed again:
h3. Error Message
guozhangwang commented on a change in pull request #8997:
URL: https://github.com/apache/kafka/pull/8997#discussion_r451912298
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/ClientState.java
##
@@ -66,32 +72,17 @@ public
guozhangwang commented on pull request #8997:
URL: https://github.com/apache/kafka/pull/8997#issuecomment-655841394
@ableegoldman @abbccdda
This is an automated message from the Apache Git Service.
To respond to the
guozhangwang opened a new pull request #8997:
URL: https://github.com/apache/kafka/pull/8997
Add log4j entry summarizing the assignment (prev owned and assigned) at the
consumer level.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
[
https://issues.apache.org/jira/browse/KAFKA-10251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17154110#comment-17154110
]
Sophie Blee-Goldman commented on KAFKA-10251:
-
cc [~bchen225242] –
Sophie Blee-Goldman created KAFKA-10251:
---
Summary: Flaky Test
kafka.api.TransactionsBounceTest.testWithGroupMetadata
Key: KAFKA-10251
URL: https://issues.apache.org/jira/browse/KAFKA-10251
mjsax closed pull request #8855:
URL: https://github.com/apache/kafka/pull/8855
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
mjsax commented on a change in pull request #8902:
URL: https://github.com/apache/kafka/pull/8902#discussion_r451903126
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractProcessorContext.java
##
@@ -45,24 +45,23 @@
protected
mjsax commented on a change in pull request #8996:
URL: https://github.com/apache/kafka/pull/8996#discussion_r451902131
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorStateManagerTest.java
##
@@ -813,6 +813,62 @@ public void
mjsax commented on a change in pull request #8996:
URL: https://github.com/apache/kafka/pull/8996#discussion_r451901975
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorStateManagerTest.java
##
@@ -784,7 +784,7 @@ public void close() {
mjsax commented on a change in pull request #8996:
URL: https://github.com/apache/kafka/pull/8996#discussion_r451900686
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorStateManager.java
##
@@ -224,6 +224,9 @@ void
mjsax commented on a change in pull request #8996:
URL: https://github.com/apache/kafka/pull/8996#discussion_r451899726
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorStateManager.java
##
@@ -224,6 +224,9 @@ void
chia7712 commented on a change in pull request #8981:
URL: https://github.com/apache/kafka/pull/8981#discussion_r451898731
##
File path: tests/kafkatest/tests/core/transactions_test.py
##
@@ -47,7 +47,10 @@ def __init__(self, test_context):
self.num_output_partitions
mjsax commented on a change in pull request #8994:
URL: https://github.com/apache/kafka/pull/8994#discussion_r451895176
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java
##
@@ -193,6 +197,28 @@ private void closeAndRevive(final
ableegoldman commented on pull request #8996:
URL: https://github.com/apache/kafka/pull/8996#issuecomment-655825204
Two failures:
`TransactionsBounceTest.testWithGroupMetadata`
`SmokeTestDriverIntegrationTest.shouldWorkWithRebalance`
The `shouldWorkWithRebalance` failure is
ableegoldman commented on pull request #8913:
URL: https://github.com/apache/kafka/pull/8913#issuecomment-655815316
Hey @vvcephei , do you think we should ask about cherrypicking this back to
2.6 to help stabilize the release? I thought failing system tests (or regularly
failing tests of
ableegoldman commented on a change in pull request #8994:
URL: https://github.com/apache/kafka/pull/8994#discussion_r451884449
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java
##
@@ -95,7 +96,7 @@
* | |
apovzner commented on a change in pull request #8977:
URL: https://github.com/apache/kafka/pull/8977#discussion_r451871529
##
File path: clients/src/main/java/org/apache/kafka/common/metrics/Sensor.java
##
@@ -97,7 +97,25 @@ public static RecordingLevel forName(String name) {
vvcephei commented on pull request #8994:
URL: https://github.com/apache/kafka/pull/8994#issuecomment-655792712
Ok, @abbccdda and @mjsax , I think this is ready for a review now. I'm not
very happy with the logic to reset to the last committed offset. Can you think
of a better way to do
ableegoldman commented on a change in pull request #8994:
URL: https://github.com/apache/kafka/pull/8994#discussion_r451862588
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java
##
@@ -766,6 +769,24 @@ void runOnce() {
vvcephei commented on a change in pull request #8994:
URL: https://github.com/apache/kafka/pull/8994#discussion_r451860750
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java
##
@@ -766,6 +769,24 @@ void runOnce() {
rhauch commented on a change in pull request #8864:
URL: https://github.com/apache/kafka/pull/8864#discussion_r451856474
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaStatusBackingStore.java
##
@@ -148,6 +148,7 @@ public
[
https://issues.apache.org/jira/browse/KAFKA-10250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17154043#comment-17154043
]
Rishank Chandra Puram edited comment on KAFKA-10250 at 7/8/20, 10:09 PM:
mjsax commented on pull request #8996:
URL: https://github.com/apache/kafka/pull/8996#issuecomment-655783477
Retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please log
[
https://issues.apache.org/jira/browse/KAFKA-10250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rishank Chandra Puram updated KAFKA-10250:
--
Description:
The following the summary/overview of the whole issue. Can you
[
https://issues.apache.org/jira/browse/KAFKA-10250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17154043#comment-17154043
]
Rishank Chandra Puram commented on KAFKA-10250:
---
1. When the issue occurs, they're able to
ableegoldman opened a new pull request #8996:
URL: https://github.com/apache/kafka/pull/8996
We have this asymmetry in how the ProcessorStateManager handles in-memory
stores: we explicitly skip over them when writing offsets to the checkpoint
file, but don't do the same when reading from
Rishank Chandra Puram created KAFKA-10250:
-
Summary: Kafka broker shrinks the ISRs and disconnects from other
brokers for few seconds
Key: KAFKA-10250
URL:
kkonstantine commented on pull request #8928:
URL: https://github.com/apache/kafka/pull/8928#issuecomment-655764773
retest this please
This is an automated message from the Apache Git Service.
To respond to the message,
kkonstantine commented on a change in pull request #8928:
URL: https://github.com/apache/kafka/pull/8928#discussion_r451832657
##
File path:
connect/runtime/src/test/java/org/apache/kafka/connect/integration/BlockingConnectorTest.java
##
@@ -76,6 +78,15 @@ public void setup()
Sophie Blee-Goldman created KAFKA-10249:
---
Summary: In-memory stores are skipped when checkpointing but not
skipped when reading the checkpoint
Key: KAFKA-10249
URL:
JimGalasyn commented on a change in pull request #8995:
URL: https://github.com/apache/kafka/pull/8995#discussion_r451809936
##
File path: docs/streams/core-concepts.html
##
@@ -170,13 +150,59 @@ Duality of
or to run interactive
queries
against your
junrao commented on pull request #8981:
URL: https://github.com/apache/kafka/pull/8981#issuecomment-655737852
triggered a system test run
This is an automated message from the Apache Git Service.
To respond to the message,
junrao commented on a change in pull request #8981:
URL: https://github.com/apache/kafka/pull/8981#discussion_r451224908
##
File path: tests/kafkatest/tests/core/transactions_test.py
##
@@ -47,7 +47,10 @@ def __init__(self, test_context):
self.num_output_partitions =
[
https://issues.apache.org/jira/browse/KAFKA-10225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao resolved KAFKA-10225.
-
Fix Version/s: 2.7.0
Resolution: Fixed
merged the PR to trunk
> Increase default zk session
junrao merged pull request #8974:
URL: https://github.com/apache/kafka/pull/8974
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
junrao commented on pull request #8974:
URL: https://github.com/apache/kafka/pull/8974#issuecomment-655734288
System test results. All 9 failures seem unrelated to this PR.
mjsax commented on a change in pull request #8995:
URL: https://github.com/apache/kafka/pull/8995#discussion_r451796320
##
File path: docs/streams/core-concepts.html
##
@@ -170,13 +150,59 @@ Duality of
or to run interactive
queries
against your application's
[
https://issues.apache.org/jira/browse/KAFKA-8770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17153977#comment-17153977
]
John Roesler commented on KAFKA-8770:
-
Ok, I created (and resolved) a subtask, which is properly
[
https://issues.apache.org/jira/browse/KAFKA-10248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-10248.
--
Resolution: Fixed
> Drop idempotent KTable source updates
>
[
https://issues.apache.org/jira/browse/KAFKA-10248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-10248:
-
Fix Version/s: 2.6.0
> Drop idempotent KTable source updates
>
[
https://issues.apache.org/jira/browse/KAFKA-10248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17153976#comment-17153976
]
John Roesler commented on KAFKA-10248:
--
This was implemented in this commit:
{code:java}
commit
John Roesler created KAFKA-10248:
Summary: Drop idempotent KTable source updates
Key: KAFKA-10248
URL: https://issues.apache.org/jira/browse/KAFKA-10248
Project: Kafka
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/KAFKA-8770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17153975#comment-17153975
]
John Roesler commented on KAFKA-8770:
-
Hi [~davispw] ,
That's a good idea. I'll split it up.
The
vvcephei commented on pull request #8994:
URL: https://github.com/apache/kafka/pull/8994#issuecomment-655721490
Hey @abbccdda and @mjsax , thanks for taking a look! The PR is not complete
yet. I'll let you know when it's ready for review.
[
https://issues.apache.org/jira/browse/KAFKA-10218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17153936#comment-17153936
]
Chris Egerton commented on KAFKA-10218:
---
[~rhauch] The primary impact here is that there are
cmccabe merged pull request #8985:
URL: https://github.com/apache/kafka/pull/8985
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
JimGalasyn opened a new pull request #8995:
URL: https://github.com/apache/kafka/pull/8995
The stream-table duality section was dropped inadvertently sometime after
version 0.11.0, so this PR restores it.
This is an
mjsax commented on pull request #8994:
URL: https://github.com/apache/kafka/pull/8994#issuecomment-655701085
It seem the root cause of the issue is that we don't cleanup internal data
structures correctly when closing a task dirty? Should the task not be removed
from the list of active
[
https://issues.apache.org/jira/browse/KAFKA-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17153862#comment-17153862
]
Guozhang Wang commented on KAFKA-10134:
---
cc 2.5.1 release manager [~vvcephei] I'm merging it to
[
https://issues.apache.org/jira/browse/KAFKA-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17153861#comment-17153861
]
Guozhang Wang commented on KAFKA-10134:
---
Thanks for the confirmation! I'm resolving this ticket
[
https://issues.apache.org/jira/browse/KAFKA-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-10134.
---
Resolution: Fixed
> High CPU issue during rebalance in Kafka consumer after upgrading to
[
https://issues.apache.org/jira/browse/KAFKA-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17153852#comment-17153852
]
Neo Wu commented on KAFKA-10134:
Hi, [~guozhang]
Your latest change fixed all my issues, Thanks!
>
[
https://issues.apache.org/jira/browse/KAFKA-10247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-10247:
-
Priority: Blocker (was: Major)
> Streams may attempt to process after closing a task
>
vvcephei opened a new pull request #8994:
URL: https://github.com/apache/kafka/pull/8994
The definition of `Task#process` allows for returning `false`
if the task isn't "processable" right now. We can conveniently
resolve KAFKA-10247 by simply considering a task not
processable
John Roesler created KAFKA-10247:
Summary: Streams may attempt to process after closing a task
Key: KAFKA-10247
URL: https://issues.apache.org/jira/browse/KAFKA-10247
Project: Kafka
Issue
vvcephei commented on a change in pull request #8993:
URL: https://github.com/apache/kafka/pull/8993#discussion_r451712293
##
File path: tests/kafkatest/tests/streams/streams_application_upgrade_test.py
##
@@ -0,0 +1,297 @@
+# Licensed to the Apache Software Foundation (ASF)
[
https://issues.apache.org/jira/browse/KAFKA-10226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17153768#comment-17153768
]
Werner Daehn edited comment on KAFKA-10226 at 7/8/20, 5:26 PM:
---
Here is my
omkreddy commented on pull request #8808:
URL: https://github.com/apache/kafka/pull/8808#issuecomment-655651164
retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please
vvcephei commented on pull request #8902:
URL: https://github.com/apache/kafka/pull/8902#issuecomment-655648704
Failure was unrelated:
kafka.api.SaslMultiMechanismConsumerTest.testCoordinatorFailover
This is an automated
[
https://issues.apache.org/jira/browse/KAFKA-10226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17153768#comment-17153768
]
Werner Daehn commented on KAFKA-10226:
--
Here is my verdict after testing:
Producer, Consumer,
tombentley commented on pull request #8808:
URL: https://github.com/apache/kafka/pull/8808#issuecomment-655641999
@omkreddy, sorry about that, now fixed.
This is an automated message from the Apache Git Service.
To respond
[
https://issues.apache.org/jira/browse/KAFKA-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17153757#comment-17153757
]
Guozhang Wang commented on KAFKA-10134:
---
I've merged the PR and would like [~seanguo] [~neowu0] to
guozhangwang commented on pull request #8934:
URL: https://github.com/apache/kafka/pull/8934#issuecomment-655636676
Cherry-picked to 2.6.
This is an automated message from the Apache Git Service.
To respond to the message,
guozhangwang merged pull request #8934:
URL: https://github.com/apache/kafka/pull/8934
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
hachikuji commented on a change in pull request #8864:
URL: https://github.com/apache/kafka/pull/8864#discussion_r451682470
##
File path:
clients/src/test/java/org/apache/kafka/clients/admin/KafkaAdminClientTest.java
##
@@ -1447,6 +1451,7 @@ public void
omkreddy commented on a change in pull request #8808:
URL: https://github.com/apache/kafka/pull/8808#discussion_r451674847
##
File path: core/src/test/scala/unit/kafka/admin/AclCommandTest.scala
##
@@ -127,25 +131,53 @@ class AclCommandTest extends ZooKeeperTestHarness with
[
https://issues.apache.org/jira/browse/KAFKA-9144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson updated KAFKA-9144:
---
Affects Version/s: 2.0.1
2.1.1
2.2.2
[
https://issues.apache.org/jira/browse/KAFKA-9144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson updated KAFKA-9144:
---
Fix Version/s: 2.3.2
2.2.3
> Early expiration of producer state can cause
tombentley commented on pull request #8808:
URL: https://github.com/apache/kafka/pull/8808#issuecomment-655617244
@omkreddy done
This is an automated message from the Apache Git Service.
To respond to the message, please log
vvcephei commented on pull request #8993:
URL: https://github.com/apache/kafka/pull/8993#issuecomment-655605721
Started the new test:
https://jenkins.confluent.io/job/system-test-kafka-branch-builder/4015/
And all streams tests:
vvcephei commented on a change in pull request #8993:
URL: https://github.com/apache/kafka/pull/8993#discussion_r451634562
##
File path: build.gradle
##
@@ -1508,6 +1508,18 @@ project(':streams:upgrade-system-tests-24') {
}
}
+project(':streams:upgrade-system-tests-25')
omkreddy commented on a change in pull request #8808:
URL: https://github.com/apache/kafka/pull/8808#discussion_r451626581
##
File path: core/src/test/scala/unit/kafka/admin/AclCommandTest.scala
##
@@ -161,10 +193,34 @@ class AclCommandTest extends ZooKeeperTestHarness with
vvcephei opened a new pull request #8993:
URL: https://github.com/apache/kafka/pull/8993
Replaces the previous upgrade test's trivial Streams app
with the commonly used SmokeTest, exercising many more
features. Also adjust the test matrix to test upgrading
from each released
[
https://issues.apache.org/jira/browse/KAFKA-10226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17153667#comment-17153667
]
John Roesler commented on KAFKA-10226:
--
Sounds good :)
> KStream without SASL information should
dajac commented on pull request #8985:
URL: https://github.com/apache/kafka/pull/8985#issuecomment-655567477
Jenkins looks good. There were one unrelated failed test during the JDK 14
and Scala 2.13 run.
This is an
omkreddy commented on pull request #8808:
URL: https://github.com/apache/kafka/pull/8808#issuecomment-65622
ok to test
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
1 - 100 of 121 matches
Mail list logo