[jira] [Commented] (KAFKA-7768) Java doc link 404

[ https://issues.apache.org/jira/browse/KAFKA-7768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16736529#comment-16736529 ] ASF GitHub Bot commented on KAFKA-7768: --- guozhangwang commented on pull request #178: KAFKA-7768:

[jira] [Commented] (KAFKA-7768) Java doc link 404

[ https://issues.apache.org/jira/browse/KAFKA-7768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16736423#comment-16736423 ] ASF GitHub Bot commented on KAFKA-7768: --- vvcephei commented on pull request #178: KAFKA-7768: Use

[jira] [Commented] (KAFKA-7786) Fast update of leader epoch may stall partition fetching due to FENCED_LEADER_EPOCH

[ https://issues.apache.org/jira/browse/KAFKA-7786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16736420#comment-16736420 ] Anna Povzner commented on KAFKA-7786: - Hi [~junrao], thanks for the comment. I recently talked to

[jira] [Commented] (KAFKA-7786) Fast update of leader epoch may stall partition fetching due to FENCED_LEADER_EPOCH

[ https://issues.apache.org/jira/browse/KAFKA-7786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16736415#comment-16736415 ] Jun Rao commented on KAFKA-7786: Great find, Anna. About the fix. I am not sure that we need the protocol

[jira] [Commented] (KAFKA-7786) Fast update of leader epoch may stall partition fetching due to FENCED_LEADER_EPOCH

[ https://issues.apache.org/jira/browse/KAFKA-7786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16736416#comment-16736416 ] ASF GitHub Bot commented on KAFKA-7786: --- apovzner commented on pull request #6101: KAFKA-7786:

[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=16736406#comment-16736406 ] Guozhang Wang commented on KAFKA-6460: -- Great! Feel free to look at KIP-267 for the context of 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=16736402#comment-16736402 ] Yishun Guan commented on KAFKA-6460: Hi [~guozhang] , I am still interested if nobody else is looking 

[jira] [Created] (KAFKA-7793) Improve the Trogdor command-line

Colin P. McCabe created KAFKA-7793: -- Summary: Improve the Trogdor command-line Key: KAFKA-7793 URL: https://issues.apache.org/jira/browse/KAFKA-7793 Project: Kafka Issue Type: Improvement

[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=16736399#comment-16736399 ] Guozhang Wang commented on KAFKA-6460: -- It should be part of the public test-utils package, and this

[jira] [Resolved] (KAFKA-4218) Enable access to key in ValueTransformer

[ https://issues.apache.org/jira/browse/KAFKA-4218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-4218. -- Resolution: Fixed Fix Version/s: (was: 1.1.0) 2.1.0 This has

[jira] [Commented] (KAFKA-7768) Java doc link 404

[ https://issues.apache.org/jira/browse/KAFKA-7768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16736382#comment-16736382 ] ASF GitHub Bot commented on KAFKA-7768: --- guozhangwang commented on pull request #6100: KAFKA-7768:

[jira] [Assigned] (KAFKA-3729) Auto-configure non-default SerDes passed alongside the topology builder

[ https://issues.apache.org/jira/browse/KAFKA-3729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-3729: Assignee: (was: Bharat Viswanadham) > Auto-configure non-default SerDes passed

[jira] [Updated] (KAFKA-4468) Correctly calculate the window end timestamp after read from state stores

[ https://issues.apache.org/jira/browse/KAFKA-4468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4468: - Fix Version/s: 2.2.0 > Correctly calculate the window end timestamp after read from state stores

[jira] [Commented] (KAFKA-4468) Correctly calculate the window end timestamp after read from state stores

[ https://issues.apache.org/jira/browse/KAFKA-4468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16736369#comment-16736369 ] Guozhang Wang commented on KAFKA-4468: -- With

[jira] [Resolved] (KAFKA-4468) Correctly calculate the window end timestamp after read from state stores

[ https://issues.apache.org/jira/browse/KAFKA-4468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-4468. -- Resolution: Fixed Assignee: Richard Yu > Correctly calculate the window end timestamp

[jira] [Commented] (KAFKA-7051) Improve the efficiency of the ReplicaManager when there are many partitions

[ https://issues.apache.org/jira/browse/KAFKA-7051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16736367#comment-16736367 ] ASF GitHub Bot commented on KAFKA-7051: --- cmccabe commented on pull request #5206: KAFKA-7051:

[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] [Commented] (KAFKA-7768) Java doc link 404

[ https://issues.apache.org/jira/browse/KAFKA-7768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16736336#comment-16736336 ] ASF GitHub Bot commented on KAFKA-7768: --- vvcephei commented on pull request #6100: KAFKA-7768: Use

[jira] [Updated] (KAFKA-7102) Error in fetch kafka.server.ReplicaFetcherThread$FetchRequest@10c8df20

[ https://issues.apache.org/jira/browse/KAFKA-7102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-7102: - Component/s: (was: KafkaConnect) core > Error in fetch

[jira] [Created] (KAFKA-7792) Trogdor should have an uptime function

Colin P. McCabe created KAFKA-7792: -- Summary: Trogdor should have an uptime function Key: KAFKA-7792 URL: https://issues.apache.org/jira/browse/KAFKA-7792 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-7160) Add check for group ID length

[ https://issues.apache.org/jira/browse/KAFKA-7160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16736238#comment-16736238 ] roo commented on KAFKA-7160: PR created no 6098, but I can't assign the issue to myself  > Add check for

[jira] [Commented] (KAFKA-7160) Add check for group ID length

[ https://issues.apache.org/jira/browse/KAFKA-7160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16736220#comment-16736220 ] ASF GitHub Bot commented on KAFKA-7160: --- rosama86 commented on pull request #6098: KAFKA-7160 Add

[jira] [Resolved] (KAFKA-7755) Kubernetes - Kafka clients are resolving DNS entries only one time

[ https://issues.apache.org/jira/browse/KAFKA-7755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-7755. --- Resolution: Fixed Fix Version/s: 2.1.1 2.2.0 > Kubernetes - Kafka

[jira] [Commented] (KAFKA-7160) Add check for group ID length

[ https://issues.apache.org/jira/browse/KAFKA-7160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16736147#comment-16736147 ] Radwa Osama commented on KAFKA-7160: Hi all, it seems that no one is working on this one, so will

[jira] [Commented] (KAFKA-5061) client.id should be set for Connect producers/consumers

[ https://issues.apache.org/jira/browse/KAFKA-5061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16736139#comment-16736139 ] Paul Davidson commented on KAFKA-5061: -- I have created a alternative PR after comments from

[jira] [Commented] (KAFKA-3184) Add Checkpoint for In-memory State Store

[ https://issues.apache.org/jira/browse/KAFKA-3184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16736113#comment-16736113 ] Guozhang Wang commented on KAFKA-3184: -- [~Yohan123] I think you are right: currently `persistent()`

[jira] [Commented] (KAFKA-7757) Too many open files after java.io.IOException: Connection to n was disconnected before the response was read

[ https://issues.apache.org/jira/browse/KAFKA-7757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16736064#comment-16736064 ] Rajini Sivaram commented on KAFKA-7757: --- Thank you [~jnadler]! > Too many open files after

[jira] [Resolved] (KAFKA-7768) Java doc link 404

[ https://issues.apache.org/jira/browse/KAFKA-7768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-7768. -- Resolution: Fixed Fix Version/s: 2.1.1 2.2.0 > Java doc link 404 >

[jira] [Commented] (KAFKA-7768) Java doc link 404

[ https://issues.apache.org/jira/browse/KAFKA-7768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16736072#comment-16736072 ] ASF GitHub Bot commented on KAFKA-7768: --- guozhangwang commented on pull request #6094: KAFKA-7768:

[jira] [Commented] (KAFKA-7768) Java doc link 404

[ https://issues.apache.org/jira/browse/KAFKA-7768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16736068#comment-16736068 ] ASF GitHub Bot commented on KAFKA-7768: --- guozhangwang commented on pull request #176: KAFKA-7768:

[jira] [Commented] (KAFKA-7743) "pure virtual method called" error message thrown for unit tests which PASS

[ https://issues.apache.org/jira/browse/KAFKA-7743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16736065#comment-16736065 ] Guozhang Wang commented on KAFKA-7743: -- I meant to have this parameter set to 1 (if I do not

[jira] [Created] (KAFKA-7791) Not log retriable exceptions as errors

Yaroslav Klymko created KAFKA-7791: -- Summary: Not log retriable exceptions as errors Key: KAFKA-7791 URL: https://issues.apache.org/jira/browse/KAFKA-7791 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-7757) Too many open files after java.io.IOException: Connection to n was disconnected before the response was read

[ https://issues.apache.org/jira/browse/KAFKA-7757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16736039#comment-16736039 ] Jeff Nadler commented on KAFKA-7757: [~rsivaram] please see attached file [^fd-spike-threads.txt] it

[jira] [Updated] (KAFKA-7757) Too many open files after java.io.IOException: Connection to n was disconnected before the response was read

[ https://issues.apache.org/jira/browse/KAFKA-7757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Nadler updated KAFKA-7757: --- Attachment: fd-spike-threads.txt > Too many open files after java.io.IOException: Connection to n

[jira] [Updated] (KAFKA-7790) Trogdor - Does not time out tasks in time

[ https://issues.apache.org/jira/browse/KAFKA-7790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-7790: --- Description: All Trogdor task specifications have a defined `startMs` and

[jira] [Updated] (KAFKA-7755) Kubernetes - Kafka clients are resolving DNS entries only one time

[ https://issues.apache.org/jira/browse/KAFKA-7755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Loïc Monney updated KAFKA-7755: --- Affects Version/s: (was: 2.1.1) (was: 2.2.0) > Kubernetes - Kafka

[jira] [Resolved] (KAFKA-7695) Cannot override StreamsPartitionAssignor in configuration

[ https://issues.apache.org/jira/browse/KAFKA-7695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dmitry Buykin resolved KAFKA-7695. -- Resolution: Not A Bug > Cannot override StreamsPartitionAssignor in configuration >

[jira] [Commented] (KAFKA-7789) SSL-related unit tests hang when run on Fedora 29

[ https://issues.apache.org/jira/browse/KAFKA-7789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16735827#comment-16735827 ] ASF GitHub Bot commented on KAFKA-7789: --- tombentley commented on pull request #6096: KAFKA-7789:

[jira] [Commented] (KAFKA-7695) Cannot override StreamsPartitionAssignor in configuration

[ https://issues.apache.org/jira/browse/KAFKA-7695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16735816#comment-16735816 ] Dmitry Buykin commented on KAFKA-7695: -- Hi [~vvcephei], Yes, I'm agree that this task should be

[jira] [Commented] (KAFKA-7755) Kubernetes - Kafka clients are resolving DNS entries only one time

[ https://issues.apache.org/jira/browse/KAFKA-7755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16735806#comment-16735806 ] ASF GitHub Bot commented on KAFKA-7755: --- rajinisivaram commented on pull request #6049: KAFKA-7755

[jira] [Created] (KAFKA-7790) Trogdor - Does not time out tasks in time

Stanislav Kozlovski created KAFKA-7790: -- Summary: Trogdor - Does not time out tasks in time Key: KAFKA-7790 URL: https://issues.apache.org/jira/browse/KAFKA-7790 Project: Kafka Issue

[jira] [Commented] (KAFKA-7361) Kafka wont reconnect after NoRouteToHostException

[ https://issues.apache.org/jira/browse/KAFKA-7361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16735755#comment-16735755 ] Igor Soarez commented on KAFKA-7361: https://issues.apache.org/jira/browse/KAFKA-7755 seems to be

[jira] [Commented] (KAFKA-7789) SSL-related unit tests hang when run on Fedora 29

[ https://issues.apache.org/jira/browse/KAFKA-7789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16735729#comment-16735729 ] Tom Bentley commented on KAFKA-7789: This is caused by Fedora tightening up its system-wide crypto

[jira] [Created] (KAFKA-7789) SSL-related unit tests hang when run on Fedora 29

Tom Bentley created KAFKA-7789: -- Summary: SSL-related unit tests hang when run on Fedora 29 Key: KAFKA-7789 URL: https://issues.apache.org/jira/browse/KAFKA-7789 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-7757) Too many open files after java.io.IOException: Connection to n was disconnected before the response was read

[ https://issues.apache.org/jira/browse/KAFKA-7757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16735600#comment-16735600 ] Rajini Sivaram commented on KAFKA-7757: --- This could be due to KAFKA-7697. Can you get a thread dump