[jira] [Updated] (KAFKA-10429) Group Coordinator unavailability leads to missing events

[ 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

[jira] [Created] (KAFKA-10429) Group Coordinator is unavailable leads to missing events

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

[jira] [Commented] (KAFKA-9757) Add documentation change for KIP-535

[ https://issues.apache.org/jira/browse/KAFKA-9757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17071906#comment-17071906 ] Navinder Brar commented on KAFKA-9757: -- Opened a PR for this: 

[jira] [Commented] (KAFKA-9757) Add documentation change for KIP-535

[ https://issues.apache.org/jira/browse/KAFKA-9757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17071251#comment-17071251 ] Navinder Brar commented on KAFKA-9757: -- Hey [~vinoth], if you are busy I can take this up. I am also

[jira] [Commented] (KAFKA-7480) 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=17059997#comment-17059997 ] Navinder Brar commented on KAFKA-7480: -- Sure, thanks Matthias. I will assign this to myself. >

[jira] [Assigned] (KAFKA-7480) GlobalThread should honor custom auto.offset.reset policy

[ 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 >

[jira] [Commented] (KAFKA-7480) 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=17059905#comment-17059905 ] Navinder Brar commented on KAFKA-7480: -- Hi [~mjsax] can I take up this up? I didn't understand why

[jira] [Updated] (KAFKA-9588) Add rocksdb event listeners in KS

[ 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)

[jira] [Updated] (KAFKA-9588) Add rocksdb event listeners in KS

[ 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)

[jira] [Created] (KAFKA-9588) Add rocksdb event listeners in KS

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

[jira] [Commented] (KAFKA-9450) Decouple inner state flushing from committing

[ https://issues.apache.org/jira/browse/KAFKA-9450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17036093#comment-17036093 ] Navinder Brar commented on KAFKA-9450: -- Sure, [~ableegoldman]. I will create a ticket. Checked with

[jira] [Resolved] (KAFKA-9487) Followup : KAFKA-9445(Allow fetching a key from a single partition); addressing code review comments

[ 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); >

[jira] [Comment Edited] (KAFKA-9450) Decouple inner state flushing from committing with EOS

[ https://issues.apache.org/jira/browse/KAFKA-9450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17025550#comment-17025550 ] Navinder Brar edited comment on KAFKA-9450 at 2/9/20 9:19 AM: -- Checked

[jira] [Updated] (KAFKA-9487) Followup : KAFKA-9445(Allow fetching a key from a single partition); addressing code review comments

[ 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

[jira] [Updated] (KAFKA-9487) Followup : KAFKA-9445(Allow fetching a key from a single partition), addressing code review comments

[ 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

[jira] [Updated] (KAFKA-9487) Followup : KAFKA-9445

[ 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

[jira] [Issue Comment Deleted] (KAFKA-9487) Followup : KAFKA-9445

[ 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,

[jira] [Commented] (KAFKA-9487) Followup : KAFKA-9445

[ https://issues.apache.org/jira/browse/KAFKA-9487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17027318#comment-17027318 ] Navinder Brar commented on KAFKA-9487: -- A few code review comments are left to be addressed from

[jira] [Created] (KAFKA-9487) Followup : KAFKA-9445

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

[jira] [Commented] (KAFKA-9450) Decouple inner state flushing from committing with EOS

[ https://issues.apache.org/jira/browse/KAFKA-9450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17025550#comment-17025550 ] Navinder Brar commented on KAFKA-9450: -- Checked Rocksdb code, event listeners are not available in

[jira] [Commented] (KAFKA-9450) Decouple inner state flushing from committing with EOS

[ https://issues.apache.org/jira/browse/KAFKA-9450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17024902#comment-17024902 ] Navinder Brar commented on KAFKA-9450: -- Or do you suggest to never (ie, for EOS and non-EOS case)

[jira] [Comment Edited] (KAFKA-9450) Decouple inner state flushing from committing with EOS

[ https://issues.apache.org/jira/browse/KAFKA-9450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17023643#comment-17023643 ] Navinder Brar edited comment on KAFKA-9450 at 1/25/20 8:38 PM: --- Great that

[jira] [Commented] (KAFKA-9450) Decouple inner state flushing from committing with EOS

[ https://issues.apache.org/jira/browse/KAFKA-9450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17023643#comment-17023643 ] Navinder Brar commented on KAFKA-9450: -- Great that I caught hold of this Jira. I had been meaning to

[jira] [Updated] (KAFKA-9445) Allow fetching a key from a single partition rather than iterating over all the stores on an instance

[ 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:

[jira] [Updated] (KAFKA-9445) Allow fetching a key from a single partition rather than iterating over all the stores on an instance

[ https://issues.apache.org/jira/browse/KAFKA-9445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Navinder Brar updated KAFKA-9445: - Labels:

[jira] [Updated] (KAFKA-9445) Allow fetching a key from a single partition rather than iterating over all the stores on an instance

[ 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,

[jira] [Updated] (KAFKA-9445) Allow fetching a key from a single partition rather than iterating over all the stores on an instance

[ 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

[jira] [Updated] (KAFKA-9445) Allow fetching a key from a single partition rather than iterating over all the stores on an instance

[ 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

[jira] [Created] (KAFKA-9445) Allow fetching a key from a single partition rather than iterating over all the stores on an instance

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:

[jira] [Commented] (KAFKA-9169) Standby Tasks point ask for incorrect offsets on resuming post suspension

[ https://issues.apache.org/jira/browse/KAFKA-9169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16975693#comment-16975693 ] Navinder Brar commented on KAFKA-9169: -- I can confirm that this has been there since 1.1 version. >

[jira] [Created] (KAFKA-9169) Standby Tasks point ask for incorrect offsets on resuming post suspension

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:

[jira] [Updated] (KAFKA-6144) 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: - Description: Currently when expanding the KS cluster, the new node's partitions will be

[jira] [Updated] (KAFKA-6144) 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 serving interactive queries from in-sync Standbys (was: Allow state stores to

[jira] [Updated] (KAFKA-6144) Allow state stores to serve stale reads during rebalance

[ 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

[jira] [Updated] (KAFKA-6144) 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: - Labels: kip-535 (was: needs-kip) > Allow serving interactive queries from in-sync Standbys >

[jira] [Updated] (KAFKA-6144) 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 serving interactive queries from in-sync Standbys (was: Allow state stores to

[jira] [Commented] (KAFKA-6144) Allow state stores to serve stale reads during rebalance

[ https://issues.apache.org/jira/browse/KAFKA-6144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16954259#comment-16954259 ] Navinder Brar commented on KAFKA-6144: -- Can I assign this to myself as KIP is already created.  >

[jira] [Commented] (KAFKA-6144) Allow state stores to serve stale reads during rebalance

[ https://issues.apache.org/jira/browse/KAFKA-6144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16950420#comment-16950420 ] Navinder Brar commented on KAFKA-6144: -- Thanks, [~mjsax]. Did the needful.  > Allow state stores to

[jira] [Commented] (KAFKA-6144) Allow state stores to serve stale reads during rebalance

[ https://issues.apache.org/jira/browse/KAFKA-6144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16950326#comment-16950326 ] Navinder Brar commented on KAFKA-6144: -- [~vinoth] started a KIP today: 

[jira] [Comment Edited] (KAFKA-6144) Allow state stores to serve stale reads during rebalance

[ https://issues.apache.org/jira/browse/KAFKA-6144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16947780#comment-16947780 ] Navinder Brar edited comment on KAFKA-6144 at 10/9/19 3:18 PM: --- Sure

[jira] [Commented] (KAFKA-6144) Allow state stores to serve stale reads during rebalance

[ https://issues.apache.org/jira/browse/KAFKA-6144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16947780#comment-16947780 ] Navinder Brar commented on KAFKA-6144: -- Sure [~vinoth] I can do that. In my current project I have

[jira] [Updated] (KAFKA-6144) Allow state stores to serve stale reads during rebalance

[ 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

[jira] [Comment Edited] (KAFKA-6144) Allow state stores to serve stale reads during rebalance

[ https://issues.apache.org/jira/browse/KAFKA-6144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16947349#comment-16947349 ] Navinder Brar edited comment on KAFKA-6144 at 10/9/19 4:28 AM: --- [~vinoth] 

[jira] [Commented] (KAFKA-6144) Allow state stores to serve stale reads during rebalance

[ https://issues.apache.org/jira/browse/KAFKA-6144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16947349#comment-16947349 ] Navinder Brar commented on KAFKA-6144: -- [~vinoth] sorry completely forgot about this one. I had

[jira] [Commented] (KAFKA-5413) Log cleaner fails due to large offset in segment file

[ https://issues.apache.org/jira/browse/KAFKA-5413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16946698#comment-16946698 ] Navinder Brar commented on KAFKA-5413: -- Can we manually delete .index and .log files for that

[jira] [Commented] (KAFKA-7149) Reduce assignment data size to improve kafka streams scalability

[ https://issues.apache.org/jira/browse/KAFKA-7149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16900634#comment-16900634 ] Navinder Brar commented on KAFKA-7149: -- [~vinoth] yeah feel free to reassign this to yourself. >

[jira] [Commented] (KAFKA-7149) Reduce assignment data size to improve kafka streams scalability

[ https://issues.apache.org/jira/browse/KAFKA-7149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16744195#comment-16744195 ] Navinder Brar commented on KAFKA-7149: -- [~mjsax] The PR has passed all the checks and code review

[jira] [Commented] (KAFKA-7149) Reduce assignment data size to improve kafka streams scalability

[ https://issues.apache.org/jira/browse/KAFKA-7149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16742857#comment-16742857 ] Navinder Brar commented on KAFKA-7149: -- [~mjsax] yeah I had submitted a PR, there were some core

[jira] [Commented] (KAFKA-6144) Allow state stores to serve stale reads during rebalance

[ https://issues.apache.org/jira/browse/KAFKA-6144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16715471#comment-16715471 ] Navinder Brar commented on KAFKA-6144: -- Sure [~NIzhikov] , I will start writing a KIP. > Allow

[jira] [Commented] (KAFKA-6144) Allow state stores to serve stale reads during rebalance

[ https://issues.apache.org/jira/browse/KAFKA-6144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16714346#comment-16714346 ] Navinder Brar commented on KAFKA-6144: -- I have made an account by id: navinder_b...@yahoo.com. You

[jira] [Commented] (KAFKA-6144) Allow state stores to serve stale reads during rebalance

[ https://issues.apache.org/jira/browse/KAFKA-6144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16709086#comment-16709086 ] Navinder Brar commented on KAFKA-6144: -- Is someone working on a patch for this? If I understand

[jira] [Commented] (KAFKA-7149) Reduce assignment data size to improve kafka streams scalability

[ https://issues.apache.org/jira/browse/KAFKA-7149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16615354#comment-16615354 ] Navinder Brar commented on KAFKA-7149: -- Yes, I agree with all you explained above. But for all the

[jira] [Comment Edited] (KAFKA-7149) Reduce assignment data size to improve kafka streams scalability

[ https://issues.apache.org/jira/browse/KAFKA-7149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16615271#comment-16615271 ] Navinder Brar edited comment on KAFKA-7149 at 9/14/18 7:24 PM: --- Hi

[jira] [Commented] (KAFKA-7149) Reduce assignment data size to improve kafka streams scalability

[ https://issues.apache.org/jira/browse/KAFKA-7149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16615271#comment-16615271 ] Navinder Brar commented on KAFKA-7149: -- Hi [~guozhang] What I mean is currently the Assignment which

[jira] [Comment Edited] (KAFKA-7149) Reduce assignment data size to improve kafka streams scalability

[ https://issues.apache.org/jira/browse/KAFKA-7149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16611610#comment-16611610 ] Navinder Brar edited comment on KAFKA-7149 at 9/14/18 8:01 AM: --- [~guozhang]

[jira] [Comment Edited] (KAFKA-7149) Reduce assignment data size to improve kafka streams scalability

[ https://issues.apache.org/jira/browse/KAFKA-7149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16611610#comment-16611610 ] Navinder Brar edited comment on KAFKA-7149 at 9/12/18 7:00 AM: --- [~guozhang]

[jira] [Commented] (KAFKA-7149) Reduce assignment data size to improve kafka streams scalability

[ https://issues.apache.org/jira/browse/KAFKA-7149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16611610#comment-16611610 ] Navinder Brar commented on KAFKA-7149: -- I am working with [~asurana] on raising this PR, will send

[jira] [Commented] (KAFKA-6924) Making state store queryable on replicas

[ https://issues.apache.org/jira/browse/KAFKA-6924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16483611#comment-16483611 ] Navinder Brar commented on KAFKA-6924: -- Hi [~guozhang] thanks for pointing it out. I believe it is

[jira] [Updated] (KAFKA-6643) Warm up new replicas from scratch when changelog topic has LIMITED retention time

[ 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

[jira] [Updated] (KAFKA-6643) Warm up new replicas from scratch when changelog topic has LIMITED retention time

[ 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

[jira] [Updated] (KAFKA-6643) Warm up new replicas from scratch when changelog topic has LIMITED retention time

[ 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:

[jira] [Updated] (KAFKA-6643) Warm up new replicas from scratch when changelog topic has retention time

[ 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

[jira] [Created] (KAFKA-6643) Warm up new replicas from scratch when changelog topic has retention time

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: