Dmitry created KAFKA-10013:
--
Summary: Consumer hang-up in case of unclean leader election
Key: KAFKA-10013
URL: https://issues.apache.org/jira/browse/KAFKA-10013
Project: Kafka
Issue Type: Bug
Chia-Ping Tsai created KAFKA-10014:
--
Summary: Always try to close all channels in Selector#close
Key: KAFKA-10014
URL: https://issues.apache.org/jira/browse/KAFKA-10014
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-8398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17109987#comment-17109987
]
Chia-Ping Tsai commented on KAFKA-8398:
---
seems
https://github.com/apache/kafka/com
[
https://issues.apache.org/jira/browse/KAFKA-9893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Cheng Tan updated KAFKA-9893:
-
Description:
This issue has two parts:
# Support transportation layer connection timeout described in KI
[
https://issues.apache.org/jira/browse/KAFKA-9893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Cheng Tan updated KAFKA-9893:
-
Description:
This issue has two parts:
# Support transportation layer connection timeout described in KI
[
https://issues.apache.org/jira/browse/KAFKA-9845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
victor updated KAFKA-9845:
--
Comment: was deleted
(was: [~ alexlumpov]人名提及某人..)
> plugin.path property does not work with config provid
[
https://issues.apache.org/jira/browse/KAFKA-9845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110023#comment-17110023
]
victor commented on KAFKA-9845:
---
[~ alexlumpov]人名提及某人..
> plugin.path property does no
chia7712 opened a new pull request #8685:
URL: https://github.com/apache/kafka/pull/8685
https://issues.apache.org/jira/browse/KAFKA-10014
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build statu
[
https://issues.apache.org/jira/browse/KAFKA-9981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110047#comment-17110047
]
victor commented on KAFKA-9981:
---
[~ChrisEgerton] [~ryannedolan] hi.
In case of dedicated m
qq619618919 commented on pull request #8656:
URL: https://github.com/apache/kafka/pull/8656#issuecomment-630040397
> I'm still not sure what is going on here. What does it mean to update the
config if !isLeader()? Only the leader actually has a config store.
The following links，Chris
brary commented on a change in pull request #8395:
URL: https://github.com/apache/kafka/pull/8395#discussion_r426485550
##
File path: docs/upgrade.html
##
@@ -39,7 +39,8 @@ Notable changes in 2
https://github.com/apache/kafka/tree/2.5/examples";>examples folder.
Check
chia7712 commented on pull request #8517:
URL: https://github.com/apache/kafka/pull/8517#issuecomment-630066071
```EmbeddedKafkaCluster``` created by Stream UT uses ```MockTime``` to
create ```KafkaServer```(
https://github.com/apache/kafka/blob/trunk/streams/src/test/java/org/apache/ka
avalsa commented on a change in pull request #8221:
URL: https://github.com/apache/kafka/pull/8221#discussion_r426498753
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/PartitionGroup.java
##
@@ -93,6 +96,28 @@ long partitionTimestamp(final Top
avalsa commented on a change in pull request #8221:
URL: https://github.com/apache/kafka/pull/8221#discussion_r426498877
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/PartitionGroup.java
##
@@ -93,6 +96,28 @@ long partitionTimestamp(final Top
avalsa commented on a change in pull request #8221:
URL: https://github.com/apache/kafka/pull/8221#discussion_r426499189
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/Task.java
##
@@ -170,6 +170,8 @@ public boolean isValidTransition(final Sta
[
https://issues.apache.org/jira/browse/KAFKA-4748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110133#comment-17110133
]
Antony Stubbs commented on KAFKA-4748:
--
FYI [~mjsax], my intention for Kafka-6943 wa
[
https://issues.apache.org/jira/browse/KAFKA-4748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110133#comment-17110133
]
Antony Stubbs edited comment on KAFKA-4748 at 5/18/20, 10:47 AM:
--
[
https://issues.apache.org/jira/browse/KAFKA-6182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110137#comment-17110137
]
Antony Stubbs commented on KAFKA-6182:
--
Ah yes that makes sense. Assuming the except
showuon opened a new pull request #8686:
URL: https://github.com/apache/kafka/pull/8686
Remove redundant TOC and introduction in Running Streams Applications
before:
showuon commented on pull request #8686:
URL: https://github.com/apache/kafka/pull/8686#issuecomment-630148688
@guozhangwang , a small documentation update PR in streams page. Please help
review. Thanks.
This is an automated
cadonna commented on a change in pull request #8669:
URL: https://github.com/apache/kafka/pull/8669#discussion_r426592363
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorContextImpl.java
##
@@ -16,87 +16,129 @@
*/
package org.apache
cadonna commented on pull request #8157:
URL: https://github.com/apache/kafka/pull/8157#issuecomment-630245364
@pierDipi FYI: We need to make some changes to the
`InternalProcessorContext` that are needed for two high priority tickets. The
changes are done in PR #8669. The changes affect a
lbradstreet commented on pull request #8517:
URL: https://github.com/apache/kafka/pull/8517#issuecomment-630249725
> `EmbeddedKafkaCluster` created by Stream UT uses `MockTime` to create
`KafkaServer`(
>
https://github.com/apache/kafka/blob/trunk/streams/src/test/java/org/apache/kafka/s
ableegoldman commented on a change in pull request #8669:
URL: https://github.com/apache/kafka/pull/8669#discussion_r426700737
##
File path:
streams/src/test/java/org/apache/kafka/test/InternalMockProcessorContext.java
##
@@ -52,6 +54,8 @@
import java.util.List;
import java.
Bruno Cadonna created KAFKA-10015:
-
Summary: React to Unexpected Errors on Stream Threads
Key: KAFKA-10015
URL: https://issues.apache.org/jira/browse/KAFKA-10015
Project: Kafka
Issue Type: Im
[
https://issues.apache.org/jira/browse/KAFKA-10015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna updated KAFKA-10015:
--
Summary: React Smartly to Unexpected Errors on Stream Threads (was: React
to Unexpected Error
[
https://issues.apache.org/jira/browse/KAFKA-10015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna reassigned KAFKA-10015:
-
Assignee: Bruno Cadonna
> React Smartly to Unexpected Errors on Stream Threads
> --
[
https://issues.apache.org/jira/browse/KAFKA-10015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna updated KAFKA-10015:
--
Labels: needs-kip (was: )
> React Smartly to Unexpected Errors on Stream Threads
> --
[
https://issues.apache.org/jira/browse/KAFKA-10015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna updated KAFKA-10015:
--
Affects Version/s: 2.5.0
> React Smartly to Unexpected Errors on Stream Threads
>
mumrah commented on a change in pull request #8376:
URL: https://github.com/apache/kafka/pull/8376#discussion_r426722927
##
File path: clients/src/test/java/org/apache/kafka/clients/MetadataTest.java
##
@@ -378,26 +382,6 @@ public void testRejectOldMetadata() {
}
vvcephei commented on pull request #8682:
URL: https://github.com/apache/kafka/pull/8682#issuecomment-630272579
Test this please
This is an automated message from the Apache Git Service.
To respond to the message, please log
guozhangwang commented on pull request #8221:
URL: https://github.com/apache/kafka/pull/8221#issuecomment-630279061
test this please
This is an automated message from the Apache Git Service.
To respond to the message, please
guozhangwang merged pull request #8686:
URL: https://github.com/apache/kafka/pull/8686
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 #8221:
URL: https://github.com/apache/kafka/pull/8221#issuecomment-630297298
test this please
This is an automated message from the Apache Git Service.
To respond to the message,
guozhangwang commented on a change in pull request #8669:
URL: https://github.com/apache/kafka/pull/8669#discussion_r426754892
##
File path:
streams/src/test/java/org/apache/kafka/test/InternalMockProcessorContext.java
##
@@ -349,6 +353,27 @@ public Headers headers() {
guozhangwang commented on pull request #8669:
URL: https://github.com/apache/kafka/pull/8669#issuecomment-630299683
test this please
This is an automated message from the Apache Git Service.
To respond to the message, please
guozhangwang commented on pull request #8669:
URL: https://github.com/apache/kafka/pull/8669#issuecomment-630299873
LGTM. Will merge after green builds.
This is an automated message from the Apache Git Service.
To respond to
[
https://issues.apache.org/jira/browse/KAFKA-6520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110447#comment-17110447
]
Guozhang Wang commented on KAFKA-6520:
--
Just to throw some more ideas here: the embe
guozhangwang commented on pull request #8669:
URL: https://github.com/apache/kafka/pull/8669#issuecomment-630320804
test this please
This is an automated message from the Apache Git Service.
To respond to the message,
guozhangwang commented on pull request #8221:
URL: https://github.com/apache/kafka/pull/8221#issuecomment-630321714
`:streams:spotbugsMain` failed, cc @avalsa
You can run the command locally to find out which sptobugMain rule is
violated.
--
[
https://issues.apache.org/jira/browse/KAFKA-10008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-10008:
---
Assignee: Matthias J. Sax
> Symbol not found when running Kafka Streams with RocksD
mjsax opened a new pull request #8687:
URL: https://github.com/apache/kafka/pull/8687
With https://issues.apache.org/jira/browse/KAFKA-9225 Kafka Streams 2.6.0
requires MacOS 10.15.
This is an automated message from the Apac
mjsax commented on pull request #8687:
URL: https://github.com/apache/kafka/pull/8687#issuecomment-630327661
Call for review @ableegoldman @vcrfxia @guozhangwang
This is an automated message from the Apache Git Service.
To r
[
https://issues.apache.org/jira/browse/KAFKA-10008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110478#comment-17110478
]
Matthias J. Sax commented on KAFKA-10008:
-
Opened a PR to update the docs: https
[
https://issues.apache.org/jira/browse/KAFKA-10012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Navina Ramesh reassigned KAFKA-10012:
-
Assignee: Navina Ramesh
> Reducing memory overhead associated with strings in MetricNam
[
https://issues.apache.org/jira/browse/KAFKA-7870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110489#comment-17110489
]
Nicolas Martinez Varsi commented on KAFKA-7870:
---
Any news on this? We upgra
[
https://issues.apache.org/jira/browse/KAFKA-10008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-10008.
--
Resolution: Won't Fix
Following the other comments, we've decided just to document it.
> Symb
[
https://issues.apache.org/jira/browse/KAFKA-9981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110488#comment-17110488
]
Chris Egerton commented on KAFKA-9981:
--
[~qq619618919] we could but it wouldn't be s
[
https://issues.apache.org/jira/browse/KAFKA-9994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler reassigned KAFKA-9994:
---
Assignee: Boyang Chen
> Catch TaskMigrated exception in task corruption code path
> ---
[
https://issues.apache.org/jira/browse/KAFKA-9994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-9994.
-
Resolution: Fixed
> Catch TaskMigrated exception in task corruption code path
>
[
https://issues.apache.org/jira/browse/KAFKA-4748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110493#comment-17110493
]
Matthias J. Sax commented on KAFKA-4748:
Thanks for clarifying [~astubbs]
> Need
[
https://issues.apache.org/jira/browse/KAFKA-9989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler reassigned KAFKA-9989:
---
Assignee: Boyang Chen
> StreamsUpgradeTest.test_metadata_upgrade could not guarantee all pro
[
https://issues.apache.org/jira/browse/KAFKA-6182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110497#comment-17110497
]
Matthias J. Sax commented on KAFKA-6182:
Failing fast is not covered via KIP-221,
ableegoldman commented on pull request #8682:
URL: https://github.com/apache/kafka/pull/8682#issuecomment-630344469
Instead of removing the tasks during `handleLostAll`, can we just clear the
`lockedTaskDirectories` set at the end of
`releaseLockedUnassignedTaskDirectories`? This set is on
ableegoldman commented on a change in pull request #8622:
URL: https://github.com/apache/kafka/pull/8622#discussion_r426808431
##
File path: docs/streams/upgrade-guide.html
##
@@ -35,7 +35,7 @@ Upgrade Guide and API Changes
Upgrading from any older version to {
cmccabe commented on a change in pull request #8569:
URL: https://github.com/apache/kafka/pull/8569#discussion_r426808657
##
File path: core/src/main/scala/kafka/metrics/LinuxIoMetricsCollector.scala
##
@@ -0,0 +1,102 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF)
[
https://issues.apache.org/jira/browse/KAFKA-6579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110508#comment-17110508
]
Sophie Blee-Goldman commented on KAFKA-6579:
No, I looked into it but the sco
[
https://issues.apache.org/jira/browse/KAFKA-6579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman reassigned KAFKA-6579:
--
Assignee: (was: Sophie Blee-Goldman)
> Consolidate window store and sessio
cmccabe commented on pull request #8569:
URL: https://github.com/apache/kafka/pull/8569#issuecomment-630352959
@mumrah : Good question. I don't think anyone has looked at Sigar. I
guess the question is whether we want to get into the business of doing
general-purpose node monitoring. I
ijuma opened a new pull request #8688:
URL: https://github.com/apache/kafka/pull/8688
This is a bit odd in that it's not needed from a semantics perspective,
but it would make it much easier to distinguish the cost of follower
fetches versus consumer fetches when profiling.
###
[
https://issues.apache.org/jira/browse/KAFKA-10010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110518#comment-17110518
]
Sophie Blee-Goldman commented on KAFKA-10010:
-
It's possible the active <->
[
https://issues.apache.org/jira/browse/KAFKA-10010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110522#comment-17110522
]
Sophie Blee-Goldman commented on KAFKA-10010:
-
When I first started looking
guozhangwang commented on pull request #8669:
URL: https://github.com/apache/kafka/pull/8669#issuecomment-630370157
test this please
This is an automated message from the Apache Git Service.
To respond to the message, please
ijuma closed pull request #8688:
URL: https://github.com/apache/kafka/pull/8688
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 #8688:
URL: https://github.com/apache/kafka/pull/8688#issuecomment-630376046
Closing this for now as there may be a better way to achieve this.
This is an automated message from the Apache Git
apovzner commented on pull request #8650:
URL: https://github.com/apache/kafka/pull/8650#issuecomment-630379942
It looks like the build couldn't even run tests:
```
15:15:09 ERROR: Error cloning remote repo 'origin'
...
15:15:18 stderr: fatal: Unable to look up github.com (port 9
cmccabe commented on pull request #8675:
URL: https://github.com/apache/kafka/pull/8675#issuecomment-630389772
ok to test
This is an automated message from the Apache Git Service.
To respond to the message, please log on to G
ijuma commented on pull request #8684:
URL: https://github.com/apache/kafka/pull/8684#issuecomment-630391729
Thanks for the PR. Java's built in string interning mechanism is known to
have issues. Not sure we want to do that. Maybe we can remove that part of the
change from this PR?
-
ijuma commented on a change in pull request #8685:
URL: https://github.com/apache/kafka/pull/8685#discussion_r426850232
##
File path: clients/src/main/java/org/apache/kafka/common/network/Selector.java
##
@@ -363,23 +363,14 @@ public void wakeup() {
@Override
public v
ijuma commented on a change in pull request #8685:
URL: https://github.com/apache/kafka/pull/8685#discussion_r426850232
##
File path: clients/src/main/java/org/apache/kafka/common/network/Selector.java
##
@@ -363,23 +363,14 @@ public void wakeup() {
@Override
public v
mjsax merged pull request #8687:
URL: https://github.com/apache/kafka/pull/8687
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
David Mollitor created KAFKA-10016:
--
Summary: Support For Purge Topic
Key: KAFKA-10016
URL: https://issues.apache.org/jira/browse/KAFKA-10016
Project: Kafka
Issue Type: Improvement
hachikuji commented on a change in pull request #8238:
URL: https://github.com/apache/kafka/pull/8238#discussion_r426867775
##
File path: clients/src/main/resources/common/message/ListGroupsRequest.json
##
@@ -20,8 +20,14 @@
// Version 1 and 2 are the same as version 0.
/
abbccdda commented on a change in pull request #8680:
URL: https://github.com/apache/kafka/pull/8680#discussion_r426806321
##
File path: clients/src/main/java/org/apache/kafka/common/feature/Features.java
##
@@ -0,0 +1,143 @@
+package org.apache.kafka.common.feature;
+
+import
[
https://issues.apache.org/jira/browse/KAFKA-4327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110609#comment-17110609
]
Jorge Esteban Quilcate Otoya commented on KAFKA-4327:
-
[~mjsax] [~guo
Sophie Blee-Goldman created KAFKA-10017:
---
Summary: Flaky Test
EosBetaUpgradeIntegrationTest.shouldUpgradeFromEosAlphaToEosBeta[true]
Key: KAFKA-10017
URL: https://issues.apache.org/jira/browse/KAFKA-10017
cmccabe merged pull request #8569:
URL: https://github.com/apache/kafka/pull/8569
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
[
https://issues.apache.org/jira/browse/KAFKA-9292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Colin McCabe resolved KAFKA-9292.
-
Fix Version/s: 2.6.0
Resolution: Fixed
> KIP-551: Expose disk read and write metrics
> ---
navina commented on pull request #8684:
URL: https://github.com/apache/kafka/pull/8684#issuecomment-630444877
@ijuma What issues with intern are you referring to? I know that there can
be a performance hit when there are a lot of intern strings. I believe string
interning mechanism has bee
[
https://issues.apache.org/jira/browse/KAFKA-10017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110633#comment-17110633
]
Sophie Blee-Goldman commented on KAFKA-10017:
-
h3. Stacktrace
java.lang.Ass
navina edited a comment on pull request #8684:
URL: https://github.com/apache/kafka/pull/8684#issuecomment-630444877
@ijuma What issues with `intern()` are you referring to? I know that there
can be a performance hit when there are a lot of intern strings. I believe
string interning mechan
[
https://issues.apache.org/jira/browse/KAFKA-10010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110636#comment-17110636
]
Boyang Chen commented on KAFKA-10010:
-
Had offline discussion with the team, so far
[
https://issues.apache.org/jira/browse/KAFKA-10017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman updated KAFKA-10017:
Summary: Flaky Test
EosBetaUpgradeIntegrationTest.shouldUpgradeFromEosAlphaToEosBe
[
https://issues.apache.org/jira/browse/KAFKA-10017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110633#comment-17110633
]
Sophie Blee-Goldman edited comment on KAFKA-10017 at 5/18/20, 9:36 PM:
---
[
https://issues.apache.org/jira/browse/KAFKA-10017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman updated KAFKA-10017:
Description:
Creating a new ticket for this since the root cause is different than
ableegoldman commented on pull request #8669:
URL: https://github.com/apache/kafka/pull/8669#issuecomment-630448469
Failed due to flaky
`EosBetaUpgradeIntegrationTest.shouldUpgradeFromEosAlphaToEosBeta` and
`ConnectorTopicsIntegrationTest.testGetActiveTopics`
[
https://issues.apache.org/jira/browse/KAFKA-10010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110638#comment-17110638
]
Boyang Chen commented on KAFKA-10010:
-
For more context, the
[reason|[https://githu
guozhangwang merged pull request #8669:
URL: https://github.com/apache/kafka/pull/8669
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
[
https://issues.apache.org/jira/browse/KAFKA-7271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110643#comment-17110643
]
Bill Bejeck commented on KAFKA-7271:
[~mjsax] I don't think I'll have time for this o
[
https://issues.apache.org/jira/browse/KAFKA-7271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck reassigned KAFKA-7271:
--
Assignee: (was: Bill Bejeck)
> Fix ignored test in streams_upgrade_test.py: test_upgrade_d
cadonna opened a new pull request #8689:
URL: https://github.com/apache/kafka/pull/8689
Unit tests
-
shouldAssignActiveStatefulTasksEvenlyOverClientsAndStreamThreadsWithMoreStreamThreadsThanTasks()
-
shouldAssignWarmUpTasksIfStatefulActiveTasksBalancedOverStreamThreadsButNotOverClien
cadonna commented on pull request #8689:
URL: https://github.com/apache/kafka/pull/8689#issuecomment-630467234
Call for review: @vvcephei @ableegoldman
This is an automated message from the Apache Git Service.
To respond to
cadonna commented on a change in pull request #8689:
URL: https://github.com/apache/kafka/pull/8689#discussion_r426924669
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/HighAvailabilityTaskAssignorTest.java
##
@@ -170,7 +171,7 @@ pu
[
https://issues.apache.org/jira/browse/KAFKA-10010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-10010:
Summary: Should make state store registration idempotent (was: Should
close standby task for safe
[
https://issues.apache.org/jira/browse/KAFKA-9989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-9989:
---
Description:
System test StreamsUpgradeTest.test_metadata_upgrade could fail due to:
"Never saw outp
[
https://issues.apache.org/jira/browse/KAFKA-9989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen reassigned KAFKA-9989:
--
Assignee: (was: Boyang Chen)
> StreamsUpgradeTest.test_metadata_upgrade could not guarante
[
https://issues.apache.org/jira/browse/KAFKA-9989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-9989:
---
Labels: newbie (was: )
> StreamsUpgradeTest.test_metadata_upgrade could not guarantee all processor
[
https://issues.apache.org/jira/browse/KAFKA-9989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-9989:
---
Description:
System test StreamsUpgradeTest.test_metadata_upgrade could fail due to:
"Never saw outp
cmccabe opened a new pull request #8690:
URL: https://github.com/apache/kafka/pull/8690
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
xiaodongdu opened a new pull request #8691:
URL: https://github.com/apache/kafka/pull/8691
Implement KIP-606, add metadata context to MetricsReporter:
Added a new api to MetricsReporter to allow client to expose additional
metadata fields to reporter plugin. Added an interface MetricsCon
1 - 100 of 156 matches
Mail list logo
