dongjinleekr commented on pull request #10339:
URL: https://github.com/apache/kafka/pull/10339#issuecomment-800852370
@chia7712 Of course. Here it is.
+1. Congrats again for becoming a PMC member!
:congratulations::congratulations::congratulations:
-
tang7526 commented on a change in pull request #10332:
URL: https://github.com/apache/kafka/pull/10332#discussion_r595764290
##
File path:
clients/src/test/java/org/apache/kafka/common/requests/ProduceResponseTest.java
##
@@ -40,42 +41,39 @@
public void produceResponseV5T
tang7526 commented on a change in pull request #10332:
URL: https://github.com/apache/kafka/pull/10332#discussion_r595764290
##
File path:
clients/src/test/java/org/apache/kafka/common/requests/ProduceResponseTest.java
##
@@ -40,42 +41,39 @@
public void produceResponseV5T
tang7526 commented on a change in pull request #10332:
URL: https://github.com/apache/kafka/pull/10332#discussion_r595764290
##
File path:
clients/src/test/java/org/apache/kafka/common/requests/ProduceResponseTest.java
##
@@ -40,42 +41,39 @@
public void produceResponseV5T
showuon commented on pull request #10338:
URL: https://github.com/apache/kafka/pull/10338#issuecomment-800863820
@apurvam @hachikuji , could you review this PR? Thanks.
This is an automated message from the Apache Git Service
songShiPeng closed pull request #7251:
URL: https://github.com/apache/kafka/pull/7251
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
rodesai commented on a change in pull request #10317:
URL: https://github.com/apache/kafka/pull/10317#discussion_r595778710
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopicManager.java
##
@@ -580,4 +562,118 @@ private String getBro
wenbingshen commented on pull request #10329:
URL: https://github.com/apache/kafka/pull/10329#issuecomment-800877844
> Thanks for the patch. Left two minor stylistic comments.
Thank you for your comments, I have modified it, can you see see it again?
Thank you. :)
-
dajac commented on a change in pull request #10329:
URL: https://github.com/apache/kafka/pull/10329#discussion_r595805567
##
File path: core/src/main/scala/kafka/admin/ReassignPartitionsCommand.scala
##
@@ -1215,10 +1214,9 @@ object ReassignPartitionsCommand extends Logging {
wenbingshen commented on a change in pull request #10329:
URL: https://github.com/apache/kafka/pull/10329#discussion_r595820217
##
File path: core/src/main/scala/kafka/admin/ReassignPartitionsCommand.scala
##
@@ -1215,10 +1214,9 @@ object ReassignPartitionsCommand extends Loggi
[
https://issues.apache.org/jira/browse/KAFKA-10251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17303205#comment-17303205
]
Luke Chen commented on KAFKA-10251:
---
Found the root cause, which is we are bouncing br
cadonna commented on a change in pull request #10317:
URL: https://github.com/apache/kafka/pull/10317#discussion_r595843144
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopicManager.java
##
@@ -580,4 +562,118 @@ private String getBro
wenbingshen commented on pull request #10329:
URL: https://github.com/apache/kafka/pull/10329#issuecomment-800933272
> LGTM, pending Jenkins. Thanks!
Many thanks for your help!
This is an automated message from the Apa
[
https://issues.apache.org/jira/browse/KAFKA-12446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17303272#comment-17303272
]
Ben Ellis commented on KAFKA-12446:
---
[~ableegoldman] What would be involved in adding
chia7712 commented on a change in pull request #10334:
URL: https://github.com/apache/kafka/pull/10334#discussion_r595891567
##
File path:
metadata/src/test/java/org/apache/kafka/timeline/BaseHashTableTest.java
##
@@ -121,4 +121,19 @@ public void testExpansion() {
chia7712 commented on a change in pull request #10332:
URL: https://github.com/apache/kafka/pull/10332#discussion_r595897827
##
File path:
core/src/test/scala/integration/kafka/api/AuthorizerIntegrationTest.scala
##
@@ -155,10 +155,16 @@ class AuthorizerIntegrationTest extends
chia7712 merged pull request #10329:
URL: https://github.com/apache/kafka/pull/10329
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
chia7712 merged pull request #10339:
URL: https://github.com/apache/kafka/pull/10339
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
chia7712 closed pull request #10291:
URL: https://github.com/apache/kafka/pull/10291
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
dengziming created KAFKA-12489:
--
Summary: Flaky test
ControllerIntegrationTest.testPartitionReassignmentToBrokerWithOfflineLogDir
Key: KAFKA-12489
URL: https://issues.apache.org/jira/browse/KAFKA-12489
P
dengziming commented on pull request #10312:
URL: https://github.com/apache/kafka/pull/10312#issuecomment-801026082
Similar to #10262, ping @tombentley to have a look.
This is an automated message from the Apache Git Service.
dengziming removed a comment on pull request #10312:
URL: https://github.com/apache/kafka/pull/10312#issuecomment-799873639
Similar to #10262, ping @tombentley to have a look.
This is an automated message from the Apache Git
satishd commented on a change in pull request #10218:
URL: https://github.com/apache/kafka/pull/10218#discussion_r595954157
##
File path:
clients/src/main/java/org/apache/kafka/server/log/remote/storage/RemoteLogSegmentState.java
##
@@ -87,4 +89,27 @@ public byte id() {
p
satishd commented on a change in pull request #10218:
URL: https://github.com/apache/kafka/pull/10218#discussion_r596032415
##
File path:
remote-storage/src/main/java/org/apache/kafka/server/log/remote/storage/InmemoryRemoteLogMetadataManager.java
##
@@ -0,0 +1,185 @@
+/*
+ *
satishd commented on a change in pull request #10218:
URL: https://github.com/apache/kafka/pull/10218#discussion_r595954157
##
File path:
clients/src/main/java/org/apache/kafka/server/log/remote/storage/RemoteLogSegmentState.java
##
@@ -87,4 +89,27 @@ public byte id() {
p
[
https://issues.apache.org/jira/browse/KAFKA-12480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17303439#comment-17303439
]
Ron Dagostino commented on KAFKA-12480:
---
See relevant discussion in KAFKA-3068
>
satishd commented on a change in pull request #10218:
URL: https://github.com/apache/kafka/pull/10218#discussion_r595954157
##
File path:
clients/src/main/java/org/apache/kafka/server/log/remote/storage/RemoteLogSegmentState.java
##
@@ -87,4 +89,27 @@ public byte id() {
p
satishd commented on a change in pull request #10218:
URL: https://github.com/apache/kafka/pull/10218#discussion_r596055570
##
File path:
remote-storage/src/main/java/org/apache/kafka/server/log/remote/storage/RemoteLogMetadataCache.java
##
@@ -0,0 +1,172 @@
+/*
+ * Licensed t
rondagostino commented on a change in pull request #10292:
URL: https://github.com/apache/kafka/pull/10292#discussion_r596082828
##
File path: tests/kafkatest/tests/client/client_compatibility_features_test.py
##
@@ -79,14 +79,16 @@ def __init__(self, test_context):
satishd commented on a change in pull request #10218:
URL: https://github.com/apache/kafka/pull/10218#discussion_r596083656
##
File path:
remote-storage/src/main/java/org/apache/kafka/server/log/remote/storage/RemoteLogMetadataCache.java
##
@@ -0,0 +1,172 @@
+/*
+ * Licensed t
chia7712 commented on a change in pull request #10292:
URL: https://github.com/apache/kafka/pull/10292#discussion_r596084937
##
File path: tests/kafkatest/tests/client/client_compatibility_features_test.py
##
@@ -79,14 +79,16 @@ def __init__(self, test_context):
"r
chia7712 commented on pull request #9973:
URL: https://github.com/apache/kafka/pull/9973#issuecomment-801152285
@gquintana thanks for your patch. Could you share the new error message to
me?
This is an automated message from
[
https://issues.apache.org/jira/browse/KAFKA-12239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai reassigned KAFKA-12239:
--
Assignee: Gérald Quintana
> Unclear warning message in JmxReporter, when getting miss
tang7526 commented on a change in pull request #10332:
URL: https://github.com/apache/kafka/pull/10332#discussion_r596102909
##
File path:
core/src/test/scala/integration/kafka/api/AuthorizerIntegrationTest.scala
##
@@ -155,10 +155,16 @@ class AuthorizerIntegrationTest extends
tang7526 commented on a change in pull request #10332:
URL: https://github.com/apache/kafka/pull/10332#discussion_r596103167
##
File path: core/src/test/scala/unit/kafka/server/KafkaApisTest.scala
##
@@ -1455,10 +1453,11 @@ class KafkaApisTest {
val response = captured
tang7526 commented on a change in pull request #10332:
URL: https://github.com/apache/kafka/pull/10332#discussion_r596103388
##
File path: core/src/test/scala/unit/kafka/server/ProduceRequestTest.scala
##
@@ -185,17 +191,20 @@ class ProduceRequestTest extends BaseRequestTest {
tang7526 commented on a change in pull request #10332:
URL: https://github.com/apache/kafka/pull/10332#discussion_r596103601
##
File path: core/src/test/scala/unit/kafka/server/ProduceRequestTest.scala
##
@@ -110,21 +110,25 @@ class ProduceRequestTest extends BaseRequestTest {
tang7526 commented on a change in pull request #10332:
URL: https://github.com/apache/kafka/pull/10332#discussion_r596102985
##
File path:
core/src/test/scala/integration/kafka/network/DynamicConnectionQuotaTest.scala
##
@@ -337,12 +336,13 @@ class DynamicConnectionQuotaTest e
tang7526 commented on a change in pull request #10332:
URL: https://github.com/apache/kafka/pull/10332#discussion_r596103233
##
File path: core/src/test/scala/unit/kafka/server/ProduceRequestTest.scala
##
@@ -61,14 +59,17 @@ class ProduceRequestTest extends BaseRequestTest {
jolshan commented on pull request #10269:
URL: https://github.com/apache/kafka/pull/10269#issuecomment-801187849
@chia7712 I'm rewriting https://github.com/apache/kafka/pull/9944 to use the
autogenerated structures based on this PR. Just pushed a version that
simplifies the unresolved topi
jolshan edited a comment on pull request #10269:
URL: https://github.com/apache/kafka/pull/10269#issuecomment-801187849
@chia7712 I'm rewriting https://github.com/apache/kafka/pull/9944 to use the
autogenerated structures based on this PR. Just pushed a version that
simplifies the unresolv
chia7712 commented on pull request #10269:
URL: https://github.com/apache/kafka/pull/10269#issuecomment-801197578
> I'm rewriting #9944 to use the autogenerated structures based on this PR.
Just pushed a version that simplifies the unresolved topic ID handling. I tried
to make it easier to
cadonna commented on a change in pull request #10317:
URL: https://github.com/apache/kafka/pull/10317#discussion_r596184003
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopicManager.java
##
@@ -580,4 +562,118 @@ private String getBro
vamossagar12 commented on a change in pull request #10278:
URL: https://github.com/apache/kafka/pull/10278#discussion_r596185719
##
File path: raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java
##
@@ -1876,7 +1876,7 @@ private long maybeAppendBatches(
hachikuji commented on pull request #10323:
URL: https://github.com/apache/kafka/pull/10323#issuecomment-801227767
@ijuma Thanks for the link. EPL 2.0 is listed as a "weak copyleft" license,
similar to Jersey under CDDL. The document says that we can include a binary
dependence as long as
satishd commented on a change in pull request #10218:
URL: https://github.com/apache/kafka/pull/10218#discussion_r596203582
##
File path:
remote-storage/src/main/java/org/apache/kafka/server/log/remote/storage/InmemoryRemoteLogMetadataManager.java
##
@@ -0,0 +1,185 @@
+/*
+ *
satishd commented on a change in pull request #10218:
URL: https://github.com/apache/kafka/pull/10218#discussion_r596204864
##
File path:
remote-storage/src/main/java/org/apache/kafka/server/log/remote/storage/InmemoryRemoteLogMetadataManager.java
##
@@ -0,0 +1,185 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/KAFKA-12313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17303576#comment-17303576
]
Sagar Rao commented on KAFKA-12313:
---
Thanks [~ableegoldman], I think what you are sayi
[
https://issues.apache.org/jira/browse/KAFKA-12446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17303577#comment-17303577
]
A. Sophie Blee-Goldman commented on KAFKA-12446:
Yeah, I don't think thi
[
https://issues.apache.org/jira/browse/KAFKA-12446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman reassigned KAFKA-12446:
--
Assignee: Ben Ellis
> Define KGroupedTable#aggregate subtractor + add
satishd commented on a change in pull request #10218:
URL: https://github.com/apache/kafka/pull/10218#discussion_r596083656
##
File path:
remote-storage/src/main/java/org/apache/kafka/server/log/remote/storage/RemoteLogMetadataCache.java
##
@@ -0,0 +1,172 @@
+/*
+ * Licensed t
jsancio commented on a change in pull request #10278:
URL: https://github.com/apache/kafka/pull/10278#discussion_r596219371
##
File path: raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java
##
@@ -1876,7 +1876,7 @@ private long maybeAppendBatches(
cmccabe commented on pull request #10292:
URL: https://github.com/apache/kafka/pull/10292#issuecomment-801266689
Thanks, @chia7712 !
This is an automated message from the Apache Git Service.
To respond to the message, please
chia7712 merged pull request #10292:
URL: https://github.com/apache/kafka/pull/10292
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
hachikuji commented on a change in pull request #10282:
URL: https://github.com/apache/kafka/pull/10282#discussion_r596231610
##
File path: core/src/main/scala/kafka/cluster/Partition.scala
##
@@ -308,27 +308,29 @@ class Partition(val topicPartition: TopicPartition,
chia7712 commented on pull request #10292:
URL: https://github.com/apache/kafka/pull/10292#issuecomment-801271819
push to trunk and 2.8
This is an automated message from the Apache Git Service.
To respond to the message, plea
[
https://issues.apache.org/jira/browse/KAFKA-12313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17303608#comment-17303608
]
A. Sophie Blee-Goldman commented on KAFKA-12313:
> Having said that, the
jolshan commented on a change in pull request #10282:
URL: https://github.com/apache/kafka/pull/10282#discussion_r596243374
##
File path: core/src/main/scala/kafka/cluster/Partition.scala
##
@@ -308,27 +308,29 @@ class Partition(val topicPartition: TopicPartition,
jolshan commented on a change in pull request #10282:
URL: https://github.com/apache/kafka/pull/10282#discussion_r596246225
##
File path: core/src/main/scala/kafka/server/ReplicaManager.scala
##
@@ -1369,7 +1377,11 @@ class ReplicaManager(val config: KafkaConfig,
jolshan commented on pull request #10282:
URL: https://github.com/apache/kafka/pull/10282#issuecomment-801278854
> I cannot think of a reason not to pass the topic id if we have it
available. Otherwise, we would need logic to set it again after the log dir is
swapped.
@hachikuji this me
jolshan edited a comment on pull request #10282:
URL: https://github.com/apache/kafka/pull/10282#issuecomment-801278854
> I cannot think of a reason not to pass the topic id if we have it
available. Otherwise, we would need logic to set it again after the log dir is
swapped.
@hachik
omkreddy commented on pull request #10202:
URL: https://github.com/apache/kafka/pull/10202#issuecomment-801279341
its unused since 2.0 release. it looks like we just forgot this config, when
we removed old producer code. I think we dont require KIP for this. we can
remove the unused conf
satishd commented on a change in pull request #10218:
URL: https://github.com/apache/kafka/pull/10218#discussion_r596247752
##
File path:
clients/src/main/java/org/apache/kafka/server/log/remote/storage/RemoteLogSegmentState.java
##
@@ -87,4 +89,27 @@ public byte id() {
p
jolshan commented on a change in pull request #10282:
URL: https://github.com/apache/kafka/pull/10282#discussion_r596248900
##
File path: core/src/main/scala/kafka/server/ReplicaManager.scala
##
@@ -1369,7 +1377,11 @@ class ReplicaManager(val config: KafkaConfig,
jolshan commented on a change in pull request #10282:
URL: https://github.com/apache/kafka/pull/10282#discussion_r596251187
##
File path: core/src/main/scala/kafka/server/ReplicaManager.scala
##
@@ -1369,7 +1377,11 @@ class ReplicaManager(val config: KafkaConfig,
omkreddy edited a comment on pull request #10202:
URL: https://github.com/apache/kafka/pull/10202#issuecomment-801279341
its unused since 2.0 release. it looks like we just forgot this config, when
we removed old producer code. I think we dont require KIP for this. maybe we
can remove th
chia7712 commented on pull request #10202:
URL: https://github.com/apache/kafka/pull/10202#issuecomment-801286324
> its unused since 2.0 release. it looks like we just forgot this config,
when we removed old producer code. I think we dont require KIP for this. we can
remove the unused conf
[
https://issues.apache.org/jira/browse/KAFKA-12472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17303621#comment-17303621
]
Guozhang Wang commented on KAFKA-12472:
---
Good questions. I'd like to dump some of
[
https://issues.apache.org/jira/browse/KAFKA-12472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17303621#comment-17303621
]
Guozhang Wang edited comment on KAFKA-12472 at 3/17/21, 5:55 PM:
-
cmccabe merged pull request #10297:
URL: https://github.com/apache/kafka/pull/10297
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
hachikuji commented on pull request #10282:
URL: https://github.com/apache/kafka/pull/10282#issuecomment-801292892
@jolshan Yeah, we haven't gotten to implementing JBOD for KIP-500. It
shouldn't be too far off though.
This i
kowshik commented on a change in pull request #10218:
URL: https://github.com/apache/kafka/pull/10218#discussion_r595492577
##
File path:
clients/src/main/java/org/apache/kafka/server/log/remote/storage/RemoteLogSegmentState.java
##
@@ -87,4 +89,27 @@ public byte id() {
p
hachikuji commented on a change in pull request #10085:
URL: https://github.com/apache/kafka/pull/10085#discussion_r596263576
##
File path: raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java
##
@@ -311,8 +311,18 @@ private void updateListenersProgress(long highWaterm
cmccabe commented on a change in pull request #10334:
URL: https://github.com/apache/kafka/pull/10334#discussion_r596269367
##
File path: metadata/src/main/java/org/apache/kafka/timeline/BaseHashTable.java
##
@@ -56,12 +58,30 @@
this.elements = new Object[expectedSizeT
cmccabe commented on a change in pull request #10334:
URL: https://github.com/apache/kafka/pull/10334#discussion_r596271529
##
File path:
metadata/src/test/java/org/apache/kafka/timeline/BaseHashTableTest.java
##
@@ -121,4 +121,19 @@ public void testExpansion() {
cmccabe commented on pull request #10334:
URL: https://github.com/apache/kafka/pull/10334#issuecomment-801303357
Thanks for the reviews! Will commit in a few hours if there are no more
comments.
This is an automated message
chia7712 commented on a change in pull request #10334:
URL: https://github.com/apache/kafka/pull/10334#discussion_r596283100
##
File path: metadata/src/main/java/org/apache/kafka/timeline/BaseHashTable.java
##
@@ -56,12 +61,27 @@
this.elements = new Object[expectedSize
hachikuji commented on pull request #10275:
URL: https://github.com/apache/kafka/pull/10275#issuecomment-801315101
@dajac Thanks for reviewing. I think you have to compare the complexity with
(for example) the `listOffsets` implementation which relies on `Call` chaining
and the internal `M
[
https://issues.apache.org/jira/browse/KAFKA-12472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17303621#comment-17303621
]
Guozhang Wang edited comment on KAFKA-12472 at 3/17/21, 6:31 PM:
-
cmccabe commented on a change in pull request #10227:
URL: https://github.com/apache/kafka/pull/10227#discussion_r596288990
##
File path: KIP-500.md
##
@@ -0,0 +1,131 @@
+KIP-500 Early Access Release
+
+
+# Introduction
+It is now possible to run Apa
hachikuji commented on a change in pull request #10275:
URL: https://github.com/apache/kafka/pull/10275#discussion_r596289179
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/internals/AdminApiDriver.java
##
@@ -0,0 +1,476 @@
+/*
+ * Licensed to the Apache So
chia7712 commented on pull request #10323:
URL: https://github.com/apache/kafka/pull/10323#issuecomment-801321480
unrelated to this PR. `forRandomRunning` is not used. Maybe we can remove it
in this PR? Also, `random` of `RaftNode` is not used also.
---
cadonna commented on a change in pull request #10317:
URL: https://github.com/apache/kafka/pull/10317#discussion_r596292688
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopicManager.java
##
@@ -580,4 +562,118 @@ private String getBro
chia7712 commented on a change in pull request #10332:
URL: https://github.com/apache/kafka/pull/10332#discussion_r596291543
##
File path:
clients/src/test/java/org/apache/kafka/common/requests/ProduceResponseTest.java
##
@@ -40,42 +42,42 @@
public void produceResponseV5T
hachikuji commented on pull request #10323:
URL: https://github.com/apache/kafka/pull/10323#issuecomment-801325094
@chia7712 I removed `forRandomRunning` here:
https://github.com/apache/kafka/pull/10309.
This is an automated
jsancio commented on a change in pull request #10085:
URL: https://github.com/apache/kafka/pull/10085#discussion_r596301164
##
File path: raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java
##
@@ -311,8 +311,18 @@ private void updateListenersProgress(long highWatermar
jsancio commented on a change in pull request #10334:
URL: https://github.com/apache/kafka/pull/10334#discussion_r596315922
##
File path: metadata/src/main/java/org/apache/kafka/timeline/BaseHashTable.java
##
@@ -56,12 +61,27 @@
this.elements = new Object[expectedSizeT
hachikuji commented on a change in pull request #10309:
URL: https://github.com/apache/kafka/pull/10309#discussion_r596330007
##
File path: raft/src/test/java/org/apache/kafka/raft/RaftEventSimulationTest.java
##
@@ -401,6 +401,51 @@ private void checkBackToBackLeaderFailures(Q
dajac commented on pull request #9963:
URL: https://github.com/apache/kafka/pull/9963#issuecomment-801373902
@hachikuji Could you take a look at this one when you have a bit of time? It
is not urgent.
This is an automated me
Jason Gustafson created KAFKA-12490:
---
Summary: Forwarded requests should use timeout from request when
possible
Key: KAFKA-12490
URL: https://issues.apache.org/jira/browse/KAFKA-12490
Project: Kafka
rhauch commented on a change in pull request #10337:
URL: https://github.com/apache/kafka/pull/10337#discussion_r596333717
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Worker.java
##
@@ -226,6 +226,7 @@ public void stop() {
offsetBack
[
https://issues.apache.org/jira/browse/KAFKA-12490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson updated KAFKA-12490:
Labels: kip-500 (was: )
> Forwarded requests should use timeout from request when possibl
rhauch commented on pull request #10337:
URL: https://github.com/apache/kafka/pull/10337#issuecomment-801398429
Also, there are [24 failed unit tests on the different
jobs](https://ci-builds.apache.org/job/Kafka/job/kafka-pr/job/PR-10337/4/testReport/junit/org.apache.kafka.connect.runtime/?
cadonna commented on pull request #9779:
URL: https://github.com/apache/kafka/pull/9779#issuecomment-801410030
@vamossagar12 I am sorry that I haven't reviewed you PR yet. I will try to
review it as soon as possible which can still take some time currently.
---
[
https://issues.apache.org/jira/browse/KAFKA-12475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17303700#comment-17303700
]
Guozhang Wang commented on KAFKA-12475:
---
+1 to [~cadonna]. I've seen some people u
mumrah opened a new pull request #10340:
URL: https://github.com/apache/kafka/pull/10340
Also use different log prefixes for the different channels. Log prefixes now
look like:
```
[BrokerToControllerChannelManager broker=1 name=alterIsr] ...
[BrokerToControllerChannelManager b
cmccabe commented on a change in pull request #10227:
URL: https://github.com/apache/kafka/pull/10227#discussion_r596364533
##
File path: KIP-500.md
##
@@ -0,0 +1,131 @@
+KIP-500 Early Access Release
+
+
+# Introduction
+It is now possible to run Apa
hachikuji commented on a change in pull request #10340:
URL: https://github.com/apache/kafka/pull/10340#discussion_r596364783
##
File path:
core/src/main/scala/kafka/server/BrokerToControllerChannelManager.scala
##
@@ -168,7 +168,7 @@ class BrokerToControllerChannelManagerImpl
cmccabe commented on a change in pull request #10334:
URL: https://github.com/apache/kafka/pull/10334#discussion_r596375185
##
File path: metadata/src/main/java/org/apache/kafka/timeline/BaseHashTable.java
##
@@ -56,12 +61,27 @@
this.elements = new Object[expectedSizeT
jolshan commented on a change in pull request #10282:
URL: https://github.com/apache/kafka/pull/10282#discussion_r596377411
##
File path: core/src/main/scala/kafka/server/ReplicaManager.scala
##
@@ -1369,7 +1377,11 @@ class ReplicaManager(val config: KafkaConfig,
1 - 100 of 179 matches
Mail list logo
