[
https://issues.apache.org/jira/browse/KAFKA-13300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17415352#comment-17415352
]
Manikumar commented on KAFKA-13300:
---
kafka-acls.sh command {{"--add"}} option is for a
[
https://issues.apache.org/jira/browse/KAFKA-13300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17415352#comment-17415352
]
Manikumar edited comment on KAFKA-13300 at 9/15/21, 7:28 AM:
-
yangshengwei created KAFKA-13301:
Summary: The relationship between request.timeout. ms and
max.poll.interval.ms in the Consumer Configs is incorrect.
Key: KAFKA-13301
URL: https://issues.apache.org/jira/browse/KA
[
https://issues.apache.org/jira/browse/KAFKA-13301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yangshengwei updated KAFKA-13301:
-
Attachment: image-2021-09-15-15-37-25-561.png
> The relationship between request.timeout. ms and
[
https://issues.apache.org/jira/browse/KAFKA-13301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17415358#comment-17415358
]
yangshengwei commented on KAFKA-13301:
--
!image-2021-09-15-15-37-25-561.png|width=52
[
https://issues.apache.org/jira/browse/KAFKA-13301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17415358#comment-17415358
]
yangshengwei edited comment on KAFKA-13301 at 9/15/21, 7:39 AM:
--
[
https://issues.apache.org/jira/browse/KAFKA-13301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17415361#comment-17415361
]
yangshengwei commented on KAFKA-13301:
--
[~guozhang]
h3. [guozhangwang|https://gi
[
https://issues.apache.org/jira/browse/KAFKA-13300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17415352#comment-17415352
]
Manikumar edited comment on KAFKA-13300 at 9/15/21, 7:43 AM:
-
Nikolay Izhikov created KAFKA-13302:
---
Summary: [IEP-59] Support not default page size
Key: KAFKA-13302
URL: https://issues.apache.org/jira/browse/KAFKA-13302
Project: Kafka
Issue Type: Impr
[
https://issues.apache.org/jira/browse/KAFKA-13301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17415358#comment-17415358
]
yangshengwei edited comment on KAFKA-13301 at 9/15/21, 9:58 AM:
--
[
https://issues.apache.org/jira/browse/KAFKA-13301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17415358#comment-17415358
]
yangshengwei edited comment on KAFKA-13301 at 9/15/21, 9:59 AM:
--
Jon McEwen created KAFKA-13303:
--
Summary: RoundRobinPartitioner broken by KIP-480
Key: KAFKA-13303
URL: https://issues.apache.org/jira/browse/KAFKA-13303
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-13246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andre Dymel reassigned KAFKA-13246:
---
Assignee: Andre Dymel
> StoreQueryIntegrationTest#shouldQueryStoresAfterAddingAndRemovingSt
jonmcewen opened a new pull request #11326:
URL: https://github.com/apache/kafka/pull/11326
NEEDS FORMAT AND TESTS fixes for sticky partitioning and thread safety.
*More detailed description of your change,
if necessary. The PR title and PR message become
the squashed commit m
[
https://issues.apache.org/jira/browse/KAFKA-13303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17415452#comment-17415452
]
Jon McEwen commented on KAFKA-13303:
WIP patch: https://github.com/apache/kafka/pull
[
https://issues.apache.org/jira/browse/KAFKA-13295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao reassigned KAFKA-13295:
-
Assignee: Sagar Rao
> Long restoration times for new tasks can lead to transaction timeouts
> -
[
https://issues.apache.org/jira/browse/KAFKA-13295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17415486#comment-17415486
]
Sagar Rao commented on KAFKA-13295:
---
[~guozhang]/ [~ableegoldman] I assigned this to m
dajac commented on a change in pull request #11170:
URL: https://github.com/apache/kafka/pull/11170#discussion_r709122840
##
File path: core/src/main/scala/kafka/server/AbstractFetcherThread.scala
##
@@ -491,6 +495,19 @@ abstract class AbstractFetcherThread(name: String,
}
[
https://issues.apache.org/jira/browse/KAFKA-13292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17415491#comment-17415491
]
NEERAJ VAIDYA commented on KAFKA-13292:
---
Thanks [~mjsax]
I will look at upgrading
[
https://issues.apache.org/jira/browse/KAFKA-13303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17415496#comment-17415496
]
Luke Chen commented on KAFKA-13303:
---
This is duplicated with KAFKA-9965.
> RoundRobin
[
https://issues.apache.org/jira/browse/KAFKA-13303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17415497#comment-17415497
]
Luke Chen commented on KAFKA-13303:
---
Could you also leave your PR link on KAFKA-9965 c
Thomas Bachmann created KAFKA-13304:
---
Summary: Implicit cast of source type long to narrower destination
type int in org.apache.kafka.common.network.MultiSend.java
Key: KAFKA-13304
URL: https://issues.apache.org
mumrah commented on a change in pull request #11320:
URL: https://github.com/apache/kafka/pull/11320#discussion_r709241900
##
File path: core/src/test/scala/unit/kafka/log/LogLoaderTest.scala
##
@@ -75,13 +75,25 @@ class LogLoaderTest {
// Create a LogManager with some o
hachikuji merged pull request #11186:
URL: https://github.com/apache/kafka/pull/11186
--
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-unsubsc
[
https://issues.apache.org/jira/browse/KAFKA-13162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson updated KAFKA-13162:
Fix Version/s: (was: 3.0.1)
3.1.0
> ElectLeader API must be forward
[
https://issues.apache.org/jira/browse/KAFKA-13162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson resolved KAFKA-13162.
-
Resolution: Fixed
> ElectLeader API must be forwarded to Controller
> --
dengziming commented on pull request #11261:
URL: https://github.com/apache/kafka/pull/11261#issuecomment-920145832
ping @hachikuji @abbccdda
--
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
jolshan commented on a change in pull request #11170:
URL: https://github.com/apache/kafka/pull/11170#discussion_r709328285
##
File path: core/src/main/scala/kafka/server/AbstractFetcherManager.scala
##
@@ -163,6 +163,17 @@ abstract class AbstractFetcherManager[T <:
AbstractFe
jolshan commented on a change in pull request #11170:
URL: https://github.com/apache/kafka/pull/11170#discussion_r709334903
##
File path: core/src/main/scala/kafka/server/AbstractFetcherThread.scala
##
@@ -459,18 +459,22 @@ abstract class AbstractFetcherThread(name: String,
jolshan commented on a change in pull request #11170:
URL: https://github.com/apache/kafka/pull/11170#discussion_r709337669
##
File path: core/src/main/scala/kafka/server/AbstractFetcherManager.scala
##
@@ -163,6 +163,17 @@ abstract class AbstractFetcherManager[T <:
AbstractFe
jolshan commented on a change in pull request #11170:
URL: https://github.com/apache/kafka/pull/11170#discussion_r709342716
##
File path: core/src/main/scala/kafka/server/ReplicaManager.scala
##
@@ -741,7 +741,8 @@ class ReplicaManager(val config: KafkaConfig,
// t
cmccabe commented on a change in pull request #11320:
URL: https://github.com/apache/kafka/pull/11320#discussion_r709348152
##
File path: core/src/test/scala/unit/kafka/log/LogLoaderTest.scala
##
@@ -75,13 +75,25 @@ class LogLoaderTest {
// Create a LogManager with some
cmccabe commented on a change in pull request #11320:
URL: https://github.com/apache/kafka/pull/11320#discussion_r709348909
##
File path: core/src/main/scala/kafka/server/ReplicaManager.scala
##
@@ -186,49 +186,37 @@ object ReplicaManager {
class ReplicaManager(val config: Kaf
cmccabe commented on a change in pull request #11320:
URL: https://github.com/apache/kafka/pull/11320#discussion_r709349588
##
File path: core/src/main/java/kafka/server/builders/KafkaApisBuilder.java
##
@@ -0,0 +1,197 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
wcarlson5 commented on pull request #11278:
URL: https://github.com/apache/kafka/pull/11278#issuecomment-920174685
@guozhangwang That is a really good point. Maybe we should more be specific.
What if each topology could request a percentage of the total cache? If a
request made the total
cmccabe commented on pull request #11320:
URL: https://github.com/apache/kafka/pull/11320#issuecomment-920176422
> On the builders, should we drop the "set" from the method names? I believe
we have establish the pattern (in Scala, at least) of not including "get" and
"set" in getters and s
jolshan commented on a change in pull request #11170:
URL: https://github.com/apache/kafka/pull/11170#discussion_r709357795
##
File path: core/src/main/scala/kafka/server/ReplicaManager.scala
##
@@ -1755,6 +1762,66 @@ class ReplicaManager(val config: KafkaConfig,
partition
[
https://issues.apache.org/jira/browse/KAFKA-7408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jose Armando Garcia Sancio reassigned KAFKA-7408:
-
Assignee: Jose Armando Garcia Sancio
> Truncate to LSO on unclea
[
https://issues.apache.org/jira/browse/KAFKA-7408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17415635#comment-17415635
]
Jose Armando Garcia Sancio commented on KAFKA-7408:
---
Good points [~guoz
Vincent Jiang created KAFKA-13305:
-
Summary: NullPointerException in LogCleanerManager
"uncleanable-bytes" gauge
Key: KAFKA-13305
URL: https://issues.apache.org/jira/browse/KAFKA-13305
Project: Kafka
ccding commented on pull request #11293:
URL: https://github.com/apache/kafka/pull/11293#issuecomment-920247203
The commend of `defineInternal` says
```
* Define a new internal configuration. Internal configuration won't
show up in the docs and aren't
* intended for gener
ccding edited a comment on pull request #11293:
URL: https://github.com/apache/kafka/pull/11293#issuecomment-920247203
The comment of `defineInternal` says
```
* Define a new internal configuration. Internal configuration won't
show up in the docs and aren't
* intended fo
ccding commented on pull request #11293:
URL: https://github.com/apache/kafka/pull/11293#issuecomment-920248580
Will cherry-pick this PR to 3.0 after it is merged to trunk
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and u
[
https://issues.apache.org/jira/browse/KAFKA-13261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17415690#comment-17415690
]
Matthias J. Sax commented on KAFKA-13261:
-
I would prefer to do a KIP and allow
vincent81jiang opened a new pull request #11327:
URL: https://github.com/apache/kafka/pull/11327
* Fix KAFKA-13305: NullPointerException in LogCleanerManager
"uncleanable-bytes" gauge
- Add a periodic task to remove deleted partitions from uncleanablePartitions
### Committer C
[
https://issues.apache.org/jira/browse/KAFKA-13261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17415690#comment-17415690
]
Matthias J. Sax edited comment on KAFKA-13261 at 9/15/21, 6:56 PM:
---
mattwong949 commented on a change in pull request #10914:
URL: https://github.com/apache/kafka/pull/10914#discussion_r709503140
##
File path: core/src/main/scala/kafka/log/LogCleaner.scala
##
@@ -622,26 +628,35 @@ private[log] class Cleaner(val id: Int,
* @param sourceRecor
gitlw commented on pull request #11285:
URL: https://github.com/apache/kafka/pull/11285#issuecomment-920312333
@lbradstreet @jolshan Can you please take a look? Thank you!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and u
mattwong949 commented on a change in pull request #10914:
URL: https://github.com/apache/kafka/pull/10914#discussion_r709510271
##
File path: core/src/main/scala/kafka/log/LogCleaner.scala
##
@@ -658,20 +673,22 @@ private[log] class Cleaner(val id: Int,
}
}
junrao commented on a change in pull request #10914:
URL: https://github.com/apache/kafka/pull/10914#discussion_r709536010
##
File path: core/src/main/scala/kafka/log/LogCleaner.scala
##
@@ -493,19 +496,20 @@ private[log] class Cleaner(val id: Int,
* @return The first offse
mattwong949 commented on a change in pull request #10914:
URL: https://github.com/apache/kafka/pull/10914#discussion_r709539669
##
File path: core/src/main/scala/kafka/log/LogCleaner.scala
##
@@ -493,19 +496,20 @@ private[log] class Cleaner(val id: Int,
* @return The first
[
https://issues.apache.org/jira/browse/KAFKA-13261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17415747#comment-17415747
]
Guozhang Wang commented on KAFKA-13261:
---
> wouldn't we still have an analogous bug
[
https://issues.apache.org/jira/browse/KAFKA-12994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17415755#comment-17415755
]
Andrew patterson commented on KAFKA-12994:
--
Think it's fine so far, will move o
[
https://issues.apache.org/jira/browse/KAFKA-13261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17415792#comment-17415792
]
Victoria Xia commented on KAFKA-13261:
--
Thanks for the confirmation, Matthias and G
guozhangwang commented on pull request #11278:
URL: https://github.com/apache/kafka/pull/11278#issuecomment-920445983
> I think that should work. now we have both an upper bound on total memory
and a minimum guarantee
Yeah, I feel more comfortable for this proposal :) Basically I thi
[
https://issues.apache.org/jira/browse/KAFKA-12226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton updated KAFKA-12226:
--
Description:
The current source task thread has the following workflow:
# Poll messages from
[
https://issues.apache.org/jira/browse/KAFKA-13301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17415801#comment-17415801
]
Guozhang Wang commented on KAFKA-13301:
---
Thanks for filing this [~yangshengwei]. I
junrao commented on a change in pull request #11058:
URL: https://github.com/apache/kafka/pull/11058#discussion_r707813690
##
File path:
storage/src/main/resources/message/RemoteLogSegmentMetadataRecordSnapshot.json
##
@@ -0,0 +1,92 @@
+// Licensed to the Apache Software Found
AnamikaN opened a new pull request #11328:
URL: https://github.com/apache/kafka/pull/11328
Objective - Use MM2 (kafka connect in distributed cluster) for data
migration between cluster hosted in private data center and aws msk cluster.
Steps performed -
Started kafka-connect s
[
https://issues.apache.org/jira/browse/KAFKA-13255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17415812#comment-17415812
]
Anamika Nadkarni commented on KAFKA-13255:
--
[~ryannedolan] Submitted PR. Thank
yangdaixai opened a new pull request #11329:
URL: https://github.com/apache/kafka/pull/11329
*More detailed description of your change,
if necessary. The PR title and PR message become
the squashed commit message, so use a separate
comment to ping reviewers.*
*Summary of test
yangdaixai commented on pull request #11329:
URL: https://github.com/apache/kafka/pull/11329#issuecomment-920537877
@guozhangwang
--
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 spe
[
https://issues.apache.org/jira/browse/KAFKA-13301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17415840#comment-17415840
]
yangshengwei commented on KAFKA-13301:
--
[~guozhang]
submit a PR:
https://git
yangdaixai commented on pull request #11329:
URL: https://github.com/apache/kafka/pull/11329#issuecomment-920539185
@guozhangwang
issues:
https://issues.apache.org/jira/browse/KAFKA-13301?focusedCommentId=17415801&page=com.atlassian.jira.plugin.system.issuetabpanels%3Acomment-tab
chia7712 commented on a change in pull request #10976:
URL: https://github.com/apache/kafka/pull/10976#discussion_r709761794
##
File path:
streams/src/test/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetricsRecorderTest.java
##
@@ -300,65 +287,47 @@ public voi
65 matches
Mail list logo
