mdedetrich commented on code in PR #12475:
URL: https://github.com/apache/kafka/pull/12475#discussion_r958078922
##
checkstyle/.scalafmt.conf:
##
@@ -12,7 +12,10 @@
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific
mdedetrich commented on PR #12475:
URL: https://github.com/apache/kafka/pull/12475#issuecomment-1231234530
> I've kicked off another Jenkins run to see if we can get at least one
green build with Scala 2.12.
So Jenkins did in fact pass this PR as green build. I have just pushed to
th
mdedetrich commented on code in PR #12475:
URL: https://github.com/apache/kafka/pull/12475#discussion_r958078922
##
checkstyle/.scalafmt.conf:
##
@@ -12,7 +12,10 @@
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific
songnon commented on PR #12543:
URL: https://github.com/apache/kafka/pull/12543#issuecomment-1231238770
Update the code and commit message. It looks like partitions being
reassigned can also benefit from auto preferred leader election
--
This is an automated message from the Apache Git Se
showuon commented on PR #12059:
URL: https://github.com/apache/kafka/pull/12059#issuecomment-1231240877
Let's wait for the test results :)
--
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 spec
showuon closed pull request #11822: [WIP] MINOR: add test
URL: https://github.com/apache/kafka/pull/11822
--
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 specific comment.
To unsubscribe, e-mail
showuon closed pull request #11444: [WIP] Kafka 13406: fix for v2.8
URL: https://github.com/apache/kafka/pull/11444
--
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 specific comment.
To unsubscri
showuon closed pull request #9104: KAFKA-10266: Update the connector config
header.converter
URL: https://github.com/apache/kafka/pull/9104
--
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 specif
showuon closed pull request #10773: [WIP] MINOR: Working in progress
URL: https://github.com/apache/kafka/pull/10773
--
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 specific comment.
To unsubscr
showuon closed pull request #11206: MINOR: Update streams doc to close
KeyValueIterator in example code
URL: https://github.com/apache/kafka/pull/11206
--
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 t
[
https://issues.apache.org/jira/browse/KAFKA-14173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guido Josquin updated KAFKA-14173:
--
Description:
I am trying to test a stream-stream join with `TopologyTestDriver`. My goal is
t
[
https://issues.apache.org/jira/browse/KAFKA-14173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guido Josquin updated KAFKA-14173:
--
Summary: TopologyTestDriver does not use mock wall clock time when sending
test records (was:
[
https://issues.apache.org/jira/browse/KAFKA-14173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guido Josquin updated KAFKA-14173:
--
Description:
I am trying to test a stream-stream join with `TopologyTestDriver`. My goal is
t
vpapavas commented on code in PR #12555:
URL: https://github.com/apache/kafka/pull/12555#discussion_r958320960
##
streams/src/main/java/org/apache/kafka/streams/kstream/internals/InternalStreamsBuilder.java:
##
@@ -270,16 +272,20 @@ private void maybeAddNodeForOptimizationMetada
vpapavas commented on code in PR #12555:
URL: https://github.com/apache/kafka/pull/12555#discussion_r958321621
##
streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java:
##
@@ -663,6 +663,12 @@ public class StreamsConfig extends AbstractConfig {
public static fin
cadonna commented on code in PR #12459:
URL: https://github.com/apache/kafka/pull/12459#discussion_r958373716
##
streams/src/test/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetricsRecorderTest.java:
##
@@ -70,105 +73,133 @@ public class RocksDBMetricsRecorderTe
C0urante commented on code in PR #12475:
URL: https://github.com/apache/kafka/pull/12475#discussion_r958380812
##
checkstyle/.scalafmt.conf:
##
@@ -12,7 +12,10 @@
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific la
C0urante commented on PR #11783:
URL: https://github.com/apache/kafka/pull/11783#issuecomment-1231565587
@showuon @mimaison @tombentley any chance we could revisit this soon? I
think we've probably missed the 3.3.0 boat but it'd be nice to get this in just
to have the testing framework avai
C0urante commented on PR #12475:
URL: https://github.com/apache/kafka/pull/12475#issuecomment-1231567747
@vvcephei @cadonna would either of you have time to double-check this quick
Scalafmt bump?
--
This is an automated message from the Apache Git Service.
To respond to the message, pleas
cadonna commented on code in PR #12459:
URL: https://github.com/apache/kafka/pull/12459#discussion_r958391930
##
streams/src/test/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetricsRecorderTest.java:
##
@@ -381,157 +395,115 @@ public void
shouldThrowIfValueProv
Junyang Liu created KAFKA-14189:
---
Summary: reuse connection of coordinator and leader in
KafkaConsumer
Key: KAFKA-14189
URL: https://issues.apache.org/jira/browse/KAFKA-14189
Project: Kafka
Is
[
https://issues.apache.org/jira/browse/KAFKA-14189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Junyang Liu updated KAFKA-14189:
Summary: connection count limit of coordinator and leader in KafkaConsumer
(was: reuse connection
[
https://issues.apache.org/jira/browse/KAFKA-14189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Junyang Liu updated KAFKA-14189:
Summary: improve connection limit and reuse of coordinator and leader in
KafkaConsumer (was: conn
[
https://issues.apache.org/jira/browse/KAFKA-14189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Junyang Liu updated KAFKA-14189:
Description:
The connection id of connection with coordinator in KafkaConsumer is
Integer.MAX_VAL
[
https://issues.apache.org/jira/browse/KAFKA-14189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Junyang Liu updated KAFKA-14189:
Summary: Improve connection limit and reuse of coordinator and leader in
KafkaConsumer (was: impr
[
https://issues.apache.org/jira/browse/KAFKA-14189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Junyang Liu updated KAFKA-14189:
Description:
The connection id of connection with coordinator in KafkaConsumer is
Integer.MAX_VAL
[
https://issues.apache.org/jira/browse/KAFKA-14189?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17597851#comment-17597851
]
Von Gosling commented on KAFKA-14189:
-
I'd like to hear some suggestions from [~junr
[
https://issues.apache.org/jira/browse/KAFKA-14189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Junyang Liu updated KAFKA-14189:
Description:
The connection id of connection with coordinator in KafkaConsumer is
Integer.MAX_VAL
Alexandre Dupriez created KAFKA-14190:
-
Summary: Corruption of Topic IDs with pre-2.8.0 admin clients
Key: KAFKA-14190
URL: https://issues.apache.org/jira/browse/KAFKA-14190
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-14189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Junyang Liu updated KAFKA-14189:
Description:
The connection id of connection with coordinator in KafkaConsumer is
Integer.MAX_VAL
[
https://issues.apache.org/jira/browse/KAFKA-14190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexandre Dupriez updated KAFKA-14190:
--
Description:
h3. Scope
The problem reported below has been verified to occur in Zooke
[
https://issues.apache.org/jira/browse/KAFKA-14190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexandre Dupriez updated KAFKA-14190:
--
Description:
h3. Scope
The problem reported below has been verified to occur in Zooke
[
https://issues.apache.org/jira/browse/KAFKA-14190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexandre Dupriez updated KAFKA-14190:
--
Description:
h3. Scope
The problem reported below has been verified to occur in Zooke
[
https://issues.apache.org/jira/browse/KAFKA-14190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexandre Dupriez updated KAFKA-14190:
--
Summary: Corruption of Topic IDs with pre-2.8.0 ZK admin clients (was:
Corruption of
[
https://issues.apache.org/jira/browse/KAFKA-14190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexandre Dupriez updated KAFKA-14190:
--
Description:
h3. Scope
The problem reported below has been verified to occur in Zooke
[
https://issues.apache.org/jira/browse/KAFKA-14190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexandre Dupriez updated KAFKA-14190:
--
Description:
h3. Scope
The problem reported below has been verified to occur in Zooke
[
https://issues.apache.org/jira/browse/KAFKA-14190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexandre Dupriez updated KAFKA-14190:
--
Affects Version/s: 2.8.0
> Corruption of Topic IDs with pre-2.8.0 ZK admin clients
> -
[
https://issues.apache.org/jira/browse/KAFKA-5337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17597900#comment-17597900
]
Rajesh commented on KAFKA-5337:
---
[~grantneale] Are we planning to add this feature. It woul
divijvaidya commented on code in PR #12459:
URL: https://github.com/apache/kafka/pull/12459#discussion_r958565181
##
streams/src/test/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetricsRecorderTest.java:
##
@@ -381,157 +395,115 @@ public void
shouldThrowIfValue
Jorge Esteban Quilcate Otoya created KAFKA-14191:
Summary: Add end-to-end latency metrics to Connectors
Key: KAFKA-14191
URL: https://issues.apache.org/jira/browse/KAFKA-14191
Project:
[
https://issues.apache.org/jira/browse/KAFKA-14190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexandre Dupriez updated KAFKA-14190:
--
Description:
h3. Scope
The problem reported below has been verified to occur in Zooke
[
https://issues.apache.org/jira/browse/KAFKA-14190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexandre Dupriez updated KAFKA-14190:
--
Description:
h3. Scope
The problem reported below has been verified to occur in Zooke
[
https://issues.apache.org/jira/browse/KAFKA-14190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17597928#comment-17597928
]
Ismael Juma edited comment on KAFKA-14190 at 8/30/22 3:11 PM:
[
https://issues.apache.org/jira/browse/KAFKA-14190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17597928#comment-17597928
]
Ismael Juma commented on KAFKA-14190:
-
Thanks for the JIRA. To clarify, the issue is
[
https://issues.apache.org/jira/browse/KAFKA-14190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17597928#comment-17597928
]
Ismael Juma edited comment on KAFKA-14190 at 8/30/22 3:13 PM:
[
https://issues.apache.org/jira/browse/KAFKA-14190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17597928#comment-17597928
]
Ismael Juma edited comment on KAFKA-14190 at 8/30/22 3:14 PM:
[
https://issues.apache.org/jira/browse/KAFKA-14190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17597928#comment-17597928
]
Ismael Juma edited comment on KAFKA-14190 at 8/30/22 3:14 PM:
[
https://issues.apache.org/jira/browse/KAFKA-14190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17597935#comment-17597935
]
Ismael Juma commented on KAFKA-14190:
-
{quote}The ID of a topic is lost when an Admi
[
https://issues.apache.org/jira/browse/KAFKA-14182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17597950#comment-17597950
]
Svyatoslav commented on KAFKA-14182:
[~showuon] on a latest trunk branch some other
[
https://issues.apache.org/jira/browse/KAFKA-14156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jose Armando Garcia Sancio updated KAFKA-14156:
---
Fix Version/s: 3.3.0
> Built-in partitioner may create suboptimal ba
[
https://issues.apache.org/jira/browse/KAFKA-14187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jose Armando Garcia Sancio updated KAFKA-14187:
---
Fix Version/s: 3.3.0
> kafka-features.sh: add support for --metadata
jsancio commented on PR #11786:
URL: https://github.com/apache/kafka/pull/11786#issuecomment-1231900372
Yeah @showuon . I'll cherry pick this to the 3.3 branch.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL a
cmccabe commented on code in PR #12571:
URL: https://github.com/apache/kafka/pull/12571#discussion_r958710277
##
docs/upgrade.html:
##
@@ -61,8 +61,27 @@ Upgrading to
3.3.0 from any vers
+Upgrading a KRaft-based
cluster to 3.3.0 from any version 3.0.x through 3.2.x
+
guozhangwang commented on code in PR #12569:
URL: https://github.com/apache/kafka/pull/12569#discussion_r958716921
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java:
##
@@ -1180,6 +1182,68 @@ void shutdown(final boolean clean) {
}
C0urante commented on code in PR #12543:
URL: https://github.com/apache/kafka/pull/12543#discussion_r958619212
##
core/src/test/scala/unit/kafka/controller/ControllerIntegrationTest.scala:
##
@@ -490,6 +490,41 @@ class ControllerIntegrationTest extends QuorumTestHarness {
cadonna commented on PR #12459:
URL: https://github.com/apache/kafka/pull/12459#issuecomment-1231952039
The test failures are unrelated:
```
Build / JDK 8 and Scala 2.12 /
org.apache.kafka.controller.QuorumControllerTest.testDelayedConfigurationOperations()
Build / JDK 11 and Scala
cadonna merged PR #12459:
URL: https://github.com/apache/kafka/pull/12459
--
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 specific comment.
To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.
[
https://issues.apache.org/jira/browse/KAFKA-14190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17597994#comment-17597994
]
Alexandre Dupriez commented on KAFKA-14190:
---
Hi Ismael,
Thanks for the follow
[
https://issues.apache.org/jira/browse/KAFKA-14190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17597994#comment-17597994
]
Alexandre Dupriez edited comment on KAFKA-14190 at 8/30/22 5:49 PM:
--
[
https://issues.apache.org/jira/browse/KAFKA-14174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jose Armando Garcia Sancio updated KAFKA-14174:
---
Affects Version/s: 3.3.0
> Operation documentation for KRaft
> -
[
https://issues.apache.org/jira/browse/KAFKA-14188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jose Armando Garcia Sancio updated KAFKA-14188:
---
Fix Version/s: 3.3.0
> Quickstart for KRaft
>
>
[
https://issues.apache.org/jira/browse/KAFKA-14174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jose Armando Garcia Sancio updated KAFKA-14174:
---
Fix Version/s: 3.3.0
> Operation documentation for KRaft
> -
[
https://issues.apache.org/jira/browse/KAFKA-14179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jose Armando Garcia Sancio updated KAFKA-14179:
---
Fix Version/s: 3.3.0
> Improve docs/upgrade.html to talk about metad
[
https://issues.apache.org/jira/browse/KAFKA-14188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jose Armando Garcia Sancio updated KAFKA-14188:
---
Affects Version/s: 3.3.0
> Quickstart for KRaft
> --
[
https://issues.apache.org/jira/browse/KAFKA-14170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Akhilesh Chaganti resolved KAFKA-14170.
---
Resolution: Fixed
> KRaft Controller: Possible NPE when we remove topics with any of
[
https://issues.apache.org/jira/browse/KAFKA-14179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jose Armando Garcia Sancio updated KAFKA-14179:
---
Affects Version/s: 3.3.0
> Improve docs/upgrade.html to talk about m
guozhangwang commented on code in PR #12555:
URL: https://github.com/apache/kafka/pull/12555#discussion_r958780670
##
streams/src/main/java/org/apache/kafka/streams/kstream/internals/InternalStreamsBuilder.java:
##
@@ -270,16 +272,20 @@ private void maybeAddNodeForOptimizationMe
dtwitty opened a new pull request, #12572:
URL: https://github.com/apache/kafka/pull/12572
TICKET = LIKAFKA-44865
LI_DESCRIPTION =
Whenever the fetch session has a cache miss on the broker, the client logs
FETCH_SESSION_ID_NOT_FOUND at the `info` level. This message isn't actionable
t
dtwitty commented on PR #12572:
URL: https://github.com/apache/kafka/pull/12572#issuecomment-1232010612
Clearly something has gone screwy with this PR. Closing to fix it.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
dtwitty closed pull request #12572: [LI-HOTFIX] Downgrade
FETCH_SESSION_ID_NOT_FOUND logging from info to debug
URL: https://github.com/apache/kafka/pull/12572
--
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
[
https://issues.apache.org/jira/browse/KAFKA-12835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17598006#comment-17598006
]
Sergey Ivanov commented on KAFKA-12835:
---
Hi All,
It seems this ticket already sol
[
https://issues.apache.org/jira/browse/KAFKA-13077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17598009#comment-17598009
]
Sergey Ivanov commented on KAFKA-13077:
---
Hi,
we faced the same issue with Kafka 2
[
https://issues.apache.org/jira/browse/KAFKA-13077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17598009#comment-17598009
]
Sergey Ivanov edited comment on KAFKA-13077 at 8/30/22 6:41 PM:
--
[
https://issues.apache.org/jira/browse/KAFKA-13036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Divij Vaidya updated KAFKA-13036:
-
Fix Version/s: 3.4.0
> Replace EasyMock and PowerMock with Mockito for RocksDBMetricsRecorderTes
mumrah commented on code in PR #12571:
URL: https://github.com/apache/kafka/pull/12571#discussion_r958851048
##
clients/src/main/java/org/apache/kafka/clients/admin/SupportedVersionRange.java:
##
@@ -36,10 +36,10 @@ public class SupportedVersionRange {
* @throws IllegalArg
cmccabe commented on code in PR #12571:
URL: https://github.com/apache/kafka/pull/12571#discussion_r958914091
##
clients/src/main/java/org/apache/kafka/clients/admin/SupportedVersionRange.java:
##
@@ -36,10 +36,10 @@ public class SupportedVersionRange {
* @throws IllegalAr
[
https://issues.apache.org/jira/browse/KAFKA-14154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17598086#comment-17598086
]
Artem Livshits commented on KAFKA-14154:
> 1. Broker 1 loses its session in Zook
guozhangwang commented on code in PR #12555:
URL: https://github.com/apache/kafka/pull/12555#discussion_r958991975
##
streams/src/main/java/org/apache/kafka/streams/kstream/internals/InternalStreamsBuilder.java:
##
@@ -270,16 +272,20 @@ private void maybeAddNodeForOptimizationMe
[
https://issues.apache.org/jira/browse/KAFKA-5337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17598108#comment-17598108
]
Grant Neale commented on KAFKA-5337:
There is no plan to implement this as a core fea
cmccabe merged PR #12571:
URL: https://github.com/apache/kafka/pull/12571
--
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 specific comment.
To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.
[
https://issues.apache.org/jira/browse/KAFKA-14187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Colin McCabe resolved KAFKA-14187.
--
Resolution: Fixed
> kafka-features.sh: add support for --metadata
> --
showuon commented on PR #11786:
URL: https://github.com/apache/kafka/pull/11786#issuecomment-1232357443
Thank you, @jsancio and @dengziming !
--
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 s
[
https://issues.apache.org/jira/browse/KAFKA-13404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Anupam Aggarwal reassigned KAFKA-13404:
---
Assignee: Anupam Aggarwal
> Kafka sink connectors do not commit offset correctly if
[
https://issues.apache.org/jira/browse/KAFKA-13631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Anupam Aggarwal reassigned KAFKA-13631:
---
Assignee: Anupam Aggarwal
> Warning "Ignoring await stop request for non-present co
songnon commented on code in PR #12543:
URL: https://github.com/apache/kafka/pull/12543#discussion_r959153232
##
core/src/test/scala/unit/kafka/controller/ControllerIntegrationTest.scala:
##
@@ -490,6 +490,41 @@ class ControllerIntegrationTest extends QuorumTestHarness {
[
https://issues.apache.org/jira/browse/KAFKA-13386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17598168#comment-17598168
]
Luke Jackson commented on KAFKA-13386:
--
Thanks [~guozhang] for the detail, and expl
86 matches
Mail list logo
