mjsax commented on a change in pull request #8776:
URL: https://github.com/apache/kafka/pull/8776#discussion_r433660276
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java
##
@@ -390,19 +387,17 @@ boolean tryToCompleteRestoration()
mjsax commented on a change in pull request #8776:
URL: https://github.com/apache/kafka/pull/8776#discussion_r433660588
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java
##
@@ -529,11 +524,7 @@ void handleLostAll() {
for
mjsax commented on a change in pull request #8776:
URL: https://github.com/apache/kafka/pull/8776#discussion_r433660588
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java
##
@@ -529,11 +524,7 @@ void handleLostAll() {
for
mjsax commented on a change in pull request #8776:
URL: https://github.com/apache/kafka/pull/8776#discussion_r433661972
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java
##
@@ -613,10 +604,14 @@ private long sumOfChangelogOffsets
mjsax commented on a change in pull request #8776:
URL: https://github.com/apache/kafka/pull/8776#discussion_r433662342
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/TaskManagerTest.java
##
@@ -2637,11 +2646,17 @@ private File getCheckpointFi
mjsax commented on a change in pull request #8776:
URL: https://github.com/apache/kafka/pull/8776#discussion_r433662426
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/TaskManagerTest.java
##
@@ -2637,11 +2646,17 @@ private File getCheckpointFi
[
https://issues.apache.org/jira/browse/KAFKA-7538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17123415#comment-17123415
]
Viktor Somogyi-Vass commented on KAFKA-7538:
[~rsivaram] has subcase 1 and 3
Luke Chen created KAFKA-10082:
-
Summary: fix failed
kafka.api.PlaintextConsumerTest.testMultiConsumerStickyAssignment
Key: KAFKA-10082
URL: https://issues.apache.org/jira/browse/KAFKA-10082
Project: Kafka
showuon opened a new pull request #8777:
URL: https://github.com/apache/kafka/pull/8777
Fix the failed `testMultiConsumerStickyAssignment` by modify the logic error
in `allSubscriptionsEqual` method. We will create the
`consumerToOwnedPartitions` to keep the set of previously owned partiti
showuon commented on pull request #8777:
URL: https://github.com/apache/kafka/pull/8777#issuecomment-637344872
@ableegoldman , could you check this PR to fix the failed tests? Thanks.
This is an automated message from the Apa
kkonstantine commented on a change in pull request #8630:
URL: https://github.com/apache/kafka/pull/8630#discussion_r433640144
##
File path:
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/isolation/PluginUtilsTest.java
##
@@ -114,68 +90,264 @@ public void testC
d8tltanc edited a comment on pull request #8421:
URL: https://github.com/apache/kafka/pull/8421#issuecomment-637300554
@skaundinya15 @ijuma @abbccdda Thanks for all the feedback and comments.
This patch was made when I was new to Kafka. It's kind of naive to me at this
time as I gained mor
[
https://issues.apache.org/jira/browse/KAFKA-9800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17123377#comment-17123377
]
Cheng Tan edited comment on KAFKA-9800 at 6/2/20, 7:53 AM:
---
Rec
dajac commented on a change in pull request #8768:
URL: https://github.com/apache/kafka/pull/8768#discussion_r433696374
##
File path: core/src/main/scala/kafka/network/SocketServer.scala
##
@@ -1287,15 +1309,97 @@ class ConnectionQuotas(config: KafkaConfig, time: Time)
extends
chia7712 commented on a change in pull request #8755:
URL: https://github.com/apache/kafka/pull/8755#discussion_r433724296
##
File path:
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/ConnectorConfigTest.java
##
@@ -434,5 +436,52 @@ public void configure(Map co
[
https://issues.apache.org/jira/browse/KAFKA-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17123542#comment-17123542
]
Mateusz Jadczyk commented on KAFKA-9891:
[~bchen225242] yes, it should be materia
[
https://issues.apache.org/jira/browse/KAFKA-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17123544#comment-17123544
]
Mateusz Jadczyk commented on KAFKA-9891:
The reason we need at least one material
[
https://issues.apache.org/jira/browse/KAFKA-9148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17123597#comment-17123597
]
adam Retter commented on KAFKA-9148:
Thanks [~ableegoldman].
I just wanted to be
[
https://issues.apache.org/jira/browse/KAFKA-10075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17123656#comment-17123656
]
Tom Bentley commented on KAFKA-10075:
-
Is the JVM in which you're running the client
astubbs commented on pull request #8771:
URL: https://github.com/apache/kafka/pull/8771#issuecomment-637501018
Retest this please.
This is an automated message from the Apache Git Service.
To respond to the message, please lo
Luke Chen created KAFKA-10083:
-
Summary: fix failed
testReassignmentWithRandomSubscriptionsAndChanges
Key: KAFKA-10083
URL: https://issues.apache.org/jira/browse/KAFKA-10083
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-10083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen updated KAFKA-10083:
--
Description:
[https://builds.apache.org/job/kafka-pr-jdk14-scala2.13/815/]
It can also locally reprod
showuon opened a new pull request #8778:
URL: https://github.com/apache/kafka/pull/8778
The failed test is because we changed the class member `partitionMovements`
initialization to the class instance created, from initialized when used within
`assign` method. This won't have any issue whe
showuon commented on pull request #8778:
URL: https://github.com/apache/kafka/pull/8778#issuecomment-637512220
@ableegoldman , could you review this PR to fix the failed tests? Thanks.
This is an automated message from the Ap
[
https://issues.apache.org/jira/browse/KAFKA-10082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen updated KAFKA-10082:
--
Reviewer: Sophie Blee-Goldman
> fix failed kafka.api.PlaintextConsumerTest.testMultiConsumerStickyAssi
[
https://issues.apache.org/jira/browse/KAFKA-10083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen updated KAFKA-10083:
--
Description:
[https://builds.apache.org/job/kafka-pr-jdk14-scala2.13/815/]
h3. Error Message
java.
nizhikov commented on pull request #8695:
URL: https://github.com/apache/kafka/pull/8695#issuecomment-637515040
@ijuma I found explanation of the test behavior.
Full information can be found in the
[guide](https://docs.oracle.com/en/java/javase/11/security/java-secure-socket-extensio
itantiger commented on pull request #8753:
URL: https://github.com/apache/kafka/pull/8753#issuecomment-637519467
@guozhangwang Can you take a look at this?
This is an automated message from the Apache Git Service.
To respond
bbejeck commented on pull request #8771:
URL: https://github.com/apache/kafka/pull/8771#issuecomment-637540041
retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please log
ijuma commented on a change in pull request #8695:
URL: https://github.com/apache/kafka/pull/8695#discussion_r433892269
##
File path:
clients/src/test/java/org/apache/kafka/common/network/SslVersionsTransportLayerTest.java
##
@@ -117,24 +123,51 @@ public void testTlsDefaults()
nizhikov commented on a change in pull request #8695:
URL: https://github.com/apache/kafka/pull/8695#discussion_r433899761
##
File path:
clients/src/test/java/org/apache/kafka/common/network/SslVersionsTransportLayerTest.java
##
@@ -117,24 +123,51 @@ public void testTlsDefault
ijuma commented on a change in pull request #8695:
URL: https://github.com/apache/kafka/pull/8695#discussion_r433903099
##
File path:
clients/src/test/java/org/apache/kafka/common/network/SslVersionsTransportLayerTest.java
##
@@ -0,0 +1,175 @@
+/*
+ * Licensed to the Apache So
ijuma commented on pull request #8695:
URL: https://github.com/apache/kafka/pull/8695#issuecomment-637569220
Oh, one more thing, let's please add an entry to `upgrade.html`.
This is an automated message from the Apache Git Se
nizhikov opened a new pull request #8779:
URL: https://github.com/apache/kafka/pull/8779
Fixing nit in c6633a157eec1712116d294eb3785a96cba4e331.
This commit break spotbug check with the "Dead store to isFreshAssignment in
org.apache.kafka.clients.consumer.internals.AbstractStickyAssignor
chia7712 commented on pull request #8774:
URL: https://github.com/apache/kafka/pull/8774#issuecomment-637570083
```testReassignmentWithRandomSubscriptionsAndChanges``` is traced by #8778
```testMultiConsumerStickyAssignment``` is traced by #8777
+1 to merge this hotfix :)
---
nizhikov commented on pull request #8779:
URL: https://github.com/apache/kafka/pull/8779#issuecomment-637570728
Hello @ableegoldman
It looks like your patch breaks spot bug check.
I prepared oneliner fix for it.
Can you, please, take a look?
--
ijuma commented on pull request #8695:
URL: https://github.com/apache/kafka/pull/8695#issuecomment-637573626
retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please log o
nizhikov commented on pull request #8695:
URL: https://github.com/apache/kafka/pull/8695#issuecomment-637574517
I think, currently, the trunk is broken with the
c6633a157eec1712116d294eb3785a96cba4e331
I prepared oneliner fix for it - #8779
nizhikov commented on a change in pull request #8695:
URL: https://github.com/apache/kafka/pull/8695#discussion_r433920350
##
File path:
clients/src/test/java/org/apache/kafka/common/network/SslVersionsTransportLayerTest.java
##
@@ -117,24 +123,51 @@ public void testTlsDefault
vvcephei commented on pull request #8775:
URL: https://github.com/apache/kafka/pull/8775#issuecomment-637578416
Ok to test
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
bbejeck commented on pull request #8771:
URL: https://github.com/apache/kafka/pull/8771#issuecomment-637586221
Retest this please.
This is an automated message from the Apache Git Service.
To respond to the message, please lo
ijuma commented on pull request #8668:
URL: https://github.com/apache/kafka/pull/8668#issuecomment-637591555
Did we check the build before merging this? It seems to have broken it:
https://github.com/apache/kafka/pull/8779
ijuma edited a comment on pull request #8668:
URL: https://github.com/apache/kafka/pull/8668#issuecomment-637592541
@guozhangwang Looks like 2.6, 2.5 and 2.4 are broken too. You should
generally also build locally when cherry-picking.
--
ijuma commented on pull request #8668:
URL: https://github.com/apache/kafka/pull/8668#issuecomment-637592541
@guozhangwang Looks like 2.6, 2.5 and 2.4 are broken too. You should
generally build locally when cherry-picking.
T
d8tltanc edited a comment on pull request #8421:
URL: https://github.com/apache/kafka/pull/8421#issuecomment-637300554
@skaundinya15 @ijuma @abbccdda Thanks for all the feedback and comments.
This patch was made when I was new to Kafka. It's kind of naive to me at this
time as I gained mor
d8tltanc edited a comment on pull request #8421:
URL: https://github.com/apache/kafka/pull/8421#issuecomment-637300554
@skaundinya15 @ijuma @abbccdda Thanks for all the feedback and comments.
This patch was made when I was new to Kafka. It's kind of naive to me at this
time as I gained mor
[
https://issues.apache.org/jira/browse/KAFKA-9800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17123377#comment-17123377
]
Cheng Tan edited comment on KAFKA-9800 at 6/2/20, 3:12 PM:
---
Rec
[
https://issues.apache.org/jira/browse/KAFKA-9800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17123935#comment-17123935
]
Ismael Juma commented on KAFKA-9800:
I think you should apply the same backoff strate
collabH closed pull request #8780:
URL: https://github.com/apache/kafka/pull/8780
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 th
collabH opened a new pull request #8780:
URL: https://github.com/apache/kafka/pull/8780
*More detailed description of your change,
if necessary. The PR title and PR message become
the squashed commit message, so use a separate
comment to ping reviewers.*
*Summary of testing s
collabH opened a new pull request #8781:
URL: https://github.com/apache/kafka/pull/8781
*More detailed description of your change,
if necessary. The PR title and PR message become
the squashed commit message, so use a separate
comment to ping reviewers.*
*Summary of testing s
collabH closed pull request #8781:
URL: https://github.com/apache/kafka/pull/8781
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 th
ijuma commented on a change in pull request #8695:
URL: https://github.com/apache/kafka/pull/8695#discussion_r433981892
##
File path: clients/src/main/java/org/apache/kafka/common/config/SslConfigs.java
##
@@ -49,11 +50,12 @@
public static final String SSL_PROTOCOL_CONFI
ijuma commented on a change in pull request #8695:
URL: https://github.com/apache/kafka/pull/8695#discussion_r433987384
##
File path: clients/src/main/java/org/apache/kafka/common/config/SslConfigs.java
##
@@ -64,7 +66,17 @@
public static final String SSL_ENABLED_PROTOCO
ijuma commented on a change in pull request #8695:
URL: https://github.com/apache/kafka/pull/8695#discussion_r433987384
##
File path: clients/src/main/java/org/apache/kafka/common/config/SslConfigs.java
##
@@ -64,7 +66,17 @@
public static final String SSL_ENABLED_PROTOCO
ijuma commented on a change in pull request #8695:
URL: https://github.com/apache/kafka/pull/8695#discussion_r433990762
##
File path: docs/upgrade.html
##
@@ -18,6 +18,10 @@
ijuma merged pull request #8779:
URL: https://github.com/apache/kafka/pull/8779
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 commented on pull request #8695:
URL: https://github.com/apache/kafka/pull/8695#issuecomment-637647620
@nizhikov I think we're good to merge this after the non code suggestions
above are addressed (assuming we can get a Jenkins build, I merged your other
PR fixing the build issue).
mjsax commented on pull request #8774:
URL: https://github.com/apache/kafka/pull/8774#issuecomment-637655627
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
mjsax removed a comment on pull request #8774:
URL: https://github.com/apache/kafka/pull/8774#issuecomment-637655696
Retest this please
This is an automated message from the Apache Git Service.
To respond to the message, plea
mjsax merged pull request #8774:
URL: https://github.com/apache/kafka/pull/8774
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-9943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismael Juma reassigned KAFKA-9943:
--
Assignee: Nikolay Izhikov
> Enable TLSv.1.3 in system tests "run all" execution.
> ---
[
https://issues.apache.org/jira/browse/KAFKA-9943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismael Juma updated KAFKA-9943:
---
Fix Version/s: 2.6.0
> Enable TLSv.1.3 in system tests "run all" execution.
> ---
ableegoldman commented on a change in pull request #8778:
URL: https://github.com/apache/kafka/pull/8778#discussion_r434008302
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignor.java
##
@@ -43,7 +43,7 @@
public static
ableegoldman commented on pull request #8777:
URL: https://github.com/apache/kafka/pull/8777#issuecomment-637664149
cc @mjsax @guozhangwang , should be cherrypicked to 2.6, 2.5, and 2.4
This is an automated message from the A
ableegoldman commented on pull request #8778:
URL: https://github.com/apache/kafka/pull/8778#issuecomment-637665071
cc @mjsax @guozhangwang , should be cherrypicked to 2.6, 2.5, and 2.4 (once
my comment above is addressed)
T
vvcephei commented on a change in pull request #8775:
URL: https://github.com/apache/kafka/pull/8775#discussion_r433923120
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignor.java
##
@@ -938,57 +930,9 @@ private void popula
chia7712 commented on pull request #8657:
URL: https://github.com/apache/kafka/pull/8657#issuecomment-637668386
@junrao Could you take a look?
This is an automated message from the Apache Git Service.
To respond to the messa
[
https://issues.apache.org/jira/browse/KAFKA-10063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai reassigned KAFKA-10063:
--
Assignee: Chia-Ping Tsai
> UnsupportedOperation when querying cleaner metrics after s
ableegoldman commented on a change in pull request #8775:
URL: https://github.com/apache/kafka/pull/8775#discussion_r434018826
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/ClientState.java
##
@@ -242,8 +250,9 @@ public void addOwn
ableegoldman commented on pull request #8668:
URL: https://github.com/apache/kafka/pull/8668#issuecomment-637672028
Sorry @ijuma, I think I only ever ran the local tests + checkstyle, not the
full suite. My mistake
This is a
ableegoldman commented on a change in pull request #8668:
URL: https://github.com/apache/kafka/pull/8668#discussion_r434021704
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignor.java
##
@@ -65,9 +72,206 @@ public MemberData(L
[
https://issues.apache.org/jira/browse/KAFKA-7599?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stanislav Kozlovski reassigned KAFKA-7599:
--
Assignee: (was: Stanislav Kozlovski)
> Trogdor - Allow configuration for n
[
https://issues.apache.org/jira/browse/KAFKA-8264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stanislav Kozlovski reassigned KAFKA-8264:
--
Assignee: (was: Stanislav Kozlovski)
> Flaky Test PlaintextConsumerTest#te
guozhangwang commented on pull request #8779:
URL: https://github.com/apache/kafka/pull/8779#issuecomment-637676075
Cherry-picked to 2.6 / 2.5 / 2.4
This is an automated message from the Apache Git Service.
To respond to the
guozhangwang merged pull request #8777:
URL: https://github.com/apache/kafka/pull/8777
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
guozhangwang commented on pull request #8777:
URL: https://github.com/apache/kafka/pull/8777#issuecomment-637677433
Cherry-picked to 2.6 / 2.5 / 2.4
This is an automated message from the Apache Git Service.
To respond to the
hachikuji opened a new pull request #8782:
URL: https://github.com/apache/kafka/pull/8782
The method `maybeWriteTxnCompletion` is unsafe for concurrent calls. This
can cause duplicate attempts to write the completion record to the log, which
can ultimately lead to illegal state errors and
[
https://issues.apache.org/jira/browse/KAFKA-8723?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stanislav Kozlovski resolved KAFKA-8723.
Resolution: Fixed
> flaky test LeaderElectionCommandTest#testAllTopicPartition
> --
[
https://issues.apache.org/jira/browse/KAFKA-7940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stanislav Kozlovski reassigned KAFKA-7940:
--
Assignee: (was: Stanislav Kozlovski)
> Flaky Test CustomQuotaCallbackTest#
[
https://issues.apache.org/jira/browse/KAFKA-8406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17124052#comment-17124052
]
Stanislav Kozlovski commented on KAFKA-8406:
[~savulchik] are you sure? Can y
bob-barrett opened a new pull request #8784:
URL: https://github.com/apache/kafka/pull/8784
…nsors
Sensor objects are stored in the Kafka metrics registry and keyed by name.
If a new sensor is created with the same name as an existing one, the existing
one is returned rather than a
chia7712 opened a new pull request #8783:
URL: https://github.com/apache/kafka/pull/8783
https://issues.apache.org/jira/browse/KAFKA-10063
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build statu
dongjinleekr commented on pull request #8117:
URL: https://github.com/apache/kafka/pull/8117#issuecomment-637683206
@vvcephei Sorry for being late, I just got out from my last project; I will
have a look.
This is an automate
dongjinleekr commented on pull request #7898:
URL: https://github.com/apache/kafka/pull/7898#issuecomment-637684403
All // Sorry for being late, I just got out from my last project; I will
have a look at this PR this weekend.
---
chia7712 commented on a change in pull request #8782:
URL: https://github.com/apache/kafka/pull/8782#discussion_r434038469
##
File path:
core/src/main/scala/kafka/coordinator/transaction/TransactionMarkerChannelManager.scala
##
@@ -215,8 +215,6 @@ class TransactionMarkerChanne
[
https://issues.apache.org/jira/browse/KAFKA-8480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jose Armando Garcia Sancio reassigned KAFKA-8480:
-
Assignee: Jose Armando Garcia Sancio (was: Anna Povzner)
> Clie
ableegoldman commented on a change in pull request #8776:
URL: https://github.com/apache/kafka/pull/8776#discussion_r434051190
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StandbyTask.java
##
@@ -247,6 +247,9 @@ private void close(final bool
[
https://issues.apache.org/jira/browse/KAFKA-9987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman resolved KAFKA-9987.
Fix Version/s: 2.5.1
2.4.2
2.6.0
Resolu
[
https://issues.apache.org/jira/browse/KAFKA-9987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman updated KAFKA-9987:
---
Component/s: consumer
> Improve sticky partition assignor algorithm
> ---
hachikuji commented on a change in pull request #8782:
URL: https://github.com/apache/kafka/pull/8782#discussion_r434098545
##
File path:
core/src/main/scala/kafka/coordinator/transaction/TransactionMarkerChannelManager.scala
##
@@ -285,15 +280,16 @@ class TransactionMarkerCha
mjsax commented on a change in pull request #8776:
URL: https://github.com/apache/kafka/pull/8776#discussion_r434110314
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StandbyTask.java
##
@@ -247,6 +247,9 @@ private void close(final boolean cle
mjsax commented on a change in pull request #8776:
URL: https://github.com/apache/kafka/pull/8776#discussion_r434111426
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StandbyTask.java
##
@@ -247,6 +247,9 @@ private void close(final boolean cle
mjsax commented on a change in pull request #8776:
URL: https://github.com/apache/kafka/pull/8776#discussion_r434111426
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StandbyTask.java
##
@@ -247,6 +247,9 @@ private void close(final boolean cle
John Roesler created KAFKA-10084:
Summary: System test failure:
StreamsEosTest.test_failure_and_recovery_complex
Key: KAFKA-10084
URL: https://issues.apache.org/jira/browse/KAFKA-10084
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-10084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-10084:
-
Affects Version/s: 2.7.0
> System test failure: StreamsEosTest.test_failure_and_recovery_complex
[
https://issues.apache.org/jira/browse/KAFKA-10084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-10084:
-
Fix Version/s: 2.6.0
2.7.0
> System test failure: StreamsEosTest.test_failure
[
https://issues.apache.org/jira/browse/KAFKA-10084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-10084:
-
Affects Version/s: 2.6.0
> System test failure: StreamsEosTest.test_failure_and_recovery_complex
abbccdda commented on a change in pull request #8776:
URL: https://github.com/apache/kafka/pull/8776#discussion_r434107127
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamTaskTest.java
##
@@ -1799,8 +1799,8 @@ public void shouldThrowIfClo
Sophie Blee-Goldman created KAFKA-10085:
---
Summary: Compute lag correctly for optimized source changelogs
Key: KAFKA-10085
URL: https://issues.apache.org/jira/browse/KAFKA-10085
Project: Kafka
1 - 100 of 227 matches
Mail list logo
