kkonstantine commented on a change in pull request #9780:
URL: https://github.com/apache/kafka/pull/9780#discussion_r570747258
##
File path:
connect/runtime/src/test/java/org/apache/kafka/connect/util/SharedTopicAdminTest.java
##
@@ -0,0 +1,118 @@
+/*
+ * Licensed to the Apach
kkonstantine commented on a change in pull request #9780:
URL: https://github.com/apache/kafka/pull/9780#discussion_r570728906
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/util/SharedTopicAdmin.java
##
@@ -0,0 +1,145 @@
+/*
+ * Licensed to the Apache So
wcarlson5 commented on pull request #10060:
URL: https://github.com/apache/kafka/pull/10060#issuecomment-773820050
+1 from me. Thanks for the pr
This is an automated message from the Apache Git Service.
To respond to the mess
hachikuji commented on a change in pull request #10045:
URL: https://github.com/apache/kafka/pull/10045#discussion_r570730096
##
File path: core/src/main/scala/kafka/server/MetadataSupport.scala
##
@@ -0,0 +1,109 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) unde
kkonstantine commented on a change in pull request #9780:
URL: https://github.com/apache/kafka/pull/9780#discussion_r570732565
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java
##
@@ -185,16 +188,33 @@
privat
hachikuji commented on a change in pull request #10045:
URL: https://github.com/apache/kafka/pull/10045#discussion_r570727037
##
File path: core/src/main/scala/kafka/server/MetadataSupport.scala
##
@@ -0,0 +1,109 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) unde
bob-barrett commented on pull request #10065:
URL: https://github.com/apache/kafka/pull/10065#issuecomment-773800777
This is a backport of 131d475 to 2.4. As with #10061, the conflicts were due
to the missing connection timeout config, which was added in 2.7, and didn't
meaningfully change
bob-barrett commented on pull request #10067:
URL: https://github.com/apache/kafka/pull/10067#issuecomment-773800834
This is a backport of 131d475 to 2.3. As with #10061, the conflicts were due
to the missing connection timeout config, which was added in 2.7, and didn't
meaningfully change
bob-barrett opened a new pull request #10067:
URL: https://github.com/apache/kafka/pull/10067
This patch changes the NetworkClient behavior to resolve the target node's
hostname after disconnecting from an established connection, rather than
waiting until the previously-resolved addresses
mjsax commented on a change in pull request #9744:
URL: https://github.com/apache/kafka/pull/9744#discussion_r570716520
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractProcessorContext.java
##
@@ -45,7 +45,6 @@
private boolean init
mjsax commented on a change in pull request #9744:
URL: https://github.com/apache/kafka/pull/9744#discussion_r570716520
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractProcessorContext.java
##
@@ -45,7 +45,6 @@
private boolean init
hachikuji opened a new pull request #10066:
URL: https://github.com/apache/kafka/pull/10066
With KIP-500, we have more complex requirements on API accessibility.
Previously all APIs were accessible on every listener exposed by the broker,
but now that is no longer true. For example:
mjsax merged pull request #10048:
URL: https://github.com/apache/kafka/pull/10048
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
mjsax commented on pull request #1:
URL: https://github.com/apache/kafka/pull/1#issuecomment-773774753
Updated this PR.
This is an automated message from the Apache Git Service.
To respond to the message, please log o
mjsax commented on a change in pull request #10048:
URL: https://github.com/apache/kafka/pull/10048#discussion_r570698424
##
File path: docs/streams/upgrade-guide.html
##
@@ -121,6 +121,12 @@ Streams API
the constructor, such as when using the console consumer. https:/
mjsax commented on a change in pull request #10048:
URL: https://github.com/apache/kafka/pull/10048#discussion_r570698397
##
File path: docs/streams/upgrade-guide.html
##
@@ -121,6 +121,12 @@ Streams API
the constructor, such as when using the console consumer. https:/
JimGalasyn commented on a change in pull request #10048:
URL: https://github.com/apache/kafka/pull/10048#discussion_r570687920
##
File path: docs/streams/upgrade-guide.html
##
@@ -121,6 +121,12 @@ Streams API
the constructor, such as when using the console consumer. ht
mjsax commented on a change in pull request #1:
URL: https://github.com/apache/kafka/pull/1#discussion_r570695899
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java
##
@@ -227,6 +230,27 @@ public void initializeIfNeeded() {
mjsax commented on a change in pull request #1:
URL: https://github.com/apache/kafka/pull/1#discussion_r570691793
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java
##
@@ -227,6 +230,27 @@ public void initializeIfNeeded() {
mjsax merged pull request #9997:
URL: https://github.com/apache/kafka/pull/9997
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the
[
https://issues.apache.org/jira/browse/KAFKA-7540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17279291#comment-17279291
]
Matthias J. Sax commented on KAFKA-7540:
[https://github.com/apache/kafka/pull/99
JimGalasyn commented on a change in pull request #10048:
URL: https://github.com/apache/kafka/pull/10048#discussion_r570687920
##
File path: docs/streams/upgrade-guide.html
##
@@ -121,6 +121,12 @@ Streams API
the constructor, such as when using the console consumer. ht
JimGalasyn commented on a change in pull request #10048:
URL: https://github.com/apache/kafka/pull/10048#discussion_r570687710
##
File path: docs/streams/upgrade-guide.html
##
@@ -121,6 +121,12 @@ Streams API
the constructor, such as when using the console consumer. ht
mjsax merged pull request #10044:
URL: https://github.com/apache/kafka/pull/10044
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-12283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17279288#comment-17279288
]
Matthias J. Sax commented on KAFKA-12283:
-
Failed again:
https://github.com/apa
mjsax merged pull request #10046:
URL: https://github.com/apache/kafka/pull/10046
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
mjsax commented on a change in pull request #10046:
URL: https://github.com/apache/kafka/pull/10046#discussion_r570683354
##
File path: docs/streams/developer-guide/memory-mgmt.html
##
@@ -168,7 +168,15 @@
RocksDB
Each instance of RocksDB allocates off-heap memor
bob-barrett opened a new pull request #10065:
URL: https://github.com/apache/kafka/pull/10065
This patch changes the NetworkClient behavior to resolve the target node's
hostname after disconnecting from an established connection, rather than
waiting until the previously-resolved addresses
bob-barrett commented on pull request #10064:
URL: https://github.com/apache/kafka/pull/10064#issuecomment-773736235
This is a backport of 131d4753cfed65ed6dee0a8c754765c97c3d513f to 2.5. As
with https://github.com/apache/kafka/pull/10061, the conflicts were due to the
missing connection t
bob-barrett opened a new pull request #10064:
URL: https://github.com/apache/kafka/pull/10064
This patch changes the NetworkClient behavior to resolve the target node's
hostname after disconnecting from an established connection, rather than
waiting until the previously-resolved addresses
jsancio opened a new pull request #10063:
URL: https://github.com/apache/kafka/pull/10063
1. Type `BatchAccumulator`. Add support for appending records into one or
more batches.
2. Type `RaftClient`. Rename `scheduleAppend` to `scheduleAtomicAppend`.
3. Type `RaftClient`. Add a new me
rhauch commented on a change in pull request #9780:
URL: https://github.com/apache/kafka/pull/9780#discussion_r570657028
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/util/SharedTopicAdmin.java
##
@@ -0,0 +1,145 @@
+/*
+ * Licensed to the Apache Software
rhauch commented on a change in pull request #9780:
URL: https://github.com/apache/kafka/pull/9780#discussion_r570655008
##
File path:
connect/runtime/src/test/java/org/apache/kafka/connect/util/SharedTopicAdminTest.java
##
@@ -0,0 +1,118 @@
+/*
+ * Licensed to the Apache Soft
abbccdda commented on a change in pull request #9579:
URL: https://github.com/apache/kafka/pull/9579#discussion_r570654953
##
File path: core/src/main/scala/kafka/server/KafkaApis.scala
##
@@ -1370,55 +1345,164 @@ class KafkaApis(val requestChannel: RequestChannel,
!au
Henry Cai created KAFKA-12295:
-
Summary: Shallow Mirroring
Key: KAFKA-12295
URL: https://issues.apache.org/jira/browse/KAFKA-12295
Project: Kafka
Issue Type: Improvement
Components: con
rhauch commented on a change in pull request #9780:
URL: https://github.com/apache/kafka/pull/9780#discussion_r570652791
##
File path:
connect/runtime/src/test/java/org/apache/kafka/connect/util/TopicAdminTest.java
##
@@ -457,17 +465,273 @@ public void verifyingGettingTopicCle
kkonstantine merged pull request #10053:
URL: https://github.com/apache/kafka/pull/10053
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 g
kkonstantine merged pull request #9726:
URL: https://github.com/apache/kafka/pull/9726
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
kkonstantine commented on pull request #9726:
URL: https://github.com/apache/kafka/pull/9726#issuecomment-773706451
One failure on an unrelated flaky test
Merging to coordinate merge with another PR. Thanks @mimaison !
Thi
rhauch commented on a change in pull request #9780:
URL: https://github.com/apache/kafka/pull/9780#discussion_r570648556
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java
##
@@ -185,16 +188,33 @@
private fina
mjsax commented on pull request #9107:
URL: https://github.com/apache/kafka/pull/9107#issuecomment-773692994
Merged to `trunk`.
Congrats for getting this into the 2.8.0 release @inponomarev -- great work!
This is an au
mjsax merged pull request #9107:
URL: https://github.com/apache/kafka/pull/9107
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
rodesai commented on a change in pull request #10046:
URL: https://github.com/apache/kafka/pull/10046#discussion_r570627385
##
File path: docs/streams/developer-guide/memory-mgmt.html
##
@@ -168,7 +168,15 @@
RocksDB
Each instance of RocksDB allocates off-heap mem
gardnervickers closed pull request #10058:
URL: https://github.com/apache/kafka/pull/10058
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
gardnervickers closed pull request #10057:
URL: https://github.com/apache/kafka/pull/10057
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
gardnervickers closed pull request #10055:
URL: https://github.com/apache/kafka/pull/10055
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
bob-barrett commented on pull request #10055:
URL: https://github.com/apache/kafka/pull/10055#issuecomment-773678966
@ableegoldman the 2.6 backport is
https://github.com/apache/kafka/pull/10061.
This is an automated message
szpak opened a new pull request #10062:
URL: https://github.com/apache/kafka/pull/10062
That method intends to increase a chance to have KeyValueIterator closed
after usage, by providing a convenient performAndClose() default method which
executes a given operation and guarantee to aut
bob-barrett commented on pull request #10061:
URL: https://github.com/apache/kafka/pull/10061#issuecomment-773678032
@dajac This is the backport of
https://github.com/apache/kafka/commit/131d4753cfed65ed6dee0a8c754765c97c3d513f.
The conflicts were because the connection timeout settings ad
bob-barrett opened a new pull request #10061:
URL: https://github.com/apache/kafka/pull/10061
This patch changes the NetworkClient behavior to resolve the target node's
hostname after disconnecting from an established connection, rather than
waiting until the previously-resolved addresses
gardnervickers commented on pull request #10055:
URL: https://github.com/apache/kafka/pull/10055#issuecomment-773675865
@ableegoldman I believe @bob-barrett was working on a PR against 2.6.
This is an automated message from
ableegoldman commented on pull request #10055:
URL: https://github.com/apache/kafka/pull/10055#issuecomment-773675180
Hey @gardnervickers , do you have plans to open a PR against 2.6 as well?
Just checking in since it seems this fix has been ported to everything except
2.6 so far and I wan
ableegoldman opened a new pull request #10060:
URL: https://github.com/apache/kafka/pull/10060
Port of https://github.com/apache/kafka/pull/9978 to the 2.7 branch
This is an automated message from the Apache Git Service.
To r
dpoldrugo commented on pull request #10059:
URL: https://github.com/apache/kafka/pull/10059#issuecomment-773663807
@ijuma, @omkreddy, @rajinisivaram could you take a look?
This is an automated message from the Apache Git Serv
rohitrmd commented on a change in pull request #9744:
URL: https://github.com/apache/kafka/pull/9744#discussion_r570605728
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractProcessorContext.java
##
@@ -45,7 +45,6 @@
private boolean i
kkonstantine commented on a change in pull request #9780:
URL: https://github.com/apache/kafka/pull/9780#discussion_r570584036
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java
##
@@ -209,7 +229,8 @@ public Distribu
cmccabe merged pull request #10030:
URL: https://github.com/apache/kafka/pull/10030
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
cmccabe commented on pull request #10030:
URL: https://github.com/apache/kafka/pull/10030#issuecomment-773648975
Test failure is
`org.apache.kafka.connect.mirror.integration.MirrorConnectorsIntegrationSSLTest`
which is not related.
C0urante commented on pull request #9726:
URL: https://github.com/apache/kafka/pull/9726#issuecomment-773648389
Just ran into a situation last night where this would have been super
helpful. Thanks for adding this @mimaison!
kkonstantine commented on a change in pull request #9726:
URL: https://github.com/apache/kafka/pull/9726#discussion_r570577845
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/resources/ConnectorsResource.java
##
@@ -188,6 +188,16 @@ public Con
dpoldrugo opened a new pull request #10059:
URL: https://github.com/apache/kafka/pull/10059
Description:
As suggested by @omkreddy in this
[comment](https://issues.apache.org/jira/browse/KAFKA-8562?focusedCommentId=16912437&page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tab
abbccdda commented on a change in pull request #9579:
URL: https://github.com/apache/kafka/pull/9579#discussion_r570568151
##
File path: core/src/main/scala/kafka/server/KafkaApis.scala
##
@@ -1084,24 +1087,9 @@ class KafkaApis(val requestChannel: RequestChannel,
(response
[
https://issues.apache.org/jira/browse/KAFKA-12294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-12294:
Component/s: core
> Consider using the forwarding mechanism for metadata auto topic creation
> ---
[
https://issues.apache.org/jira/browse/KAFKA-12294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-12294:
Parent: (was: KAFKA-9705)
Issue Type: Improvement (was: Sub-task)
> Consider using th
Boyang Chen created KAFKA-12294:
---
Summary: Consider using the forwarding mechanism for metadata auto
topic creation
Key: KAFKA-12294
URL: https://issues.apache.org/jira/browse/KAFKA-12294
Project: Kafka
gardnervickers opened a new pull request #10058:
URL: https://github.com/apache/kafka/pull/10058
The original PR was #9902
The reason for back-porting this improved test infrastructure is to address
some flakes which we have seen when kafka.apache.org DNS changes, specifically
in th
mimaison commented on a change in pull request #9726:
URL: https://github.com/apache/kafka/pull/9726#discussion_r570545828
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/resources/ConnectorsResource.java
##
@@ -188,6 +188,16 @@ public Connect
gardnervickers opened a new pull request #10057:
URL: https://github.com/apache/kafka/pull/10057
The original PR was #9902
The reason for back-porting this improved test infrastructure is to address
some flakes which we have seen when kafka.apache.org DNS changes, specifically
in th
[
https://issues.apache.org/jira/browse/KAFKA-12293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17279162#comment-17279162
]
Dejan Stojadinović commented on KAFKA-12293:
Note: at the moment I am not su
hachikuji merged pull request #10005:
URL: https://github.com/apache/kafka/pull/10005
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
dejan2609 opened a new pull request #10056:
URL: https://github.com/apache/kafka/pull/10056
Related jira ticket:
https://issues.apache.org/jira/browse/KAFKA-12293 **_Remove JCenter and
Bintray repositories mentions out of Gradle build (sunset is announced for
those repositories)_**
gardnervickers opened a new pull request #10055:
URL: https://github.com/apache/kafka/pull/10055
The original PR was #9902
The reason for back-porting this improved test infrastructure is to address
some flakes which we have seen when kafka.apache.org DNS changes, specifically
in t
ableegoldman commented on a change in pull request #1:
URL: https://github.com/apache/kafka/pull/1#discussion_r570535029
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java
##
@@ -227,6 +230,27 @@ public void initializeIfNee
Dejan Stojadinović created KAFKA-12293:
--
Summary: Remove JCenter and Bintray repositories mentions out of
Gradle build (sunset is announced for those repositories)
Key: KAFKA-12293
URL: https://issues.apache.
chia7712 commented on pull request #10054:
URL: https://github.com/apache/kafka/pull/10054#issuecomment-773582456
@ramesh-muthusamy Could you take a look? thanks!
This is an automated message from the Apache Git Service.
To r
chia7712 opened a new pull request #10054:
URL: https://github.com/apache/kafka/pull/10054
issue: https://issues.apache.org/jira/browse/KAFKA-12283
It seems to me the new tasks distribution (8, 4, 4) is valid if following
conditions are true.
1. all tasks are assigned to (single)
[
https://issues.apache.org/jira/browse/KAFKA-12284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai reassigned KAFKA-12284:
--
Assignee: (was: Chia-Ping Tsai)
> Flaky Test
> MirrorConnectorsIntegrationSSLTes
[
https://issues.apache.org/jira/browse/KAFKA-12283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai reassigned KAFKA-12283:
--
Assignee: Chia-Ping Tsai
> Flaky Test
> RebalanceSourceConnectorsIntegrationTest#tes
[
https://issues.apache.org/jira/browse/KAFKA-12284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai reassigned KAFKA-12284:
--
Assignee: Chia-Ping Tsai
> Flaky Test
> MirrorConnectorsIntegrationSSLTest#testOneWa
kkonstantine commented on a change in pull request #9726:
URL: https://github.com/apache/kafka/pull/9726#discussion_r570505650
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/resources/ConnectorsResource.java
##
@@ -188,6 +188,16 @@ public Con
jsancio commented on a change in pull request #10045:
URL: https://github.com/apache/kafka/pull/10045#discussion_r570507065
##
File path: core/src/main/scala/kafka/server/MetadataSupport.scala
##
@@ -0,0 +1,109 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under
mimaison commented on pull request #9726:
URL: https://github.com/apache/kafka/pull/9726#issuecomment-773567218
Thanks @kkonstantine for the feedback. I've pushed an update
This is an automated message from the Apache Git Ser
ableegoldman commented on a change in pull request #1:
URL: https://github.com/apache/kafka/pull/1#discussion_r570495244
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java
##
@@ -227,6 +230,27 @@ public void initializeIfNee
abbccdda commented on a change in pull request #9579:
URL: https://github.com/apache/kafka/pull/9579#discussion_r570492431
##
File path: core/src/main/scala/kafka/server/KafkaApis.scala
##
@@ -1234,19 +1171,28 @@ class KafkaApis(val requestChannel: RequestChannel,
// In ve
abbccdda commented on a change in pull request #9579:
URL: https://github.com/apache/kafka/pull/9579#discussion_r570492221
##
File path: core/src/main/scala/kafka/server/AutoTopicCreationManager.scala
##
@@ -0,0 +1,139 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
[
https://issues.apache.org/jira/browse/KAFKA-12279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17279097#comment-17279097
]
prabhu biradar commented on KAFKA-12279:
Hi Sophie Blee-Goldman,
1) This error
vvcephei commented on pull request #9107:
URL: https://github.com/apache/kafka/pull/9107#issuecomment-773549603
Thanks, all, that Scala fix looks perfect to me.
This is an automated message from the Apache Git Service.
To res
abbccdda commented on a change in pull request #9579:
URL: https://github.com/apache/kafka/pull/9579#discussion_r570480399
##
File path: core/src/main/scala/kafka/server/KafkaApis.scala
##
@@ -1234,19 +1171,28 @@ class KafkaApis(val requestChannel: RequestChannel,
// In ve
mumrah commented on a change in pull request #10049:
URL: https://github.com/apache/kafka/pull/10049#discussion_r570474971
##
File path: core/src/test/scala/unit/kafka/server/MetadataCacheTest.scala
##
@@ -483,61 +475,4 @@ class MetadataCacheTest {
assertEquals(initialBrok
mumrah commented on a change in pull request #10049:
URL: https://github.com/apache/kafka/pull/10049#discussion_r570474971
##
File path: core/src/test/scala/unit/kafka/server/MetadataCacheTest.scala
##
@@ -483,61 +475,4 @@ class MetadataCacheTest {
assertEquals(initialBrok
kkonstantine commented on a change in pull request #10053:
URL: https://github.com/apache/kafka/pull/10053#discussion_r570464187
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java
##
@@ -236,7 +236,7 @@ public Distri
cmccabe merged pull request #10019:
URL: https://github.com/apache/kafka/pull/10019
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
jsancio commented on a change in pull request #10030:
URL: https://github.com/apache/kafka/pull/10030#discussion_r570367570
##
File path: metadata/src/main/java/org/apache/kafka/queue/KafkaEventQueue.java
##
@@ -0,0 +1,420 @@
+/*
+ * Licensed to the Apache Software Foundation (
jsancio commented on a change in pull request #10030:
URL: https://github.com/apache/kafka/pull/10030#discussion_r570462338
##
File path: metadata/src/main/java/org/apache/kafka/queue/KafkaEventQueue.java
##
@@ -0,0 +1,420 @@
+/*
+ * Licensed to the Apache Software Foundation (
junrao commented on a change in pull request #10030:
URL: https://github.com/apache/kafka/pull/10030#discussion_r570453181
##
File path: metadata/src/main/java/org/apache/kafka/queue/EventQueue.java
##
@@ -0,0 +1,263 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) u
cmccabe commented on pull request #10047:
URL: https://github.com/apache/kafka/pull/10047#issuecomment-773516371
Test failures are not related to the PR
This is an automated message from the Apache Git Service.
To respond to
mumrah commented on a change in pull request #10049:
URL: https://github.com/apache/kafka/pull/10049#discussion_r570451366
##
File path: core/src/test/scala/unit/kafka/server/MetadataCacheTest.scala
##
@@ -483,61 +475,4 @@ class MetadataCacheTest {
assertEquals(initialBrok
cmccabe commented on a change in pull request #10030:
URL: https://github.com/apache/kafka/pull/10030#discussion_r570450458
##
File path: metadata/src/main/java/org/apache/kafka/queue/KafkaEventQueue.java
##
@@ -0,0 +1,420 @@
+/*
+ * Licensed to the Apache Software Foundation (
cmccabe commented on a change in pull request #10030:
URL: https://github.com/apache/kafka/pull/10030#discussion_r570442555
##
File path: metadata/src/main/java/org/apache/kafka/queue/KafkaEventQueue.java
##
@@ -0,0 +1,420 @@
+/*
+ * Licensed to the Apache Software Foundation (
[
https://issues.apache.org/jira/browse/KAFKA-7271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna resolved KAFKA-7271.
--
Resolution: Duplicate
> Fix ignored test in streams_upgrade_test.py: test_upgrade_downgrade_bro
1 - 100 of 154 matches
Mail list logo