[
https://issues.apache.org/jira/browse/KAFKA-10176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Smolinski resolved KAFKA-10176.
-
Resolution: Won't Fix
Closing, as the feature has been deprecated in Kafka 0.9 and the p
[
https://issues.apache.org/jira/browse/KAFKA-10176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17140272#comment-17140272
]
Piotr Smolinski commented on KAFKA-10176:
-
I raised the corresponding ticket for
chia7712 closed pull request #8385:
URL: https://github.com/apache/kafka/pull/8385
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 t
chia7712 closed pull request #8098:
URL: https://github.com/apache/kafka/pull/8098
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 t
chia7712 closed pull request #8202:
URL: https://github.com/apache/kafka/pull/8202
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 t
chia7712 closed pull request #8078:
URL: https://github.com/apache/kafka/pull/8078
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 t
[
https://issues.apache.org/jira/browse/KAFKA-10179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17140208#comment-17140208
]
Matthias J. Sax commented on KAFKA-10179:
-
What you say is fair I guess. Given t
[
https://issues.apache.org/jira/browse/KAFKA-9509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17140203#comment-17140203
]
Matthias J. Sax commented on KAFKA-9509:
[https://builds.apache.org/job/kafka-pr-
mjsax commented on pull request #8886:
URL: https://github.com/apache/kafka/pull/8886#issuecomment-646427756
Java 8 passed.
Java 11:
```
org.apache.kafka.connect.mirror.MirrorConnectorsIntegrationTest.testReplication
```
[
https://issues.apache.org/jira/browse/KAFKA-9846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17140193#comment-17140193
]
Sophie Blee-Goldman commented on KAFKA-9846:
Just realized I never replied [~
[
https://issues.apache.org/jira/browse/KAFKA-7271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman updated KAFKA-7271:
---
Fix Version/s: (was: 2.6.0)
2.7.0
> Fix ignored test in stream
ableegoldman commented on a change in pull request #8900:
URL: https://github.com/apache/kafka/pull/8900#discussion_r442619557
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java
##
@@ -69,7 +68,6 @@
private final ChangelogRea
ableegoldman commented on a change in pull request #8900:
URL: https://github.com/apache/kafka/pull/8900#discussion_r442619459
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java
##
@@ -522,7 +522,7 @@ private void close(final boole
hachikuji merged pull request #8850:
URL: https://github.com/apache/kafka/pull/8850
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
[
https://issues.apache.org/jira/browse/KAFKA-10179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17140166#comment-17140166
]
Rohan Desai commented on KAFKA-10179:
-
Also, it's not really clear from the document
[
https://issues.apache.org/jira/browse/KAFKA-9974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17140162#comment-17140162
]
Luke Chen commented on KAFKA-9974:
--
I don't have thought on fixing the errors. See if an
[
https://issues.apache.org/jira/browse/KAFKA-9974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen reassigned KAFKA-9974:
Assignee: (was: Luke Chen)
> Flaky Test OptimizedKTableIntegrationTest#shouldApplyUpdatesToSta
[
https://issues.apache.org/jira/browse/KAFKA-10179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17140158#comment-17140158
]
Rohan Desai edited comment on KAFKA-10179 at 6/19/20, 3:19 AM:
---
[
https://issues.apache.org/jira/browse/KAFKA-10179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17140158#comment-17140158
]
Rohan Desai commented on KAFKA-10179:
-
Deserialization may itself be a transformatio
showuon edited a comment on pull request #8894:
URL: https://github.com/apache/kafka/pull/8894#issuecomment-646406717
@ryannedolan @skaundinya15 , thanks for your good suggestion. Yes, what I
did to add retries is the same as increasing the timeout value.
And I found the `waitForCon
showuon commented on pull request #8894:
URL: https://github.com/apache/kafka/pull/8894#issuecomment-646406717
@ryannedolan @skaundinya15 , thanks for your good suggestion. Yes, what I
did to add retries is the same as increasing the timeout value. And after some
investigation, I found the
[
https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17140138#comment-17140138
]
harsha commented on KAFKA-7500:
---
Hi,
Does Mirror maker 2 support Kafka version 0.10.0.0 ?
[
https://issues.apache.org/jira/browse/KAFKA-10184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17140089#comment-17140089
]
Sophie Blee-Goldman commented on KAFKA-10184:
-
This is all pretty pathetic l
[
https://issues.apache.org/jira/browse/KAFKA-10184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17140088#comment-17140088
]
John Roesler commented on KAFKA-10184:
--
What in the world... How can we not have pr
[
https://issues.apache.org/jira/browse/KAFKA-10113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson resolved KAFKA-10113.
-
Fix Version/s: 2.6.0
Resolution: Fixed
> LogTruncationException sets fetch offset
[
https://issues.apache.org/jira/browse/KAFKA-10113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson updated KAFKA-10113:
Affects Version/s: 2.5.0
2.4.1
> LogTruncationException sets fetch
hachikuji merged pull request #8822:
URL: https://github.com/apache/kafka/pull/8822
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
[
https://issues.apache.org/jira/browse/KAFKA-8266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17140082#comment-17140082
]
Matthias J. Sax commented on KAFKA-8266:
The other ticket is resolved, but I just
[
https://issues.apache.org/jira/browse/KAFKA-10186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arun R updated KAFKA-10186:
---
Comment: was deleted
(was: I would love to take a look if no one else is looking at it.)
> Aborting transac
mjsax commented on pull request #8886:
URL: https://github.com/apache/kafka/pull/8886#issuecomment-646376402
Retest this please.
This is an automated message from the Apache Git Service.
To respond to the message, please log
mjsax commented on pull request #8886:
URL: https://github.com/apache/kafka/pull/8886#issuecomment-646376357
Java 8 passed.
Java 11:
```
kafka.api.ConsumerBounceTest.testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup
```
mjsax commented on a change in pull request #8887:
URL: https://github.com/apache/kafka/pull/8887#discussion_r442574574
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java
##
@@ -1048,4 +1042,28 @@ public String toString(final Stri
mjsax commented on a change in pull request #8887:
URL: https://github.com/apache/kafka/pull/8887#discussion_r442574113
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java
##
@@ -741,29 +741,23 @@ void shutdown(final boolean clean)
[
https://issues.apache.org/jira/browse/KAFKA-10179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17140075#comment-17140075
]
Matthias J. Sax commented on KAFKA-10179:
-
{quote}I'm not sure it's correct to u
[
https://issues.apache.org/jira/browse/KAFKA-10179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17140075#comment-17140075
]
Matthias J. Sax edited comment on KAFKA-10179 at 6/19/20, 12:42 AM:
--
[
https://issues.apache.org/jira/browse/KAFKA-10114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17140073#comment-17140073
]
Jason Gustafson commented on KAFKA-10114:
-
[~ibinyami] Hmm, this is still not ve
hachikuji commented on pull request #8850:
URL: https://github.com/apache/kafka/pull/8850#issuecomment-646369171
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
hachikuji commented on pull request #8850:
URL: https://github.com/apache/kafka/pull/8850#issuecomment-646368944
retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please l
[
https://issues.apache.org/jira/browse/KAFKA-10186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17140069#comment-17140069
]
Arun R commented on KAFKA-10186:
I would love to take a look if no one else is looking a
mjsax commented on pull request #8752:
URL: https://github.com/apache/kafka/pull/8752#issuecomment-646367241
@sneakyburro Any update on this PR?
This is an automated message from the Apache Git Service.
To respond to the mess
mjsax commented on pull request #8871:
URL: https://github.com/apache/kafka/pull/8871#issuecomment-646365697
Retest this please.
This is an automated message from the Apache Git Service.
To respond to the message, please log
mumrah commented on pull request #8822:
URL: https://github.com/apache/kafka/pull/8822#issuecomment-646361035
Sounds good to me
This is an automated message from the Apache Git Service.
To respond to the message, please log o
vinothchandar commented on pull request #8898:
URL: https://github.com/apache/kafka/pull/8898#issuecomment-646360446
@cmccabe Please take a pass when you can..
This is an automated message from the Apache Git Service.
To res
ableegoldman opened a new pull request #8900:
URL: https://github.com/apache/kafka/pull/8900
If there's any pending data and we haven't flushed the producer when we
abort a transaction, a KafkaException is returned for the previous `send`. This
is a bit misleading, since the situation is n
[
https://issues.apache.org/jira/browse/KAFKA-10167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-10167.
---
Resolution: Fixed
> Streams EOS-Beta should not try to get end-offsets as read-committed
> -
hachikuji commented on pull request #8822:
URL: https://github.com/apache/kafka/pull/8822#issuecomment-646348733
@mumrah Hmm, I think I like the current approach of discarding the response
if we're no longer in the same state in which the fetch state was sent. Mainly
because it's simple. A
ijuma opened a new pull request #8899:
URL: https://github.com/apache/kafka/pull/8899
Most builds don't require test coverage output, so it's wasteful
to spend cycles tracking coverage information for each method
invoked.
I ran a quick test in a fast desktop machine, the absolut
mumrah commented on pull request #8822:
URL: https://github.com/apache/kafka/pull/8822#issuecomment-646338829
@hachikuji yea that's the check I was referring to (where we disregard the
fetch response, errors included). Do you think any of the errors we handle
besides OOOR are worth handlin
[
https://issues.apache.org/jira/browse/KAFKA-10186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman updated KAFKA-10186:
Labels: needs-kip newbie newbie++ (was: needs-kip)
> Aborting transaction with pe
cmccabe commented on a change in pull request #8891:
URL: https://github.com/apache/kafka/pull/8891#discussion_r442535630
##
File path: core/src/main/scala/kafka/controller/KafkaController.scala
##
@@ -647,8 +647,14 @@ class KafkaController(val config: KafkaConfig,
inf
[
https://issues.apache.org/jira/browse/KAFKA-10169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman reassigned KAFKA-10169:
---
Assignee: Sophie Blee-Goldman
> KafkaException: Failing batch since transac
Sophie Blee-Goldman created KAFKA-10186:
---
Summary: Aborting transaction with pending data should throw
non-fatal exception
Key: KAFKA-10186
URL: https://issues.apache.org/jira/browse/KAFKA-10186
vvcephei commented on a change in pull request #8896:
URL: https://github.com/apache/kafka/pull/8896#discussion_r442531300
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/StoreChangelogReaderTest.java
##
@@ -223,6 +227,7 @@ public void
shouldI
cmccabe commented on a change in pull request #8891:
URL: https://github.com/apache/kafka/pull/8891#discussion_r442533488
##
File path: core/src/main/scala/kafka/admin/ReassignPartitionsCommand.scala
##
@@ -1685,10 +1702,9 @@ object ReassignPartitionsCommand extends Logging {
cmccabe commented on pull request #8891:
URL: https://github.com/apache/kafka/pull/8891#issuecomment-646334265
The refactors to the tool generally look good. I thought we always allowed
throttles to be set to 0 for some reason, though? Looks like this change
removes that ability which we
vvcephei commented on a change in pull request #8896:
URL: https://github.com/apache/kafka/pull/8896#discussion_r442529975
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StoreChangelogReader.java
##
@@ -496,8 +539,9 @@ private void bufferChang
vinothchandar opened a new pull request #8898:
URL: https://github.com/apache/kafka/pull/8898
http://confluent-kafka-branch-builder-system-test-results.s3-us-west-2.amazonaws.com/2020-06-17--001.1592453352--vinothchandar--KC342-ducktape--e64cc463b/report.html
Both ThrottlingTest
dajac opened a new pull request #8897:
URL: https://github.com/apache/kafka/pull/8897
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including upgrade n
ConcurrencyPractitioner commented on pull request #8881:
URL: https://github.com/apache/kafka/pull/8881#issuecomment-646304787
@vvcephei Think you have time to look at this?
This is an automated message from the Apache Git Se
vvcephei commented on a change in pull request #8892:
URL: https://github.com/apache/kafka/pull/8892#discussion_r442497609
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignorTest.java
##
@@ -148,27 +150,35 @@
private f
vvcephei commented on pull request #8892:
URL: https://github.com/apache/kafka/pull/8892#issuecomment-646303241
test 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-10160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sats reassigned KAFKA-10160:
Assignee: sats
> Kafka MM2 consumer configuration
>
>
>
[
https://issues.apache.org/jira/browse/KAFKA-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17139963#comment-17139963
]
Mateusz Jadczyk commented on KAFKA-9891:
LGTM thanks for looking into it and maki
[
https://issues.apache.org/jira/browse/KAFKA-10185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17139955#comment-17139955
]
Boyang Chen commented on KAFKA-10185:
-
Could we add the context to this ticket?
> S
dajac commented on pull request #8672:
URL: https://github.com/apache/kafka/pull/8672#issuecomment-646271944
@hachikuji I just rebased and fixed the build issue. Could you re-trigger
jenkins please?
This is an automated mess
skaundinya15 commented on a change in pull request #8894:
URL: https://github.com/apache/kafka/pull/8894#discussion_r442445728
##
File path:
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorConnectorsIntegrationTest.java
##
@@ -207,23 +212,45 @@ public void c
[
https://issues.apache.org/jira/browse/KAFKA-10179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17139926#comment-17139926
]
Rohan Desai commented on KAFKA-10179:
-
I'm not sure it's correct to use the same "to
[
https://issues.apache.org/jira/browse/KAFKA-10005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17139925#comment-17139925
]
Sophie Blee-Goldman commented on KAFKA-10005:
-
Yeah, I didn't mean to imply
[
https://issues.apache.org/jira/browse/KAFKA-10005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17139533#comment-17139533
]
Guozhang Wang edited comment on KAFKA-10005 at 6/18/20, 6:58 PM:
-
[
https://issues.apache.org/jira/browse/KAFKA-10005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17139919#comment-17139919
]
Guozhang Wang commented on KAFKA-10005:
---
I think even if we only move standbys to
[
https://issues.apache.org/jira/browse/KAFKA-10005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17139916#comment-17139916
]
Sophie Blee-Goldman commented on KAFKA-10005:
-
I've been thinking about this
guozhangwang commented on pull request #8876:
URL: https://github.com/apache/kafka/pull/8876#issuecomment-646234217
Cherry-pick to 2.6.
This is an automated message from the Apache Git Service.
To respond to the message, plea
guozhangwang merged pull request #8876:
URL: https://github.com/apache/kafka/pull/8876
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
d8tltanc commented on pull request #8683:
URL: https://github.com/apache/kafka/pull/8683#issuecomment-646217062
Thanks, @dajac for the comments. I've modified the PR per your suggestions.
@rajinisivaram Do you think we can start testing?
vvcephei commented on a change in pull request #8896:
URL: https://github.com/apache/kafka/pull/8896#discussion_r442397523
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StoreChangelogReader.java
##
@@ -415,19 +418,20 @@ public void restore()
hachikuji commented on pull request #8891:
URL: https://github.com/apache/kafka/pull/8891#issuecomment-646209534
Had some discussion offline with @cmccabe . The intention in KIP-455 is to
use --additional to resubmit the reassignment and change the quota. I found
that this did not work as
d8tltanc commented on a change in pull request #8683:
URL: https://github.com/apache/kafka/pull/8683#discussion_r442394058
##
File path:
clients/src/main/java/org/apache/kafka/common/utils/GeometricProgression.java
##
@@ -0,0 +1,51 @@
+/*
+ * Licensed to the Apache Software Fo
d8tltanc commented on a change in pull request #8683:
URL: https://github.com/apache/kafka/pull/8683#discussion_r442389711
##
File path:
clients/src/main/java/org/apache/kafka/common/utils/GeometricProgression.java
##
@@ -0,0 +1,51 @@
+/*
+ * Licensed to the Apache Software Fo
vvcephei opened a new pull request #8896:
URL: https://github.com/apache/kafka/pull/8896
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including upgrad
d8tltanc commented on a change in pull request #8683:
URL: https://github.com/apache/kafka/pull/8683#discussion_r442387660
##
File path:
clients/src/test/java/org/apache/kafka/common/utils/GeometricProgressionTest.java
##
@@ -0,0 +1,45 @@
+/*
+ * Licensed to the Apache Softwar
John Roesler created KAFKA-10185:
Summary: Streams should log summarized restoration information at
info level
Key: KAFKA-10185
URL: https://issues.apache.org/jira/browse/KAFKA-10185
Project: Kafka
d8tltanc commented on a change in pull request #8683:
URL: https://github.com/apache/kafka/pull/8683#discussion_r442382471
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/AdminClientConfig.java
##
@@ -149,6 +155,16 @@
cmccabe commented on a change in pull request #8891:
URL: https://github.com/apache/kafka/pull/8891#discussion_r442378048
##
File path: core/src/main/scala/kafka/admin/ReassignPartitionsCommand.scala
##
@@ -930,6 +935,38 @@ object ReassignPartitionsCommand extends Logging {
d8tltanc commented on a change in pull request #8683:
URL: https://github.com/apache/kafka/pull/8683#discussion_r442375424
##
File path: clients/src/main/java/org/apache/kafka/clients/NetworkClient.java
##
@@ -786,6 +808,29 @@ private void handleAbortedSends(List
responses) {
d8tltanc commented on a change in pull request #8683:
URL: https://github.com/apache/kafka/pull/8683#discussion_r442372873
##
File path:
clients/src/main/java/org/apache/kafka/clients/CommonClientConfigs.java
##
@@ -103,6 +103,12 @@
Utils.join(SecurityProtocol.names()
hachikuji commented on pull request #8672:
URL: https://github.com/apache/kafka/pull/8672#issuecomment-646173735
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
hachikuji commented on pull request #8822:
URL: https://github.com/apache/kafka/pull/8822#issuecomment-646168538
retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please l
[
https://issues.apache.org/jira/browse/KAFKA-10184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17139548#comment-17139548
]
Sophie Blee-Goldman commented on KAFKA-10184:
-
Or instead (or in addition to
[
https://issues.apache.org/jira/browse/KAFKA-10184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17139546#comment-17139546
]
Sophie Blee-Goldman commented on KAFKA-10184:
-
[~vvcephei] Could we maybe do
edoardocomar commented on pull request #4204:
URL: https://github.com/apache/kafka/pull/4204#issuecomment-646162106
After @hachikuji fixes in https://github.com/apache/kafka/pull/8586
the metrics are no longer ticked at the end of a DelayedFetch, so the time
window for topic deletion is
[
https://issues.apache.org/jira/browse/KAFKA-10184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17139543#comment-17139543
]
Sophie Blee-Goldman commented on KAFKA-10184:
-
Yeah, it's failing on the set
d8tltanc commented on a change in pull request #8683:
URL: https://github.com/apache/kafka/pull/8683#discussion_r442363632
##
File path: clients/src/main/java/org/apache/kafka/clients/NetworkClient.java
##
@@ -678,7 +696,11 @@ public Node leastLoadedNode(long now) {
d8tltanc commented on a change in pull request #8683:
URL: https://github.com/apache/kafka/pull/8683#discussion_r442362673
##
File path:
clients/src/main/java/org/apache/kafka/clients/CommonClientConfigs.java
##
@@ -103,6 +103,12 @@
Utils.join(SecurityProtocol.names()
d8tltanc commented on a change in pull request #8683:
URL: https://github.com/apache/kafka/pull/8683#discussion_r442355123
##
File path:
clients/src/main/java/org/apache/kafka/clients/ClusterConnectionStates.java
##
@@ -357,6 +398,36 @@ private NodeConnectionState nodeState(St
d8tltanc commented on a change in pull request #8683:
URL: https://github.com/apache/kafka/pull/8683#discussion_r442355123
##
File path:
clients/src/main/java/org/apache/kafka/clients/ClusterConnectionStates.java
##
@@ -357,6 +398,36 @@ private NodeConnectionState nodeState(St
d8tltanc commented on a change in pull request #8683:
URL: https://github.com/apache/kafka/pull/8683#discussion_r442355123
##
File path:
clients/src/main/java/org/apache/kafka/clients/ClusterConnectionStates.java
##
@@ -357,6 +398,36 @@ private NodeConnectionState nodeState(St
[
https://issues.apache.org/jira/browse/KAFKA-10184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-10184:
--
Issue Type: Test (was: Bug)
> Flaky
> HighAvailabilityTaskAssignorIntegrationTest.shouldScal
[
https://issues.apache.org/jira/browse/KAFKA-10184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-10184:
--
Priority: Minor (was: Major)
> Flaky
> HighAvailabilityTaskAssignorIntegrationTest.shouldSca
Guozhang Wang created KAFKA-10184:
-
Summary: Flaky
HighAvailabilityTaskAssignorIntegrationTest.shouldScaleOutWithWarmupTasksAndPersistentStores
Key: KAFKA-10184
URL: https://issues.apache.org/jira/browse/KAFKA-101
d8tltanc commented on a change in pull request #8683:
URL: https://github.com/apache/kafka/pull/8683#discussion_r442355123
##
File path:
clients/src/main/java/org/apache/kafka/clients/ClusterConnectionStates.java
##
@@ -357,6 +398,36 @@ private NodeConnectionState nodeState(St
1 - 100 of 123 matches
Mail list logo
