[jira] [Commented] (KAFKA-7206) Enable batching in FindCoordinator

[ https://issues.apache.org/jira/browse/KAFKA-7206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16850051#comment-16850051 ] Yishun Guan commented on KAFKA-7206: [~sagarrao] yes, that's basically the reason. > Enable batching

[jira] [Commented] (KAFKA-7206) Enable batching in FindCoordinator

[ https://issues.apache.org/jira/browse/KAFKA-7206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16839059#comment-16839059 ] Yishun Guan commented on KAFKA-7206: Hi [~sagarrao], feel free to take a look at this:

[jira] [Commented] (KAFKA-6460) Add mocks for state stores used in Streams unit testing

[ https://issues.apache.org/jira/browse/KAFKA-6460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16769862#comment-16769862 ] Yishun Guan commented on KAFKA-6460: Sounds good to me [~mjsax] and [~guozhang], the design scope and

[jira] [Comment Edited] (KAFKA-6460) Add mocks for state stores used in Streams unit testing

[ https://issues.apache.org/jira/browse/KAFKA-6460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16757803#comment-16757803 ] Yishun Guan edited comment on KAFKA-6460 at 1/31/19 11:32 PM: -- Hi

[jira] [Commented] (KAFKA-6460) Add mocks for state stores used in Streams unit testing

[ https://issues.apache.org/jira/browse/KAFKA-6460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16757803#comment-16757803 ] Yishun Guan commented on KAFKA-6460: Hi [~guozhang] , I still not quite understand - so we should

[jira] [Assigned] (KAFKA-6460) Add mocks for state stores used in Streams unit testing

[ https://issues.apache.org/jira/browse/KAFKA-6460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yishun Guan reassigned KAFKA-6460: -- Assignee: Yishun Guan > Add mocks for state stores used in Streams unit testing >

[jira] [Commented] (KAFKA-7699) Improve wall-clock time punctuations

[ https://issues.apache.org/jira/browse/KAFKA-7699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16744402#comment-16744402 ] Yishun Guan commented on KAFKA-7699: [~mjsax] Oh I see now I have more context. Thanks! > Improve

[jira] [Commented] (KAFKA-6460) Add mocks for state stores used in Streams unit testing

[ https://issues.apache.org/jira/browse/KAFKA-6460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16736402#comment-16736402 ] Yishun Guan commented on KAFKA-6460: Hi [~guozhang] , I am still interested if nobody else is looking 

[jira] [Commented] (KAFKA-7699) Improve wall-clock time punctuations

[ https://issues.apache.org/jira/browse/KAFKA-7699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16736364#comment-16736364 ] Yishun Guan commented on KAFKA-7699: Hi, just curious (I am not an expert in this), why won't

[jira] [Comment Edited] (KAFKA-7699) Improve wall-clock time punctuations

[ https://issues.apache.org/jira/browse/KAFKA-7699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16736364#comment-16736364 ] Yishun Guan edited comment on KAFKA-7699 at 1/7/19 9:16 PM: Hi, just curious

[jira] [Assigned] (KAFKA-7402) Kafka Streams should implement AutoCloseable where appropriate

[ https://issues.apache.org/jira/browse/KAFKA-7402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yishun Guan reassigned KAFKA-7402: -- Assignee: Yishun Guan > Kafka Streams should implement AutoCloseable where appropriate >

[jira] [Commented] (KAFKA-7402) Kafka Streams should implement AutoCloseable where appropriate

[ https://issues.apache.org/jira/browse/KAFKA-7402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16619541#comment-16619541 ] Yishun Guan commented on KAFKA-7402: Hi [~vvcephei], should we create an KIP for KafkaStream first or

[jira] [Assigned] (KAFKA-7206) Enable batching in FindCoordinator

[ https://issues.apache.org/jira/browse/KAFKA-7206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yishun Guan reassigned KAFKA-7206: -- Assignee: Yishun Guan > Enable batching in FindCoordinator >

[jira] [Updated] (KAFKA-7206) Enable batching in FindCoordinator

[ https://issues.apache.org/jira/browse/KAFKA-7206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yishun Guan updated KAFKA-7206: --- Description: To quote [~guozhang] : "The proposal is that, we extend FindCoordinatorRequest to have

[jira] [Updated] (KAFKA-7206) Enable batching in FindCoordinator

[ https://issues.apache.org/jira/browse/KAFKA-7206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yishun Guan updated KAFKA-7206: --- Labels: needs-discussion needs-kip newbie++ (was: newbie++) > Enable batching in FindCoordinator >

[jira] [Updated] (KAFKA-7206) Enable batching in FindCoordinator

[ https://issues.apache.org/jira/browse/KAFKA-7206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yishun Guan updated KAFKA-7206: --- Description: To quote [~guozhang] : "The proposal is that, we extend FindCoordinatorRequest to have

[jira] [Updated] (KAFKA-7206) Enable batching in FindCoordinator

[ https://issues.apache.org/jira/browse/KAFKA-7206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yishun Guan updated KAFKA-7206: --- Description: To quote [~guozhang] : "The proposal is that, we extend FindCoordinatorRequest to have

[jira] [Updated] (KAFKA-7206) Enable batching in FindCoordinator

[ https://issues.apache.org/jira/browse/KAFKA-7206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yishun Guan updated KAFKA-7206: --- Labels: newbie++ (was: ) > Enable batching in FindCoordinator > --

[jira] [Created] (KAFKA-7206) Enable batching in FindCoordinator

Yishun Guan created KAFKA-7206: -- Summary: Enable batching in FindCoordinator Key: KAFKA-7206 URL: https://issues.apache.org/jira/browse/KAFKA-7206 Project: Kafka Issue Type: Improvement

[jira] [Resolved] (KAFKA-5447) AdminClient metrics

[ https://issues.apache.org/jira/browse/KAFKA-5447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yishun Guan resolved KAFKA-5447. Resolution: Fixed

[jira] [Commented] (KAFKA-5447) AdminClient metrics

[ https://issues.apache.org/jira/browse/KAFKA-5447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16544308#comment-16544308 ] Yishun Guan commented on KAFKA-5447: This is resolved with 

[jira] [Assigned] (KAFKA-5447) AdminClient metrics

[ https://issues.apache.org/jira/browse/KAFKA-5447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yishun Guan reassigned KAFKA-5447: -- Assignee: Yishun Guan > AdminClient metrics > --- > > Key:

[jira] [Updated] (KAFKA-7146) Grouping consumer requests per consumer coordinator in admin client in describeConsumerGroups

[ https://issues.apache.org/jira/browse/KAFKA-7146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yishun Guan updated KAFKA-7146: --- Description: Subtask of KAFKA-6788. Group consumer requests for describeConsumerGroups().  

[jira] [Assigned] (KAFKA-7146) Grouping consumer requests per consumer coordinator in admin client in describeConsumerGroups

[ https://issues.apache.org/jira/browse/KAFKA-7146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yishun Guan reassigned KAFKA-7146: -- Assignee: Yishun Guan > Grouping consumer requests per consumer coordinator in admin client

[jira] [Updated] (KAFKA-7146) Grouping consumer requests per consumer coordinator in admin client in describeConsumerGroups

[ https://issues.apache.org/jira/browse/KAFKA-7146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yishun Guan updated KAFKA-7146: --- Description: Subtask of KAFKA-6788. Group consumer requests for describeConsumerGroups().  

[jira] [Created] (KAFKA-7146) Grouping consumer requests per consumer coordinator in admin client in describeConsumerGroups

Yishun Guan created KAFKA-7146: -- Summary: Grouping consumer requests per consumer coordinator in admin client in describeConsumerGroups Key: KAFKA-7146 URL: https://issues.apache.org/jira/browse/KAFKA-7146

[jira] [Commented] (KAFKA-6788) Grouping consumer requests per consumer coordinator in admin client

[ https://issues.apache.org/jira/browse/KAFKA-6788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16535308#comment-16535308 ] Yishun Guan commented on KAFKA-6788: Hi, I will work on this issue from scratch then? > Grouping

[jira] [Commented] (KAFKA-6788) Grouping consumer requests per consumer coordinator in admin client

[ https://issues.apache.org/jira/browse/KAFKA-6788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16530469#comment-16530469 ] Yishun Guan commented on KAFKA-6788: Does it have a retry mechanism now? I am looking at KAKFA-6789

[jira] [Assigned] (KAFKA-6755) MaskField SMT should optionally take a literal value to use instead of using null

[ https://issues.apache.org/jira/browse/KAFKA-6755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yishun Guan reassigned KAFKA-6755: -- Assignee: (was: Yishun Guan) > MaskField SMT should optionally take a literal value to

[jira] [Assigned] (KAFKA-6755) MaskField SMT should optionally take a literal value to use instead of using null

[ https://issues.apache.org/jira/browse/KAFKA-6755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yishun Guan reassigned KAFKA-6755: -- Assignee: Yishun Guan > MaskField SMT should optionally take a literal value to use instead

[jira] [Commented] (KAFKA-6755) MaskField SMT should optionally take a literal value to use instead of using null

[ https://issues.apache.org/jira/browse/KAFKA-6755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16528306#comment-16528306 ] Yishun Guan commented on KAFKA-6755: [~rhauch] [~jingc]Hi, is anyone working on this story? If no, I