[jira] [Commented] (KAFKA-6964) Add ability to print all internal topic names

[ https://issues.apache.org/jira/browse/KAFKA-6964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16524058#comment-16524058 ] Jagadesh Adireddi commented on KAFKA-6964: -- Got it [~bbejeck]... Should we skip this feature for

[jira] [Comment Edited] (KAFKA-6964) Add ability to print all internal topic names

[ https://issues.apache.org/jira/browse/KAFKA-6964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16523810#comment-16523810 ] Jagadesh Adireddi edited comment on KAFKA-6964 at 6/26/18 2:38 PM: ---

[jira] [Commented] (KAFKA-6964) Add ability to print all internal topic names

[ https://issues.apache.org/jira/browse/KAFKA-6964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16523810#comment-16523810 ] Jagadesh Adireddi commented on KAFKA-6964: -- [~mjsax],  After revisiting code, got 2 points in

[jira] [Commented] (KAFKA-6964) Add ability to print all internal topic names

[ https://issues.apache.org/jira/browse/KAFKA-6964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16507936#comment-16507936 ] Jagadesh Adireddi commented on KAFKA-6964: -- Hi [~bbejeck], Just trying to make myself clear. If

[jira] [Assigned] (KAFKA-6964) Add ability to print all internal topic names

[ https://issues.apache.org/jira/browse/KAFKA-6964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadesh Adireddi reassigned KAFKA-6964: Assignee: Jagadesh Adireddi > Add ability to print all internal topic names >

[jira] [Assigned] (KAFKA-7015) Enhance RecordCollectorImpl exceptions with more context information

[ https://issues.apache.org/jira/browse/KAFKA-7015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadesh Adireddi reassigned KAFKA-7015: Assignee: Jagadesh Adireddi > Enhance RecordCollectorImpl exceptions with more

[jira] [Commented] (KAFKA-6906) Kafka Streams does not commit transactions if data is produced via wall-clock punctuation

[ https://issues.apache.org/jira/browse/KAFKA-6906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16494742#comment-16494742 ] Jagadesh Adireddi commented on KAFKA-6906: -- [~guozhang], Thank you for the conformation. Will 

[jira] [Commented] (KAFKA-6906) Kafka Streams does not commit transactions if data is produced via wall-clock punctuation

[ https://issues.apache.org/jira/browse/KAFKA-6906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16494692#comment-16494692 ] Jagadesh Adireddi commented on KAFKA-6906: -- [~mjsax], should we keep using `commitOffsetNeeded` 

[jira] [Comment Edited] (KAFKA-6906) Kafka Streams does not commit transactions if data is produced via wall-clock punctuation

[ https://issues.apache.org/jira/browse/KAFKA-6906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16492827#comment-16492827 ] Jagadesh Adireddi edited comment on KAFKA-6906 at 5/28/18 5:00 PM: --- Hi

[jira] [Comment Edited] (KAFKA-6906) Kafka Streams does not commit transactions if data is produced via wall-clock punctuation

[ https://issues.apache.org/jira/browse/KAFKA-6906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16492827#comment-16492827 ] Jagadesh Adireddi edited comment on KAFKA-6906 at 5/28/18 5:06 PM: --- Hi

[jira] [Commented] (KAFKA-6906) Kafka Streams does not commit transactions if data is produced via wall-clock punctuation

[ https://issues.apache.org/jira/browse/KAFKA-6906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16492827#comment-16492827 ] Jagadesh Adireddi commented on KAFKA-6906: -- Hi [~mjsax], Sorry for the late response. I am on

[jira] [Commented] (KAFKA-6906) Kafka Streams does not commit transactions if data is produced via wall-clock punctuation

[ https://issues.apache.org/jira/browse/KAFKA-6906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16477158#comment-16477158 ] Jagadesh Adireddi commented on KAFKA-6906: -- [~mjsax], Identified fix for this. Once we decide to

[jira] [Assigned] (KAFKA-6906) Kafka Streams does not commit transactions if data is produced via wall-clock punctuation

[ https://issues.apache.org/jira/browse/KAFKA-6906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadesh Adireddi reassigned KAFKA-6906: Assignee: Jagadesh Adireddi > Kafka Streams does not commit transactions if data

[jira] [Commented] (KAFKA-6677) Remove EOS producer config max.in.flight.request.per.connection=1

[ https://issues.apache.org/jira/browse/KAFKA-6677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16437360#comment-16437360 ] Jagadesh Adireddi commented on KAFKA-6677: -- Hi @mjsax , Fixed `StreamsConfig` to set the default

[jira] [Assigned] (KAFKA-6677) Remove EOS producer config max.in.flight.request.per.connection=1

[ https://issues.apache.org/jira/browse/KAFKA-6677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadesh Adireddi reassigned KAFKA-6677: Assignee: Jagadesh Adireddi > Remove EOS producer config

[jira] [Commented] (KAFKA-6677) Remove EOS producer config max.in.flight.request.per.connection=1

[ https://issues.apache.org/jira/browse/KAFKA-6677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16433723#comment-16433723 ] Jagadesh Adireddi commented on KAFKA-6677: -- Hi [~mjsax], I am thinking to contribute to this

[jira] [Assigned] (KAFKA-6749) TopologyTestDriver fails when topoloy under test uses EXACTLY_ONCE

[ https://issues.apache.org/jira/browse/KAFKA-6749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadesh Adireddi reassigned KAFKA-6749: Assignee: Jagadesh Adireddi > TopologyTestDriver fails when topoloy under test

[jira] [Commented] (KAFKA-5253) TopologyTestDriver must handle streams created with patterns

[ https://issues.apache.org/jira/browse/KAFKA-5253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16427284#comment-16427284 ] Jagadesh Adireddi commented on KAFKA-5253: -- Hi [~mjsax], Made changes to `{{TopologyTestDriver`}} 

[jira] [Assigned] (KAFKA-6538) Enhance ByteStore exceptions with more context information

[ https://issues.apache.org/jira/browse/KAFKA-6538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadesh Adireddi reassigned KAFKA-6538: Assignee: Jagadesh Adireddi > Enhance ByteStore exceptions with more context

[jira] [Commented] (KAFKA-6538) Enhance ByteStore exceptions with more context information

[ https://issues.apache.org/jira/browse/KAFKA-6538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16420657#comment-16420657 ] Jagadesh Adireddi commented on KAFKA-6538: -- Hi [~mjsax], To work on this ticket, I would like to 

[jira] [Commented] (KAFKA-5253) TopologyTestDriver must handle streams created with patterns

[ https://issues.apache.org/jira/browse/KAFKA-5253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16417896#comment-16417896 ] Jagadesh Adireddi commented on KAFKA-5253: -- Hi [~mjsax], I am new to Kafka contribution. I made

[jira] [Assigned] (KAFKA-5253) TopologyTestDriver must handle streams created with patterns

[ https://issues.apache.org/jira/browse/KAFKA-5253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadesh Adireddi reassigned KAFKA-5253: Assignee: Jagadesh Adireddi > TopologyTestDriver must handle streams created with

[jira] [Assigned] (KAFKA-6685) Connect deserialization log message should distinguish key from value

[ https://issues.apache.org/jira/browse/KAFKA-6685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadesh Adireddi reassigned KAFKA-6685: Assignee: Jagadesh Adireddi > Connect deserialization log message should

[jira] [Comment Edited] (KAFKA-6685) Connect deserialization log message should distinguish key from value

[ https://issues.apache.org/jira/browse/KAFKA-6685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16406081#comment-16406081 ] Jagadesh Adireddi edited comment on KAFKA-6685 at 3/22/18 12:28 PM: Hi

[jira] [Commented] (KAFKA-6685) Connect deserialization log message should distinguish key from value

[ https://issues.apache.org/jira/browse/KAFKA-6685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16407436#comment-16407436 ] Jagadesh Adireddi commented on KAFKA-6685: -- Hi , I am unable to assign this issue to myself. I

[jira] [Comment Edited] (KAFKA-6685) Connect deserialization log message should distinguish key from value

[ https://issues.apache.org/jira/browse/KAFKA-6685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16406081#comment-16406081 ] Jagadesh Adireddi edited comment on KAFKA-6685 at 3/20/18 10:25 AM: Hi

[jira] [Commented] (KAFKA-6629) SegmentedCacheFunctionTest does not cover session window serdes

[ https://issues.apache.org/jira/browse/KAFKA-6629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16405191#comment-16405191 ] Jagadesh Adireddi commented on KAFKA-6629: -- Hi Guozhang Thank you  for the information. I  got

[jira] [Commented] (KAFKA-6629) SegmentedCacheFunctionTest does not cover session window serdes

[ https://issues.apache.org/jira/browse/KAFKA-6629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16404947#comment-16404947 ] Jagadesh Adireddi commented on KAFKA-6629: -- Hi [~guozhang], I am new to kafka contribution. I am