[
https://issues.apache.org/jira/browse/KAFKA-9774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109910#comment-17109910
]
Jordan Moore commented on KAFKA-9774:
-
Done here
akatona84 commented on a change in pull request #8673:
URL: https://github.com/apache/kafka/pull/8673#discussion_r426401253
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/utils/EmbeddedKafkaCluster.java
##
@@ -297,6 +295,15 @@ public void
akatona84 commented on a change in pull request #8673:
URL: https://github.com/apache/kafka/pull/8673#discussion_r426401253
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/utils/EmbeddedKafkaCluster.java
##
@@ -297,6 +295,15 @@ public void
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
akatona84 commented on pull request #8673:
URL: https://github.com/apache/kafka/pull/8673#issuecomment-629983824
retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please
[
https://issues.apache.org/jira/browse/KAFKA-8398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109987#comment-17109987
]
Chia-Ping Tsai commented on KAFKA-8398:
---
seems
abbccdda commented on a change in pull request #8221:
URL: https://github.com/apache/kafka/pull/8221#discussion_r426377894
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/Task.java
##
@@ -170,6 +170,8 @@ public boolean isValidTransition(final
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
akatona84 commented on a change in pull request #8673:
URL: https://github.com/apache/kafka/pull/8673#discussion_r426402078
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/utils/EmbeddedKafkaCluster.java
##
@@ -314,8 +321,7 @@ private
[
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
[
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
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 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
[
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
[
https://issues.apache.org/jira/browse/KAFKA-9845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110023#comment-17110023
]
victor commented on KAFKA-9845:
---
[~ alexlumpov]人名提及某人..
> plugin.path property does not work with
[
https://issues.apache.org/jira/browse/KAFKA-9981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110047#comment-17110047
]
victor commented on KAFKA-9981:
---
[~ChrisEgerton] [~ryannedolan] hi.
In case of dedicated mm2 clusters, If
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
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
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
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```(
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
[
https://issues.apache.org/jira/browse/KAFKA-4748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110133#comment-17110133
]
Antony Stubbs edited comment on KAFKA-4748 at 5/18/20, 10:47 AM:
-
FYI
[
https://issues.apache.org/jira/browse/KAFKA-4748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110133#comment-17110133
]
Antony Stubbs commented on KAFKA-4748:
--
FYI [~mjsax], my intention for Kafka-6943 was for a single
[
https://issues.apache.org/jira/browse/KAFKA-6182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110137#comment-17110137
]
Antony Stubbs commented on KAFKA-6182:
--
Ah yes that makes sense. Assuming the exception thrown when
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?
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
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
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
[
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
>
[
https://issues.apache.org/jira/browse/KAFKA-10017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110633#comment-17110633
]
Sophie Blee-Goldman commented on KAFKA-10017:
-
h3. Stacktrace
java.lang.AssertionError: Did
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
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=17110638#comment-17110638
]
Boyang Chen commented on KAFKA-10010:
-
For more context, the
[
https://issues.apache.org/jira/browse/KAFKA-10017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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
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
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
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.
[
https://issues.apache.org/jira/browse/KAFKA-4327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110609#comment-17110609
]
Jorge Esteban Quilcate Otoya commented on KAFKA-4327:
-
[~mjsax] [~guozhang] I'd like
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
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
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
[
https://issues.apache.org/jira/browse/KAFKA-10010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110636#comment-17110636
]
Boyang Chen commented on KAFKA-10010:
-
Had offline discussion with the team, so far some action
[
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
[
https://issues.apache.org/jira/browse/KAFKA-7271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110643#comment-17110643
]
Bill Bejeck commented on KAFKA-7271:
[~mjsax] I don't think I'll have time for this one, so I've
[
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:
cadonna opened a new pull request #8689:
URL: https://github.com/apache/kafka/pull/8689
Unit tests
-
shouldAssignActiveStatefulTasksEvenlyOverClientsAndStreamThreadsWithMoreStreamThreadsThanTasks()
-
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 @@
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
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-7870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110489#comment-17110489
]
Nicolas Martinez Varsi commented on KAFKA-7870:
---
Any news on this? We upgraded from 2.0.0
[
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.
>
[
https://issues.apache.org/jira/browse/KAFKA-9981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110488#comment-17110488
]
Chris Egerton commented on KAFKA-9981:
--
[~qq619618919] we could but it wouldn't be simple. We'd have
[
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
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
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
[
https://issues.apache.org/jira/browse/KAFKA-10010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110518#comment-17110518
]
Sophie Blee-Goldman commented on KAFKA-10010:
-
It's possible the active <-> standby task
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
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
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
[
https://issues.apache.org/jira/browse/KAFKA-6520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110447#comment-17110447
]
Guozhang Wang commented on KAFKA-6520:
--
Just to throw some more ideas here: the embedded clients are
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
[
https://issues.apache.org/jira/browse/KAFKA-4748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110493#comment-17110493
]
Matthias J. Sax commented on KAFKA-4748:
Thanks for clarifying [~astubbs]
> Need a way to
[
https://issues.apache.org/jira/browse/KAFKA-6182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110497#comment-17110497
]
Matthias J. Sax commented on KAFKA-6182:
Failing fast is not covered via KIP-221, but there are
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
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
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
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.
[
https://issues.apache.org/jira/browse/KAFKA-10010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110522#comment-17110522
]
Sophie Blee-Goldman commented on KAFKA-10010:
-
When I first started looking into the store
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 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-630320804
test this please
This is an automated message from the Apache Git Service.
To respond to the
[
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
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.
###
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
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
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
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
[
https://issues.apache.org/jira/browse/KAFKA-10008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110478#comment-17110478
]
Matthias J. Sax commented on KAFKA-10008:
-
Opened a PR to update the docs:
[
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-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-6579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110508#comment-17110508
]
Sophie Blee-Goldman commented on KAFKA-6579:
No, I looked into it but the scope its
[
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
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
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
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:
[
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:
--
Summary: React Smartly to Unexpected Errors on Stream Threads (was: React
to Unexpected
[
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:
--
Affects Version/s: 2.5.0
> React Smartly to Unexpected Errors on Stream Threads
>
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:
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() {
}
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
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`(
>
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
1 - 100 of 156 matches
Mail list logo
