Navinder Brar created KAFKA-9445:
Summary: Allow fetching a key from a single partition rather than
iterating over all the stores on an instance
Key: KAFKA-9445
URL: https://issues.apache.org/jira/browse/KAFKA-944
[
https://issues.apache.org/jira/browse/KAFKA-9445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Navinder Brar updated KAFKA-9445:
-
Labels: (was: kip-535)
> Allow fetching a key from a single partition rather than iterating ove
[
https://issues.apache.org/jira/browse/KAFKA-9445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Navinder Brar updated KAFKA-9445:
-
Description: (was: Currently when expanding the KS cluster, the new
node's partitions will be
[
https://issues.apache.org/jira/browse/KAFKA-9445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Navinder Brar updated KAFKA-9445:
-
Description: Whenever a call is made to get a particular key from a Kafka
Streams instance, curre
[
https://issues.apache.org/jira/browse/KAFKA-9445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Navinder Brar updated KAFKA-9445:
-
Labels:
https://cwiki.apache.org/confluence/display/KAFKA/KIP-562%3A+Allow+fetching+a+key+from+a+
[
https://issues.apache.org/jira/browse/KAFKA-9445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Navinder Brar updated KAFKA-9445:
-
Labels: KIP-562 (was:
https://cwiki.apache.org/confluence/display/KAFKA/KIP-562%3A+Allow+fetchin
[
https://issues.apache.org/jira/browse/KAFKA-9450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17023643#comment-17023643
]
Navinder Brar commented on KAFKA-9450:
--
Great that I caught hold of this Jira. I had
[
https://issues.apache.org/jira/browse/KAFKA-9450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17023643#comment-17023643
]
Navinder Brar edited comment on KAFKA-9450 at 1/25/20 8:38 PM:
[
https://issues.apache.org/jira/browse/KAFKA-9450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17024902#comment-17024902
]
Navinder Brar commented on KAFKA-9450:
--
Or do you suggest to never (ie, for EOS and
[
https://issues.apache.org/jira/browse/KAFKA-9450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17025550#comment-17025550
]
Navinder Brar commented on KAFKA-9450:
--
Checked Rocksdb code, event listeners are no
Navinder Brar created KAFKA-9487:
Summary: Followup : KAFKA-9445
Key: KAFKA-9487
URL: https://issues.apache.org/jira/browse/KAFKA-9487
Project: Kafka
Issue Type: New Feature
Compone
[
https://issues.apache.org/jira/browse/KAFKA-9487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17027318#comment-17027318
]
Navinder Brar commented on KAFKA-9487:
--
A few code review comments are left to be ad
[
https://issues.apache.org/jira/browse/KAFKA-9487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Navinder Brar updated KAFKA-9487:
-
Description: A few code review comments are left to be addressed from Kafka
9445, which I will be
[
https://issues.apache.org/jira/browse/KAFKA-9487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Navinder Brar updated KAFKA-9487:
-
Comment: was deleted
(was: A few code review comments are left to be addressed from Kafka 9445,
[
https://issues.apache.org/jira/browse/KAFKA-9487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Navinder Brar updated KAFKA-9487:
-
Summary: Followup : KAFKA-9445(Allow fetching a key from a single
partition), addressing code rev
[
https://issues.apache.org/jira/browse/KAFKA-9487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Navinder Brar updated KAFKA-9487:
-
Summary: Followup : KAFKA-9445(Allow fetching a key from a single
partition); addressing code rev
[
https://issues.apache.org/jira/browse/KAFKA-9450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17025550#comment-17025550
]
Navinder Brar edited comment on KAFKA-9450 at 2/9/20 9:19 AM:
-
[
https://issues.apache.org/jira/browse/KAFKA-9487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Navinder Brar resolved KAFKA-9487.
--
Resolution: Fixed
> Followup : KAFKA-9445(Allow fetching a key from a single partition);
> add
[
https://issues.apache.org/jira/browse/KAFKA-9450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17036093#comment-17036093
]
Navinder Brar commented on KAFKA-9450:
--
Sure, [~ableegoldman]. I will create a ticke
Navinder Brar created KAFKA-9588:
Summary: Add rocksdb event listeners in KS
Key: KAFKA-9588
URL: https://issues.apache.org/jira/browse/KAFKA-9588
Project: Kafka
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/KAFKA-9588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Navinder Brar updated KAFKA-9588:
-
Description: Rocsdb is coming up with the support of event listeners(like
onCompactionCompleted)
[
https://issues.apache.org/jira/browse/KAFKA-9588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Navinder Brar updated KAFKA-9588:
-
Description: Rocsdb is coming up with the support of event listeners(like
onCompactionCompleted)
[
https://issues.apache.org/jira/browse/KAFKA-7480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17059905#comment-17059905
]
Navinder Brar commented on KAFKA-7480:
--
Hi [~mjsax] can I take up this up?
I didn't
[
https://issues.apache.org/jira/browse/KAFKA-7480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Navinder Brar reassigned KAFKA-7480:
Assignee: Navinder Brar
> GlobalThread should honor custom auto.offset.reset policy
>
[
https://issues.apache.org/jira/browse/KAFKA-7480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17059997#comment-17059997
]
Navinder Brar commented on KAFKA-7480:
--
Sure, thanks Matthias. I will assign this to
[
https://issues.apache.org/jira/browse/KAFKA-9757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17071251#comment-17071251
]
Navinder Brar commented on KAFKA-9757:
--
Hey [~vinoth], if you are busy I can take th
[
https://issues.apache.org/jira/browse/KAFKA-9757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17071906#comment-17071906
]
Navinder Brar commented on KAFKA-9757:
--
Opened a PR for this: [https://github.com/ap
Navinder Brar created KAFKA-10429:
-
Summary: Group Coordinator is unavailable leads to missing events
Key: KAFKA-10429
URL: https://issues.apache.org/jira/browse/KAFKA-10429
Project: Kafka
Is
[
https://issues.apache.org/jira/browse/KAFKA-10429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Navinder Brar updated KAFKA-10429:
--
Summary: Group Coordinator unavailability leads to missing events (was:
Group Coordinator is
[
https://issues.apache.org/jira/browse/KAFKA-7149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16900634#comment-16900634
]
Navinder Brar commented on KAFKA-7149:
--
[~vinoth] yeah feel free to reassign this to
[
https://issues.apache.org/jira/browse/KAFKA-5413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16946698#comment-16946698
]
Navinder Brar commented on KAFKA-5413:
--
Can we manually delete .index and .log files
[
https://issues.apache.org/jira/browse/KAFKA-6144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16947349#comment-16947349
]
Navinder Brar commented on KAFKA-6144:
--
[~vinoth] sorry completely forgot about this
[
https://issues.apache.org/jira/browse/KAFKA-6144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16947349#comment-16947349
]
Navinder Brar edited comment on KAFKA-6144 at 10/9/19 4:28 AM:
[
https://issues.apache.org/jira/browse/KAFKA-6144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Navinder Brar updated KAFKA-6144:
-
Attachment: image-2019-10-09-20-33-37-423.png
> Allow state stores to serve stale reads during re
[
https://issues.apache.org/jira/browse/KAFKA-6144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16947780#comment-16947780
]
Navinder Brar commented on KAFKA-6144:
--
Sure [~vinoth] I can do that. In my current
[
https://issues.apache.org/jira/browse/KAFKA-6144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16947780#comment-16947780
]
Navinder Brar edited comment on KAFKA-6144 at 10/9/19 3:18 PM:
[
https://issues.apache.org/jira/browse/KAFKA-6144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16950326#comment-16950326
]
Navinder Brar commented on KAFKA-6144:
--
[~vinoth] started a KIP today:
[https://cwi
[
https://issues.apache.org/jira/browse/KAFKA-6144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16950420#comment-16950420
]
Navinder Brar commented on KAFKA-6144:
--
Thanks, [~mjsax]. Did the needful.
> Allow
[
https://issues.apache.org/jira/browse/KAFKA-6144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16954259#comment-16954259
]
Navinder Brar commented on KAFKA-6144:
--
Can I assign this to myself as KIP is alread
[
https://issues.apache.org/jira/browse/KAFKA-6144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Navinder Brar updated KAFKA-6144:
-
Summary: Allow serving interactive queries from in-sync Standbys (was:
Allow state stores to ser
[
https://issues.apache.org/jira/browse/KAFKA-6144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Navinder Brar updated KAFKA-6144:
-
Labels: kip-535 (was: needs-kip)
> Allow serving interactive queries from in-sync Standbys
> ---
[
https://issues.apache.org/jira/browse/KAFKA-6144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Navinder Brar updated KAFKA-6144:
-
Summary: Allow state stores to serve stale reads during rebalance (was:
Allow serving interactiv
[
https://issues.apache.org/jira/browse/KAFKA-6144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Navinder Brar updated KAFKA-6144:
-
Summary: Allow serving interactive queries from in-sync Standbys (was:
Allow state stores to ser
[
https://issues.apache.org/jira/browse/KAFKA-6144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Navinder Brar updated KAFKA-6144:
-
Description:
Currently when expanding the KS cluster, the new node's partitions will be
unavaila
Navinder Brar created KAFKA-9169:
Summary: Standby Tasks point ask for incorrect offsets on resuming
post suspension
Key: KAFKA-9169
URL: https://issues.apache.org/jira/browse/KAFKA-9169
Project: Kafk
[
https://issues.apache.org/jira/browse/KAFKA-9169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16975693#comment-16975693
]
Navinder Brar commented on KAFKA-9169:
--
I can confirm that this has been there since
[
https://issues.apache.org/jira/browse/KAFKA-6144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16709086#comment-16709086
]
Navinder Brar commented on KAFKA-6144:
--
Is someone working on a patch for this? If I
[
https://issues.apache.org/jira/browse/KAFKA-6144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16714346#comment-16714346
]
Navinder Brar commented on KAFKA-6144:
--
I have made an account by id: navinder_b...@
[
https://issues.apache.org/jira/browse/KAFKA-6144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16715471#comment-16715471
]
Navinder Brar commented on KAFKA-6144:
--
Sure [~NIzhikov] , I will start writing a KI
[
https://issues.apache.org/jira/browse/KAFKA-7149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16742857#comment-16742857
]
Navinder Brar commented on KAFKA-7149:
--
[~mjsax] yeah I had submitted a PR, there we
[
https://issues.apache.org/jira/browse/KAFKA-7149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16744195#comment-16744195
]
Navinder Brar commented on KAFKA-7149:
--
[~mjsax] The PR has passed all the checks an
[
https://issues.apache.org/jira/browse/KAFKA-7149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16611610#comment-16611610
]
Navinder Brar commented on KAFKA-7149:
--
I am working with [~asurana] on raising this
[
https://issues.apache.org/jira/browse/KAFKA-7149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16611610#comment-16611610
]
Navinder Brar edited comment on KAFKA-7149 at 9/12/18 7:00 AM:
[
https://issues.apache.org/jira/browse/KAFKA-7149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16611610#comment-16611610
]
Navinder Brar edited comment on KAFKA-7149 at 9/14/18 8:01 AM:
[
https://issues.apache.org/jira/browse/KAFKA-7149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16615271#comment-16615271
]
Navinder Brar commented on KAFKA-7149:
--
Hi [~guozhang] What I mean is currently the
[
https://issues.apache.org/jira/browse/KAFKA-7149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16615271#comment-16615271
]
Navinder Brar edited comment on KAFKA-7149 at 9/14/18 7:24 PM:
[
https://issues.apache.org/jira/browse/KAFKA-7149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16615354#comment-16615354
]
Navinder Brar commented on KAFKA-7149:
--
Yes, I agree with all you explained above. B
Navinder Brar created KAFKA-6643:
Summary: Warm up new replicas from scratch when changelog topic
has retention time
Key: KAFKA-6643
URL: https://issues.apache.org/jira/browse/KAFKA-6643
Project: Kafk
[
https://issues.apache.org/jira/browse/KAFKA-6643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Navinder Brar updated KAFKA-6643:
-
Description:
In the current scenario, Kafka Streams has changelog Kafka topics(internal
topics ha
[
https://issues.apache.org/jira/browse/KAFKA-6643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Navinder Brar updated KAFKA-6643:
-
Summary: Warm up new replicas from scratch when changelog topic has LIMITED
retention time (was:
[
https://issues.apache.org/jira/browse/KAFKA-6643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Navinder Brar updated KAFKA-6643:
-
Description:
In the current scenario, Kafka Streams has changelog Kafka topics(internal
topics ha
[
https://issues.apache.org/jira/browse/KAFKA-6643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Navinder Brar updated KAFKA-6643:
-
Description:
In the current scenario, Kafka Streams has changelog Kafka topics(internal
topics ha
Navinder Brar created KAFKA-6924:
Summary: Making state store queryable on replicas
Key: KAFKA-6924
URL: https://issues.apache.org/jira/browse/KAFKA-6924
Project: Kafka
Issue Type: New Featur
[
https://issues.apache.org/jira/browse/KAFKA-6924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Navinder Brar updated KAFKA-6924:
-
Description:
State store in Kafka streams are currently only queryable when StreamTask is in
RUNN
[
https://issues.apache.org/jira/browse/KAFKA-6924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16483611#comment-16483611
]
Navinder Brar commented on KAFKA-6924:
--
Hi [~guozhang] thanks for pointing it out. I
65 matches
Mail list logo
