[
https://issues.apache.org/jira/browse/KAFKA-14379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17638188#comment-17638188
]
Luke Chen commented on KAFKA-14379:
---
[~jeffkbkim] , we recently also encountered this
[
https://issues.apache.org/jira/browse/KAFKA-14379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen updated KAFKA-14379:
--
Description:
The consumer (fetcher) refreshes the preferred read replica only on three
conditions:
#
[
https://issues.apache.org/jira/browse/KAFKA-14379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17638191#comment-17638191
]
Luke Chen commented on KAFKA-14379:
---
Oh, sorry, I saw you have a WIP PR opened. Thanks
lucasbru opened a new pull request, #12903:
URL: https://github.com/apache/kafka/pull/12903
Optimization of `ThreadCache`. The original implementation showed
significant slow-down when many caches were registered.
`sizeBytes` was called at least once, and potentially many times in eve
lucasbru commented on PR #12903:
URL: https://github.com/apache/kafka/pull/12903#issuecomment-1326138928
@ableegoldman Could you have a look?
--
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-14362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17638225#comment-17638225
]
Mikael commented on KAFKA-14362:
I can confirm that there is no duplication in this scen
patrik-marton commented on code in PR #12846:
URL: https://github.com/apache/kafka/pull/12846#discussion_r1031302727
##
connect/basic-auth-extension/src/main/java/org/apache/kafka/connect/rest/basic/auth/extension/JaasBasicAuthFilter.java:
##
@@ -174,4 +153,84 @@ public void han
lucasbru opened a new pull request, #12904:
URL: https://github.com/apache/kafka/pull/12904
The original implementation of the state updater could not
handle double rebalances within one poll phase correctly,
because it could create tasks more than once if they hadn't
finished initia
lucasbru commented on PR #12904:
URL: https://github.com/apache/kafka/pull/12904#issuecomment-1326221089
@cadonna could you please have a look?
--
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
clolov commented on PR #12607:
URL: https://github.com/apache/kafka/pull/12607#issuecomment-1326276846
Polite bump for a review here @cadonna. I have rebased on the latest trunk
and I believe I have answered the majority of the comments already on the pull
request. Given the size of the cha
Divij Vaidya created KAFKA-14418:
Summary: Add safety checks for modifying partitions of
__consumer_offsets
Key: KAFKA-14418
URL: https://issues.apache.org/jira/browse/KAFKA-14418
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-14418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Divij Vaidya updated KAFKA-14418:
-
Description:
Today a user can change the number of partitions of
{{{}_{}}}{_}{{_consumer}}{_}{{
divijvaidya commented on PR #12890:
URL: https://github.com/apache/kafka/pull/12890#issuecomment-1326424695
@mimaison please take a look when you get a chance!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL ab
Mikael created KAFKA-14419:
--
Summary: Same message consumed again by the same stream task after
partition is lost and reassigned
Key: KAFKA-14419
URL: https://issues.apache.org/jira/browse/KAFKA-14419
Projec
[
https://issues.apache.org/jira/browse/KAFKA-14362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17638282#comment-17638282
]
Mikael commented on KAFKA-14362:
Created KAFKA-14419 for the stream consumer duplication
[
https://issues.apache.org/jira/browse/KAFKA-14362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mikael updated KAFKA-14362:
---
Attachment: (was:
KAFKA-14362_Do_not_return_any_records_from_KafkaConsumer_poll()_while_rebalance_is_in_
divijvaidya commented on PR #12900:
URL: https://github.com/apache/kafka/pull/12900#issuecomment-1326457410
> Were these suggestions generated through some sort of a tool?
No. I checked them manually. This came up while I was trying to find
optimisation opportunities for toSet scala o
dajac commented on code in PR #12748:
URL: https://github.com/apache/kafka/pull/12748#discussion_r1031512818
##
clients/src/test/java/org/apache/kafka/clients/consumer/CooperativeStickyAssignorTest.java:
##
@@ -44,14 +46,26 @@ public AbstractStickyAssignor createAssignor() {
lucasbru commented on PR #12903:
URL: https://github.com/apache/kafka/pull/12903#issuecomment-1326489671
Test failures are unrelated
--
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 c
dajac commented on code in PR #12877:
URL: https://github.com/apache/kafka/pull/12877#discussion_r1031546311
##
core/src/test/scala/integration/kafka/server/FetchFromFollowerIntegrationTest.scala:
##
@@ -84,9 +84,58 @@ class FetchFromFollowerIntegrationTest extends
BaseFetchReq
dajac merged PR #12877:
URL: https://github.com/apache/kafka/pull/12877
--
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.or
dajac commented on PR #12877:
URL: https://github.com/apache/kafka/pull/12877#issuecomment-1326505121
Merged to trunk and 3.3
--
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.
[
https://issues.apache.org/jira/browse/KAFKA-14372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot resolved KAFKA-14372.
-
Fix Version/s: 3.4.0
3.3.2
Resolution: Fixed
> RackAwareReplicaSelecto
dajac merged PR #12308:
URL: https://github.com/apache/kafka/pull/12308
--
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.or
[
https://issues.apache.org/jira/browse/KAFKA-14009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot updated KAFKA-14009:
Summary: Rebalance timeout should be updated when static member rejoins
(was: Consumers do not re
[
https://issues.apache.org/jira/browse/KAFKA-14009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot reassigned KAFKA-14009:
---
Assignee: zou shengfu
> Rebalance timeout should be updated when static member rejoins
> --
dajac commented on PR #12308:
URL: https://github.com/apache/kafka/pull/12308#issuecomment-1326519129
@Stephan14 Thanks for the patch!
--
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
[
https://issues.apache.org/jira/browse/KAFKA-14009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot resolved KAFKA-14009.
-
Fix Version/s: 3.4.0
3.3.2
Resolution: Fixed
> Rebalance timeout shoul
dajac commented on PR #12308:
URL: https://github.com/apache/kafka/pull/12308#issuecomment-1326519325
Merged to trunk and 3.3.
--
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
divijvaidya commented on PR #12891:
URL: https://github.com/apache/kafka/pull/12891#issuecomment-1326539413
Hi @C0urante @showuon
I didn't find much difference in CPU usage after this optimization (thanks
to Chris's tip on adding after/before profile), hence I am aborting this PR. It
divijvaidya closed pull request #12891: MINOR: Reduce impact of trace logging
produce request hot path
URL: https://github.com/apache/kafka/pull/12891
--
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-14418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Divij Vaidya updated KAFKA-14418:
-
Description:
Today a user can change the number of partitions of
{{{}{}}}{{{}_consumer_{}}}{{{}
jonathan-albrecht-ibm commented on code in PR #12343:
URL: https://github.com/apache/kafka/pull/12343#discussion_r1031785630
##
clients/src/test/java/org/apache/kafka/clients/producer/KafkaProducerTest.java:
##
@@ -2263,7 +2263,10 @@ public void configure(Map configs) {
jonathan-albrecht-ibm commented on code in PR #12343:
URL: https://github.com/apache/kafka/pull/12343#discussion_r1031785699
##
core/src/test/scala/kafka/security/minikdc/MiniKdc.scala:
##
@@ -260,11 +260,17 @@ class MiniKdc(config: Properties, workDir: File) extends
Logging {
jonathan-albrecht-ibm commented on PR #12343:
URL: https://github.com/apache/kafka/pull/12343#issuecomment-1326790440
TFTR @cadonna, I've updated the changes according to your feedback.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on t
lucasbru commented on PR #12875:
URL: https://github.com/apache/kafka/pull/12875#issuecomment-1326818177
Okay, I revised the change and it is ready for review.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL ab
Scanteianu opened a new pull request, #12906:
URL: https://github.com/apache/kafka/pull/12906
*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
showuon commented on code in PR #12748:
URL: https://github.com/apache/kafka/pull/12748#discussion_r1032023101
##
clients/src/test/java/org/apache/kafka/clients/consumer/CooperativeStickyAssignorTest.java:
##
@@ -44,14 +46,26 @@ public AbstractStickyAssignor createAssignor() {
showuon commented on PR #12748:
URL: https://github.com/apache/kafka/pull/12748#issuecomment-1327047070
@dajac , thanks for the comment. And thanks to the test, I found there's one
thing I missed, which is in eager rebalance protocol like StickyAssignor, the
ownedPartitions will all get rev
39 matches
Mail list logo
